DataWorks:データプッシュノード

背景情報

データプッシュノードは、Node Context Parameters を使用して、上流の SQL クエリノード（代入ノード、Hologres SQL ノード、ClickHouse SQL ノードなど）の出力パラメーターを取得します。その後、これらのパラメーターをプッシュ本文内のプレースホルダーとして編集し、内容を送信先に送信できます。

• 上流の SQL クエリノードの実行が完了すると、クエリ結果を含む outputs という名前のノード出力パラメーターが生成されます。

• 下流のデータプッシュノードでは、Node Context Parameters を使用して、上流ノードの outputs パラメーターを取得し、データプッシュノードの入力パラメーターとしてバインドします。

• データプッシュノードの構成で、入力パラメーターをプッシュ内容として参照し、送信先を設定して内容をプッシュします。

サポートされる上流の SQL クエリノード：

• 代入ノード：MaxCompute SQL クエリノードは直接サポートされていません。必要に応じて、代入ノードを作成して MaxCompute データをクエリできます。

• その他の SQL ノード：Hologres SQL ノード、ClickHouse SQL ノード、AnalyticDB for MySQL SQL ノード、AnalyticDB for PostgreSQL SQL ノード、StarRocks SQL ノード、PostgreSQL ノード、および MySQL ノード。

前提条件

• ワークスペースを作成済み である必要があります。

• サーバーレスリソースグループを作成済み であり、対象の DataWorks ワークスペースに関連付けられている必要があります。

制限事項

• 各プッシュ送信先ごとのデータサイズ制限は以下のとおりです。

  送信先	限界を押し広げる
  DingTalk	プッシュデータサイズは 20 KB を超えてはなりません。
  Lark	プッシュデータサイズは 20 KB を超えてはならず、画像は 10 MB 未満である必要があります。
  WeCom	各ボットは、毎分20 メッセージまでしか送信できません。
  Teams	プッシュデータサイズは 28 KB を超えてはなりません。
  メール	各データプッシュタスクでは、メール本文を 1 つだけサポートします。メール本文がすでに追加されている場合、別の本文を追加することはできません。その他の制限については、ご利用のメールサービスの SMTP 制限をご確認ください。

• Data Push がサポートするリージョン：

  中国 (杭州)、中国 (上海)、中国 (北京)、中国 (深セン)、中国 (成都)、中国 (香港)、シンガポール、日本 (東京)、米国 (シリコンバレー)、米国 (バージニア)。

Data Studio への移動

1. DataWorks コンソールの ワークスペース一覧 ページに移動します。上部ナビゲーションバーで目的のリージョンを選択し、目的のワークスペースを見つけ、操作 列の ショートカット > Data Studio を選択します。

2. 左側のナビゲーションウィンドウで、 アイコンをクリックして Data Studio ページに移動します。

プッシュパイプラインの作成

SQL クエリノードとデータプッシュノードで構成されるパイプラインを作成・構成します。

1. ワークフローを作成 し、ワークフロー内に SQL クエリノードとデータプッシュノードを作成します。

2. SQL クエリノードを作成し、プッシュするデータをクエリするための SQL コードを追加します。

   説明

   • データプッシュノードは、ODPS SQL からのクエリデータを直接取得することをサポートしていません。代入ノードを作成 し、代入ノード 内でプッシュするデータをクエリできます。

   • その他の SQL クエリノードは通常どおり作成できます。

3. SQL クエリノードを構成します。

   ノード右側の Scheduling Settings パネルで、Compute Resource、Resource Group for Scheduling、および Same-cycle Dependency を構成する必要があります。上流ノードが存在しない場合は、Add Root Node を選択できます。出力パラメーターの構成は以下のとおり異なります。

   ノードタイプ	構成に関する注意事項
   代入ノード	代入ノードにはデフォルトのノード出力パラメーターがあります。追加の出力パラメーター構成は不要です。
   その他の SQL クエリノード	その他の SQL クエリノードにはデフォルトのノード出力パラメーターがありません。ノード右側の Scheduling Settings パネルで、Node Context Parameters を開き、Node output parameters を見つけ、Add Assignment Parameter をクリックして、現在のクエリ結果をパラメーター経由で下流のデータプッシュノードに渡す必要があります。

4. データプッシュノードを作成済み であり、SQL クエリノードを上流ノードとして構成しています。

   1. Scheduling Settings をクリックします。Scheduling Dependency > Same-cycle Dependency セクションで、Add をクリックし、ノード名で検索して、作成した SQL クエリノードをデータプッシュノードの上流ノードとして追加します。

   2. Scheduling Policy > Resource Group for Scheduling セクションで、作成したサーバーレスリソースグループを選択します。

   3. Node Context Parameters > Input Parameters セクションで、Add parameters をクリックし、SQL クエリノードの 出力パラメーター を値ソースとして追加し、データプッシュノードの 入力パラメーター としてバインドします。

プッシュ送信先と内容の構成

データプッシュノードの編集ページで、プッシュタイトルをカスタマイズし、プッシュ送信先と本文内容を構成します。

データプッシュのデバッグ

構成が完了したら、SQL クエリノードとデータプッシュノードを保存します。その後、ワークフロー上部のツールバーにある アイコンをクリックして、データプッシュタスクをデバッグします。

次のステップ

• スケジュール設定の構成：プロジェクトディレクトリ内のノードを定期的にスケジュール実行したい場合は、ノード右側の Scheduling Settings パネルで Scheduling Policy を構成します。

• ノードのデプロイ：タスクを本番環境にデプロイしたい場合は、ページ上の アイコンをクリックしてデプロイメントプロセスを開始します。プロジェクトディレクトリ内のノードは、本番環境にデプロイされた後でのみ定期的なスケジュールが適用されます。