0
私は一定の時間間隔でトリガーするGoogleクラウドデータフロージョブを持っています。データフロージョブが完了した後で、ジョブのステータスを特定のメールIDに送信した後、メールをトリガーする必要があります。あなたはまた、result.metrics()
によって返された電子メールに完成したジョブのメトリックを含めることができデータフロージョブが特定のdlに完了した後にメールをトリガーする方法
PipelineResult result = pipeline.run();
PipelineResult.State status = result.waitUntilFinish();
// send email
を行うことができます
おかげで、 ダモダル川
DataFlowのジョブIDがありますか(ジョブをスケジュールした後にアクセスできますか?) –
いいえ、ジョブIDはGoogleのデータフローによって作成されるため、ジョブIDはありません。問題は、ジョブのステータスでジョブが完了した後にメールを送信するためのAPIが組み込まれているかどうかです。 – Damodar
Pythonを使用している場合、ジョブをスケジュールすると、DataFlow Job IDを返すメソッドがあります。私はかなりJava SDKが同じであると確信しています。電子メールを送信するための組み込みメソッドはないと思いますが、DataFlow Job IDを取得するとCRONのDataFlow APIにクエリを送信してステータスを確認し、後で電子メールを送信できます。 –