【发布时间】:2017-12-26 06:00:19
【问题描述】:
我有一个谷歌云数据流作业,在特定时间间隔触发。我需要在数据流作业完成后触发一封邮件,作业状态为特定邮件 ID。
谢谢, 达莫达
【问题讨论】:
-
您是否有可用的 DataFlow 作业 ID(我的意思是您在安排作业后是否可以访问它)?
-
不,我们没有工作 ID,因为工作 ID 是由谷歌数据流创建的。问题是,是否有任何内置 API 可用于在工作完成后发送邮件以及工作状态。
-
如果您使用的是 Python,那么有一种方法可以在您调度作业后返回 DataFlow 作业 ID。我很确定 Java SDK 具有相同的功能。我不认为有发送电子邮件的内置方法,但是一旦你有了 DataFlow Job ID,你就可以在 CRON 中查询 DataFlow API 来检查状态并在之后发送电子邮件。
标签: google-app-engine google-cloud-dataflow apache-beam