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 が選択されていますが、他のオプションも利用可能です。
右上の作成を押してアクションを作成します。
参照を主テーブルに結合する
結合を指定するには、ソースを追加をクリックし、結合するテーブルを選択するように求められます。ドロップダウンメニューから結合の種類を選択し、UIに結合条件を入力します。複数のソーステーブルを結合できます。
結合したすべてのテーブルの属性は、下部の属性セクションでドロップダウンメニューまたはSQLを使用して選択できます。
アクションの設定を構成する
属性のマッピングに満足したら、設定タブを使用してアクション設定を構成します。
アドバンスモードを使用する
アクションのJSON設定ファイルにアクセスする必要がある場合は、Advancedをページの上部にクリックしてアドバンスモードを有効にできます。
さらに詳しく
トレーニングや技術的なサポートを受けてソリューションを実装するには、営業担当者にお問い合わせください、またはプロフェッショナルサービスページにアクセスして、見積もりを依頼し、専門家がプロジェクトを分析するようにしてください。
Data Platformを構築するチームと直接質問し、フィードバックを共有し、相互作用するには、専用のDiscordチャネルにアクセスしてください。
OVHcloudサービスについてサポートが必要な場合は、ヘルプセンターでリクエストを作成してください。
コミュニティに参加してください。

