データプッシュノードで SQL クエリ結果を DingTalk と WeCom に送信 - DataWorks

Data Push Node は、Data Studio ワークフロー内の他のノードから取得したクエリ結果を、DingTalk、Lark、WeCom、Microsoft Teams、メールなどのさまざまな宛先に送信します。これにより、チームメンバーがタイムリーにデータ更新を受け取ることができます。

背景情報

Data Push Node は、入力および出力パラメーター を使用して、上流の SQL クエリノード（Assignment Node、Hologres SQL Node、ClickHouse SQL Node など）から出力パラメーターを取得します。その後、これらのパラメーターをメッセージ本文内のプレースホルダーとして使用し、設定済みの宛先に送信します。

上流の SQL クエリノードが実行されると、結果を含む outputs という名前の出力パラメーターが生成されます。
下流の Data Push Node では、入力および出力パラメーター を使用して、上流ノードの outputs パラメーターを取得し、入力パラメーターとして割り当てます。
Data Push Node では、メッセージコンテンツを構成して入力パラメーターを参照し、宛先を指定します。その後、ノードがコンテンツをプッシュします。

以下の上流の SQL クエリノード がサポートされています。

Assignment Node：Data Push Node は MaxCompute SQL Node から直接データを取得できません。このデータを使用するには、まず Assignment Node を使用してクエリを実行する必要があります。
その他の SQL ノード：Hologres SQL Node、ClickHouse SQL Node、EMR Spark SQL Node、EMR Hive Node、MaxCompute Script Node、ADB for PostgreSQL Node、および MySQL Node。

前提条件

ワークスペースが作成済みです。
Serverless Resource Group が作成済みで、対象の DataWorks ワークスペースにバインドされています。

制限事項

Data Push 機能には、宛先ごとに以下のデータサイズ制限があります。

宛先	制限
DingTalk	データサイズは 20 KB を超えてはなりません。
Lark	データサイズは 20 KB を超えてはならず、画像は 10 MB 未満である必要があります。
WeCom	各ボットは 1 分間に最大 20 件のメッセージを送信できます。
Teams	データサイズは 28 KB を超えてはなりません。
Email	各 Data Push タスクは 1 つのメール本文のみをサポートします。その他の制限については、ご利用のメールサービスプロバイダーの SMTP 制限をご確認ください。

Data Push 機能は以下のリージョンで利用可能です。
中国 (杭州)、中国 (上海)、中国 (北京)、中国 (深セン)、中国 (成都)、中国 (香港)、シンガポール、日本 (東京)、米国 (シリコンバレー)、米国 (バージニア)。

Data Studio への移動

DataWorks コンソールのワークスペースページに移動します。上部ナビゲーションバーで目的のリージョンを選択し、目的のワークスペースを見つけ、操作列で ショートカット > Data Studio を選択します。
左側のナビゲーションウィンドウで、アイコンをクリックして Data Studio ページを開きます。

データプッシュワークフローの作成

SQL クエリノードと Data Push Node を含むワークフローを作成および構成します。

スケジュールワークフローを作成し、SQL クエリノードと Data Push Node を追加します。
SQL クエリノードで、プッシュするデータを取得するためのクエリを記述します。
説明
- Data Push Node は MaxCompute SQL ノードから直接データを取得できません。このデータを使用するには、まず Assignment Node を作成し、Assignment Node でプッシュする結果情報をクエリする必要があります。
- その他の種類の SQL クエリノードは直接作成および使用できます。

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

ノード構成ペインの右側で、スケジューリング セクションに移動し、計算リソース、リソースグループ、および 同サイクル依存関係 を構成します。上流ノードがない場合は、ワークスペースルートノードを使用 を選択できます。出力パラメーターの構成はノードタイプによって異なります。

ノードタイプ	説明
Assignment Node	Assignment Node にはデフォルトの出力パラメーターがあります。追加の構成は不要です。
その他の SQL クエリノード	これらのノードにはデフォルトの出力パラメーターがありません。右側のスケジューリングセクションで、入力および出力パラメーターセクションを見つけ、ノード出力パラメーターの下で代入パラメーターを追加をクリックして、クエリ結果を下流ノードに渡します。

Data Push Node を作成し、SQL クエリノードをその上流ノードとして構成します。
1. スケジューリング をクリックします。スケジューリング依存関係 > 同サイクル依存関係 セクションで、SQL クエリノードを名前で検索し、追加をクリックして上流ノードに設定します。
2. スケジューリングポリシー > リソースグループ フィールドで、Serverless Resource Group を選択します。
3. 入力および出力パラメーター > 入力パラメーター セクションで、パラメーターを追加 をクリックします。新しいパラメーターを構成し、SQL クエリノードの 出力パラメーター を値のソースとして使用します。

宛先とコンテンツの構成

Data Push Node のエディターで、カスタムプッシュタイトルを定義し、宛先とメッセージ本文を構成できます。

宛先の構成

宛先セクションで、宛先を選択します。

宛先が存在しない場合は、宛先を作成 をクリックします。または、DataService Studio でデータプッシュ宛先を設定することもできます。
説明
宛先を変更するには、DataService Studio > Data Push に移動してください。

宛先の作成 ページで、以下のパラメーターを構成します。

Webhook

パラメーター	説明
宛先	DingTalk、Lark、WeCom、または Teams を選択します。
宛先名	宛先のカスタム名を入力します。
Webhook	選択した宛先の Webhook URL を取得し、ここに入力します。 Lark ボットの Webhook を取得するには、「Lark Webhook トリガーの構成」をご参照ください。 Teams の Webhook を取得するには、「Microsoft Teams のワークフローで受信 Webhook を作成する」をご参照ください。

Email

パラメーター	説明
宛先	Email を選択します。
SMTP ホスト	SMTP サーバーアドレス。
SMTP ポート	SMTP サーバーポート。デフォルトは 465 です。
送信者アドレス	送信者のメールアドレス。
送信者表示名	任意。送信者のカスタム表示名。
SMTP アカウント	SMTP ログインアカウント。
SMTP パスワード	SMTP アカウントのパスワード。
受信者アドレス	受信者のメールアドレス。複数のアドレスはカンマで区切ります。

メッセージ本文の設定

メッセージ本文は Markdown、テーブル、または専用のメール本文を使用して構成できます。

Markdown エディターでは、上流ノードの 入力パラメーター の値を含めるために、${parameter_name} 形式のプレースホルダーを使用できます。
メッセージ本文でテーブルを構成する場合、上流の SQL クエリノードの出力にあるフィールド名を パラメーター として使用して、テーブルに値を入力できます。
メール通知用の専用本文を追加できます。以下の点にご注意ください。
- 各 Data Push タスクは 1 つのメール本文のみをサポートします。
- メール本文は Email 宛先に対してのみレンダリングされます。Webhook などの他の宛先では、メール本文 セクションのコンテンツは無視されます。

ワークフローの実行とデバッグ

SQL クエリノードと Data Push Node の構成および保存後、ワークフローツールバーのアイコンをクリックしてタスクを実行およびデバッグします。

次のステップ

ノードのスケジューリングを構成：ノードをスケジュール実行するには、スケジューリングポリシー の スケジューリング ペインでプロパティを構成します。
ノードをデプロイ：本番環境でタスクを実行するには、アイコンをクリックしてデプロイメントプロセスを開始します。スケジュールタスクは、本番環境にデプロイされた後にのみ実行されます。