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

仕組み

データプッシュノードは、[ノードコンテキストのパラメーター] を使用して、上流の SQL クエリノードと代入ノードから出力パラメーターを取得します。これらのパラメーターをメッセージ本文でプレースホルダーとして使用し、送信先にプッシュできます。

• SQL クエリノードは実行後、クエリ結果を含む outputs パラメーターを生成し、下流ノードに渡します。詳細については、「ノードコンテキストの設定」をご参照ください。

• データプッシュノードでメッセージ本文を設定する際、Markdown コンポーネントで ${パラメーター名} 形式を使用して、上流ノードの出力パラメーターを参照して表示できます。

• テーブルコンポーネントでデータを表示するには、コンポーネントの関連パラメーター設定で、上流の SQL クエリからフィールド名を選択します。

前提条件

• DataWorks サービスが有効化されていること。詳細については、「購入ガイド」をご参照ください。

• DataWorks ワークスペースが作成されていること。詳細については、「ワークスペースの作成」をご参照ください。

• DataWorks ワークスペースでワークフローが作成されていること。

• このノードはサーバーレスリソースグループでのみ実行できるため、サーバーレスリソースグループが必要です。サーバーレスリソースグループの購入と使用については、「サーバーレスリソースグループの使用」をご参照ください。

• リソースグループでパブリックネットワークアクセスが有効になっていること。詳細については、「ネットワーク接続ソリューションの概要」をご参照ください。

制限事項

• 異なる送信先にデータをプッシュする場合、以下のデータサイズ制限が適用されます：

  • DingTalk：メッセージサイズは 20 KB を超えることはできません。

  • Lark：メッセージサイズは 20 KB を超えることはできず、画像は 10 MB 未満である必要があります。

  • WeCom：各チャットボットは、1 分あたり 20 メッセージまでしか送信できません。

  • Teams：メッセージサイズは 28 KB を超えることはできません。

  • メール：各データプッシュタスクは、1 つのメール本文のみをサポートします。その他の制限については、お使いのメールサービスプロバイダーの SMTP 制限をご参照ください。

• データプッシュノードは、次のリージョンのワークスペースでのみ利用可能です：中国 (杭州)、中国 (上海)、中国 (北京)、中国 (深圳)、中国 (成都)、中国 (香港)、シンガポール、マレーシア (クアラルンプール)、米国 (シリコンバレー)、米国 (バージニア)、ドイツ (フランクフルト)。

1. 上流ノードの作成

データプッシュノードは、上流ノードのコンテキストから [コンテキストパラメーター] を取得し、それらを送信先にプッシュします。データプッシュノードを作成する前に、上流の SQL クエリノード または 代入ノード を作成してください。

2. データプッシュノードの作成

1. ワークフローキャンバスで、 をクリックしてデータプッシュノードを作成します。

   パラメーター	説明
   [ノードタイプ]	ドロップダウンリストから [データプッシュ] を選択します。
   [パス]	手順1 の上流ノードを含むパスを選択します。
   [名前]	ノードの名前を入力します。

2. 新しいデータプッシュノードをダブルクリックして設定ページを開きます。

3. 右側のペインで [プロパティ] をクリックします。スケジュールの依存関係 > 依存する先祖ノード で、追加 をクリックし、手順1 で作成したノードを上流の依存関係として設定します。

4. [プロパティ] パネルの リソースプロパティ > Resource Group for Scheduling で、2024 年 6 月 28 日以降に作成されたサーバーレスリソースグループを選択します。リソースグループがこの日付より前に作成された場合は、チケットを送信してアップグレードする必要があります。

5. [プロパティ] パネルの ノードコンテキストのパラメーター > このノードの入力パラメーター で、追加 をクリックして入力パラメーター を作成します。その値として、手順1 のクエリノードの出力パラメーター を選択します。その後、スケジューリング設定 パネルを閉じます。

6. ノードの設定ページで、メッセージの送信先、タイトル、本文を設定します。

   1. データプッシュ対象 ドロップダウンリストから送信先を選択します。目的の送信先がリストにない場合は、[データプッシュ送信先の作成] をクリックして作成します。

      パラメーター	説明
      [タイプ]	サポートされているタイプ：DingTalk、Lark、WeCom、Teams、メール。
      [オブジェクト名]	送信先の名前。
      [Webhook]	DingTalk、Lark、または WeCom チャットボットの Webhook URL、Teams の受信 Webhook、またはメールの SMTP 詳細。この情報はターゲットプラットフォームから取得します。 説明 Lark ボット Webhook の取得方法については、「Lark Webhook トリガーを設定する」をご参照ください。 Teams Webhook の取得方法については、「Microsoft Teams ワークフローを使用して受信 Webhook を作成する」をご参照ください。

      プッシュ送信先を管理するには：

      1. DataWorks コンソールにログインします。 左側のナビゲーションウィンドウで、[DataService Studio] をクリックします。 表示されるページで、ドロップダウンリストから目的のワークスペースを選択し、[DataService Studioに移動] をクリックします。

      2. [サービス開発] ページで、左下隅にある 設定アイコンをクリックし、プッシュオブジェクトの管理 タブに移動します。このタブでは、既存の送信先を管理したり、[データプッシュ送信先の作成] をクリックして新しい送信先を追加したりできます。詳細については、「Webhook データプッシュ送信先の作成」をご参照ください。

   2. [タイトル]：メッセージのタイトルを入力します。

   3. [本文]：Markdown およびテーブルコンポーネントを追加できます。詳細については、「プッシュコンテンツの設定」をご参照ください。

      説明

      • 上流ノードが SQL クエリノードの場合：

        • データプッシュの Markdown 本文では、SQL クエリのフィールド名を ${field_name} 形式のプレースホルダーとして使用して、上流の出力パラメーターを取得します。

        • データプッシュ本文のテーブルでは、上流の SQL クエリのフィールド名を[パラメーターの関連付け] として使用してデータを取得します。

      • 上流ノードが代入ノードの場合、メッセージ本文で ${入力パラメーター名} 形式のプレースホルダーを使用する必要があります。${入力パラメーター名} は、データプッシュノードで設定した[このノードの入力パラメーター] の名前です。

7. 保存アイコンをクリックして、データプッシュノードを保存します。

3. タスクの実行とデプロイ

データプッシュワークフローを設定した後、テストして正しく実行されることを確認し、タスクをコミットしてデプロイします。

1. ワークフローキャンバスで、 実行アイコンをクリックしてワークフローを実行します。

2. すべてのノードに 成功アイコンが表示された後、 コミットアイコンをクリックしてワークフローをコミットします。

3. コミット ダイアログボックスで、コミットするノードを選択し、入出力の不一致によるアラートを無視する チェックボックスにチェックを入れます。

4. コミット をクリックします。

5. ノードが正常にコミットされた後、それらをデプロイします。詳細については、「タスクを公開」をご参照ください。

ベストプラクティス

データプッシュノードは、シンプルプッシュ、組み合わせプッシュ、スクリプトによるプッシュ、条件付きプッシュ、MaxCompute プッシュなど、いくつかのワークフローパターンをサポートしています。詳細については、「ベストプラクティス：ワークフローでのデータプッシュノードの設定」をご参照ください。

次のステップ

デプロイ後は、オペレーションセンターでタスクを管理できます。詳細については、「自動トリガーノードの基本的な O&M 操作の実行」をご参照ください。