2017-12-26 13 views
0

私は一定の時間間隔でトリガーするGoogleクラウドデータフロージョブを持っています。データフロージョブが完了した後で、ジョブのステータスを特定のメールIDに送信した後、メールをトリガーする必要があります。あなたはまた、result.metrics()によって返された電子メールに完成したジョブのメトリックを含めることができデータフロージョブが特定のdlに完了した後にメールをトリガーする方法

PipelineResult result = pipeline.run(); 
PipelineResult.State status = result.waitUntilFinish(); 
// send email 

を行うことができます

おかげで、 ダモダル川

+0

DataFlowのジョブIDがありますか(ジョブをスケジュールした後にアクセスできますか?) –

+0

いいえ、ジョブIDはGoogleのデータフローによって作成されるため、ジョブIDはありません。問題は、ジョブのステータスでジョブが完了した後にメールを送信するためのAPIが組み込まれているかどうかです。 – Damodar

+0

Pythonを使用している場合、ジョブをスケジュールすると、DataFlow Job IDを返すメソッドがあります。私はかなりJava SDKが同じであると確信しています。電子メールを送信するための組み込みメソッドはないと思いますが、DataFlow Job IDを取得するとCRONのDataFlow APIにクエリを送信してステータスを確認し、後で電子メールを送信できます。 –

答えて

0

関連する問題