データプッシュノードは、Data Studio ワークフローからのクエリ結果を DingTalk、Lark、WeCom、Teams、またはメールに送信し、チームが最新のデータを即座に把握できるようにします。
バックグラウンド
データプッシュノードは、[入出力パラメーター] を介して、上流の SQL クエリノード (代入ノード、Hologres SQL ノード、ClickHouse SQL ノードなど) から出力パラメーターを取得します。これらのパラメーターをメッセージコンテンツにプレースホルダーとして埋め込み、選択した宛先にプッシュできます。
プロセス:
上流の SQL ノードが完了し、クエリ結果を含む
outputsパラメーターを生成します。データプッシュノードは、[入出力パラメーター] を介して
outputsパラメーターを取得し、ノード入力パラメーターとしてバインドします。メッセージで入力パラメーターを参照し、宛先を設定してプッシュすることで、構成と送信を行います。
サポートされている上流 SQL ノード:
代入ノード: MaxCompute SQL クエリに使用します (MaxCompute SQL ノードへの直接接続はまだサポートされていません)。
その他の SQL ノード: Hologres SQL ノード、ClickHouse SQL ノード、EMR Spark SQL ノード、EMR Hive ノード、MaxCompute Script ノード、AnalyticDB for PostgreSQL ノード、および MySQL ノード。
前提条件
ワークスペースを作成していること。
サーバーレスリソースグループを追加し、DataWorks ワークスペースにバインドしていること。
制限事項
サイズとレートの制限:
宛先
制限
DingTalk
メッセージあたり最大 20 KB。
Lark
メッセージあたり最大 20 KB。イメージは 10 MB 未満である必要があります。
WeCom
ボットあたり毎分最大 20 メッセージ。
Teams
メッセージあたり最大 28 KB。
メール
タスクごとに 1 つのメール本文。追加の制限については、メールプロバイダーの SMTP 制限をご参照ください。
データプッシュでサポートされているリージョン:
中国 (杭州)、中国 (上海)、中国 (北京)、中国 (深圳)、中国 (成都)、中国 (香港)、シンガポール、米国 (シリコンバレー)、米国 (バージニア)。
Data Studio へのアクセス
DataWorks コンソールの ワークスペースページに移動します。上部のナビゲーションバーで、目的のリージョンを選択します。目的のワークスペースを見つけ、[アクション] 列で を選択します。
左側のナビゲーションウィンドウで、
アイコンをクリックします。
ワークフローの作成
SQL クエリノードを構成し、SQL クエリコードを追加します。
説明データプッシュノードは ODPS SQL に直接アクセスできません。MaxCompute データをクエリするには、代わりに 代入ノードを作成します。
ノードの右側で [スケジューリング] を設定します。[コンピューティングリソース]、[リソースグループ] を選択し、[同一サイクル依存関係] の上流ノードを選択します (存在しない場合は [ワークスペースルートノードを使用] を選択します)。出力パラメーターを構成します:
ノードタイプ
構成
代入ノード
出力パラメーターは自動的に作成されるため、設定は不要です
その他の SQL ノード
手動で出力パラメーターを追加します: に移動し、[代入パラメーターの追加] をクリックします。
データプッシュノードを作成し、下流ノードとして構成します。
[スケジューリング] をクリックし、 で [追加] をクリックし、SQL クエリノードを上流依存関係として選択します。
で、作成したサーバーレスリソースグループを選択します。
で、[パラメーターの作成] をクリックします。SQL ノードからの出力パラメーターをデータプッシュノードの入力パラメーターとしてバインドします。
プッシュの構成
宛先の設定
データプッシュノードで、[宛先] を選択します。宛先がまだ存在しない場合は、[宛先の作成] をクリックするか、DataService Studio でプッシュターゲットを構成します。
説明既存のプッシュターゲットを変更するには、 に移動します。
宛先タイプを選択します:
DingTalk、Lark、WeCom、または Teams の場合
パラメーター | 説明 | |
宛先 | [DingTalk]、[Lark]、[WeCom]、または [Teams] を選択します。 | |
宛先名 | わかりやすい名前を選択します。 | |
Webhook | メッセージングプラットフォームから Webhook URL を貼り付けます: | |
メールの場合
パラメーター | 説明 |
宛先 | [メール] を選択します。 |
SMTP ホスト | メールサーバーのアドレス。 |
SMTP ポート | サーバーポート (デフォルト: 465)。 |
送信者アドレス | メッセージの送信に使用するメールアドレス。 |
送信者ニックネーム | オプションの表示名。 |
SMTP アカウント | SMTP サーバーのログインユーザー名。 |
SMTP パスワード | 認証パスワード。 |
受信者アドレス | メールの受信者 (複数のアドレスの場合はカンマ区切り)。 |
メッセージの構成
Markdown、テーブル、またはメール本文を使用してコンテンツをフォーマットできます:
Markdown:
${parameter_name}プレースホルダーを使用して入力パラメーターを参照しますテーブル: 上流の SQL ノードのフィールド名を [パラメーター] として使用します
メール本文:
データプッシュタスクごとに 1 つのメール本文に制限します。
メール本文は、宛先がメールの場合にのみレンダリングされます (Webhook メッセージでは非表示)。
テスト
両方のノードを構成して保存した後、ツールバーの
アイコンをクリックしてデータプッシュタスクをテストします。
次のステップ
ノードのスケジューリング: 定期的なスケジュールでノードを実行するには、[スケジューリング] の [スケジューリングポリシー] を構成します。
ノードのデプロイメント: 本番環境でタスクを実行するには、
アイコンをクリックしてデプロイメントプロセスを開始します。ノードは、本番環境にデプロイされた後にのみスケジュールどおりに実行されます。