すべてのプロダクト
Search
ドキュメントセンター

MaxCompute:MaxFrame API

最終更新日:Jan 17, 2025

MaxFrame APIは、互換性APIとMaxFrame固有のAPIに分類されます。 互換性APIは、Pandasなどのさまざまな標準ライブラリと統合して、データ処理を容易にします。 タスクを分散実行するために、MaxFrame固有のAPIが導入されました。 MaxFrame APIを使用してジョブを開発すると、標準データベースと同様のデータ操作エクスペリエンスが得られ、MaxFrameプラットフォームで大規模なデータ処理タスクを効率的に実行できます。

MaxFrame固有のAPI

APIタイプ

API名

説明

タスクセッション

new_session

MaxFrameジョブセッションを開始します。 new_sessionメソッドは、タスク全体の実行を初期化するためにスクリプトの最初に呼び出されます。 その後のデータ処理は、初期化中に構築されたセッションオブジェクトとバックエンドサービスとの間の対話に基づいて実行される。

入力 /出力

read_odps_table

MaxComputeテーブル全体、テーブルの特定のパーティション、またはテーブルの特定の列のデータに基づいてDataFrameオブジェクトを構築します。

read_odps_query

MaxCompute SQL文のクエリ結果に基づいてDataFrameオブジェクトを構築します。

to_odps_table

DataFrameデータをMaxComputeテーブルに書き込みます。

タスク実行

execute

タスクを実行します。 MaxFrameは遅延コンピューティングモデルを使用します。 タスクの実行は、executeメソッドが呼び出されたときにのみトリガーされます。 このAPIにより、データ変換をパイプラインの最後まで遅らせることができます。 このようにして、1つのタスクで複数の操作を同時に実行できます。 これにより、クライアントとデータベース間で送信されるデータ量が削減され、パフォーマンスが向上します。

タスク結果の取得

fetch

タスクの計算結果を取得します。 計算結果はクライアントに直接送信されません。 これにより、送信されるデータ量やクライアントの負荷を軽減することができる。 結果データの一部をチェックするには、executeメソッドの後にfetchメソッドを呼び出して結果データを取得します。

MaxFrame for Pandas

MaxFrameでサポートされているPandas API