Aggregateアクションを使用してテーブル間でデータを変換する
この記事は、Data Platformの独自のPythonデータ処理エンジンを使用するアクションについて説明しています
目的
この記事は、Data Platformの独自のPythonデータ処理エンジンを使用するアクションについて説明しています。Apache Sparkクラスターを使用するには、Aggregate PySparkアクションを参照してください。
Aggregate アクションを使用すると、既存の任意のテーブルからデータを転送し、任意の他のテーブル(同じテーブルを含む)に転送できます。Aggregateアクションの範囲は広く、SQLの処理や複数のテーブルの結合、結果のグループ化などが可能です。そのため、データ処理ワークフローで最もよく使用されるアクションの1つです。
Aggregateアクションの設定
Aggregateアクションは、1つ以上のソーステーブルのリストで構成され、その値が単一の宛先テーブルに抽出されて配置されます。各宛先属性はソース属性にマッピングする必要があります。
複数のソーステーブルを選択した場合、SQLで行うように結合条件を指定する必要があります。
Aggregateアクションの設定で宛先属性をマッピングしないと、アクションを実行するとエラーが発生します。宛先フィールドを空のままにしたい場合は、マッピングされた属性のリストから削除するだけです。
宛先属性がマッピングされた属性のリストから削除されると、次の動作が期待されます。
- Aggregateアクションが新しい行を挿入する場合、宛先属性列にNULL値を入力します。
- Aggregateアクションが既存の行を更新する場合(既存のデータ上に挿入する場合)、その値がNULLかどうかにかかわらず、以前の値をそのままにします。
単一のソーステーブルと複数のソーステーブルの両方のユースケース例は、以下に記載されています。
生データを主テーブルに転送する
新しいAggregateアクションを作成します。
ソース(左)と宛先テーブルを選択します。可能な場合、属性は自動的に割り当てられます。ソースと宛先の間でどの属性がマッピングされるかを手動で選択することもできます。
必要に応じて、MAP ボタンをクリックし、SQL または txt を選択して、マッピングをSQLまたはプレーンテキストに変更できます。
属性セクションでは、各属性の計算モードを変更することもできます。上記の例では、SELECT が選択されていますが、他のオプションも利用可能です。
右上の作成を押してアクションを作成します。
参照を主テーブルに結合する
結合を指定するには、Add a sourceをクリックし、結合するテーブルを選択するように求められます。ドロップダウンメニューから結合の種類を選択し、UIに結合条件を入力します。複数のソーステーブルを結合できます。
結合されたすべてのテーブルの属性は、下部の属性セクションでドロップダウンメニューから選択するか、SQLを使用して選択できます。
アクションの設定を構成する
属性のマッピングに満足したら、設定タブを使用してアクション設定を構成します。
アドバンスモードを使用する
アクションのJSON設定ファイルにアクセスする必要がある場合は、Advancedをページの上部にクリックしてアドバンスモードを有効にできます。
さらに詳しく
トレーニングや技術的なサポートが必要な場合は、営業担当者にお問い合わせください、またはこのリンクをクリックして見積もりを依頼し、プロフェッショナルサービスの専門家にプロジェクトのカスタム分析を依頼してください。
専用DiscordチャネルでData Platformを構築するチームと直接質問し、フィードバックを共有し、交流できます。
OVHcloudサービスについてサポートが必要な場合は、ヘルプセンターでリクエストを作成してください。
コミュニティに参加してください。

