【问题标题】:How to trigger a mail after dataflow job completed to certain dl数据流作业完成后如何触发邮件到某个 dl
【发布时间】: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


【解决方案1】:

你可以的

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

您还可以在result.metrics() 返回的电子邮件中包含已完成工作的指标。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2019-06-06
    • 2020-01-03
    • 1970-01-01
    • 2019-11-30
    • 2023-03-18
    • 1970-01-01
    • 2019-02-12
    • 1970-01-01
    相关资源
    最近更新 更多