DataWorks:データプッシュノードを作成する

概要

データプッシュノードは、先祖ノードの [出力] パラメーターを受信し、出力パラメーターをデータプッシュノードの入力パラメーターとして使用して、特定の宛先にデータをプッシュします。たとえば、データプッシュノードは、コンテンツ内のプレースホルダーを使用して、先祖ノードの出力パラメーターを取得するようにプッシュできます。データプッシュノードは、先祖 SQL クエリノードと代入ノードの出力パラメーターを取得できます。

• SQL クエリノードがデータをクエリした後、outputs パラメーターが生成され、ノードはクエリ結果を子孫ノードに渡します。 入力パラメーターと出力パラメーターを設定する方法については、「入力パラメーターと出力パラメーターを設定する」をご参照ください。

• Markdown を使用して特定の宛先にプッシュするコンテンツを表示する場合は、コンテンツに ${パラメーター名} を追加して、先祖ノードの出力パラメーターを参照できます。

• 表を使用して特定の宛先にプッシュするコンテンツを表示する場合は、先祖 SQL クエリノードによってクエリされたフィールドを入力パラメーターとして選択してデータを取得できます。

前提条件

• DataWorks がアクティブ化されている。詳細については、「DataWorks をアクティブ化する」をご参照ください。

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

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

• サーバーレスリソースグループが作成されている。サーバーレスリソースグループのみがサポートされています。サーバーレスリソースグループを作成および使用する方法については、「サーバーレスリソースグループを作成および使用する」をご参照ください。

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

制限

• データサイズの制限：

  • DingTalk にデータをプッシュする場合、データサイズは 20 KB を超えることはできません。

  • Lark にデータをプッシュする場合、データサイズは 20 KB を超えてはならず、イメージのサイズは 10 MB 未満である必要があります。

  • WeCom にデータをプッシュする場合、各チャットボットは 1 分あたり最大 20 件のメッセージを送信できます。

  • Microsoft Teams にプッシュするデータのサイズは、28 KB を超えることはできません。

  • Email にデータをプッシュする場合、各データプッシュタスクに 1 つの Email 本文のみを追加できます。Email 本文が追加されている場合、Email 本文を再度追加することはできません。制限の詳細については、使用されている Email サービスの簡易メール転送プロトコル（SMTP）の制限事項をご参照ください。

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

ステップ 1：SQL クエリノードまたは代入ノードを作成する

データプッシュノードは、先祖ノードの [出力] パラメーターを受信し、出力パラメーターをデータプッシュノードの入力パラメーターとして使用して、特定の宛先にデータをプッシュします。データプッシュノードを作成する前に、データプッシュノードの先祖ノードとしてSQL クエリノードまたは代入ノードを作成する必要があります。

ステップ 2：データプッシュノードを作成する

1. 作成したワークフローをダブルクリックします。ワークフローの構成タブで、 アイコンをクリックします。次に、「全般」セクションで「データプッシュ」をクリックします。「ノードの作成」ダイアログボックスで、パラメーターを設定し、「確認」をクリックします。次の表にパラメーターを示します。

   パラメーター	説明
   ノードタイプ	ノードのタイプ。ドロップダウンリストから「データプッシュ」を選択します。
   パス	ノードを格納するパス。パスは、ステップ 1 で作成したノードのパスと同じである必要があります。
   名前	データプッシュノードの名前。ビジネス要件に基づいて名前を指定できます。

2. 作成したデータプッシュノードをダブルクリックします。ノードの構成タブが表示されます。

3. ステップ 1 で作成した SQL クエリノードを、データプッシュノードの先祖ノードとして追加します。 データプッシュノードの構成タブの右側にあるナビゲーションウィンドウで、[プロパティ] をクリックします。 依存関係 セクションで、親ノード の下のドロップダウンリストから [ノード名] を選択し、フィールドに SQL クエリノードの名前を入力して、作成 をクリックします。

4. 「プロパティ」タブの [リソースグループ] セクションで、[リソースグループ] パラメーターを設定します。データプッシュ機能のリリース日である 2024 年 6 月 28 日以降に作成されたサーバーレスリソースグループを選択する必要があります。リソースグループが 2024 年 6 月 28 日より前に作成された場合は、チケットを送信 してリソースグループをアップグレードしてください。

5. ステップ 1 で作成した SQL クエリノードの outputs パラメーターをデータプッシュノードの入力パラメーターとして追加します。「プロパティ」タブで、[入力パラメーターと出力パラメーター] の右側にあるドロップダウン矢印をクリックします。[入力パラメーター] の右側にある [作成] をクリックします。次に、[パラメーター名] 列にパラメーター名を入力し、「値のソース」列のドロップダウンリストから outputs パラメーターを選択します。「プロパティ」タブを閉じます。

6. データプッシュノードの「宛先」、「タイトル」、および「本文」パラメーターを設定します。

   1. 宛先：「宛先」ドロップダウンリストから宛先を選択します。使用可能な宛先がない場合は、[宛先の作成] をクリックして宛先を作成します。次の表に、宛先を作成するためのパラメーターを示します。

      パラメーター	説明
      タイプ	プッシュチャネルを選択します。DingTalk、Lark、WeCom、Microsoft Teams、および Email がサポートされています。
      宛先名	ビジネス要件に基づいて名前を入力します。
      Webhook	DingTalk、Lark、または WeCom のチャットボット、または Microsoft Teams の Webhook URL を入力します。対応するプラットフォームで、関連するプッシュチャネルのチャットボットと Webhook URL を取得する必要があります。対応するプラットフォームで Email の SMTP を取得することもできます。 説明 Lark の Webhook URL の取得方法については、「Webhook トリガーを使用する」をご参照ください。 Teams の Webhook URL の取得方法については、「ワークフローを使用して Microsoft Teams の受信 Webhook を作成する」をご参照ください。

      DataService Studio で宛先を作成および管理する：

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

      2. DataService Studio ページの [サービス開発] タブの左下隅にある アイコンをクリックします。 表示されるページで、[宛先管理] タブをクリックします。 このタブで、[宛先の作成] をクリックして宛先を作成し、既存の宛先を管理できます。 詳細については、「データプッシュ」トピックの「Webhook 宛先を作成する」セクションをご参照ください。

   2. タイトル：関連フィールドに、ビジネス要件に基づいてデータプッシュノードのタイトルを入力します。

   3. 本文: [追加] をクリックし、[Markdown] または [表] を選択して、プッシュするコンテンツを構成します。 詳細については、「データプッシュ」トピックの「プッシュするコンテンツを構成する」セクションをご参照ください。

      説明

      • SQL クエリノードをデータプッシュノードの先祖ノードとして使用する場合は、次の点に注意してください。

        • [本文] セクションでプッシュするコンテンツを構成するために [Markdown] を選択した場合は、SQL クエリノードによってクエリされるフィールド名をプレースホルダーとして直接使用して、SQL クエリノードの出力パラメーターを取得できます。 プレースホルダーは、${フィールド名} 形式である必要があります。

        • 「本文」セクションで「表」を選択してプッシュするコンテンツを設定する場合、SQL クエリノードによってクエリされたフィールドを入力パラメーターとして追加してデータを取得できます。

      • 代入ノードをデータプッシュノードの先祖ノードとして使用する場合は、データプッシュノードの 入力パラメーター の名前をプレースホルダーとして使用して、代入ノードの出力パラメーターを取得する必要があります。 プレースホルダーは、${入力パラメーター名} 形式である必要があります。

7. 上部のツールバーで、 アイコンをクリックして設定を保存します。

ステップ 3：ワークフローでデータプッシュフローをテストし、ワークフローをコミットしてから、ワークフロー内のノードをデプロイする

ワークフロー内のすべてのデータプッシュフローを設定した後、ワークフローをダブルクリックします。ワークフローの構成タブで、すべてのデータプッシュフローをテストします。すべてのデータプッシュフローが期待どおりに実行された場合は、ワークフローをコミットし、ワークフロー内のノードをデプロイします。

1. ワークフローの構成タブで、 アイコンをクリックしてワークフローを実行します。

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

3. [コミット] ダイアログボックスで、コミットするノードを選択し、説明を入力して、[I/O の不整合アラートを無視する] を選択します。

4. [確認] をクリックします。

5. ノードをデプロイします。 詳細については、「ノードをデプロイする」をご参照ください。

ベストプラクティス

DataWorks DataStudio では、シンプルなデータプッシュ、組み合わせデータプッシュ、スクリプトデータプッシュ、条件付きデータプッシュ、MaxCompute データプッシュというプッシュメソッドを使用して、ワークフローにデータプッシュノードを作成し、特定の宛先にデータをプッシュできます。詳細については、「ワークフローでのデータプッシュノードの設定のベストプラクティス」をご参照ください。

次のステップ

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