气流 - 如何根据运营商结果发送电子邮件？

Posted 2023-03-25

【中文标题】气流 - 如何根据运营商结果发送电子邮件？

【英文标题】：Airflow - how to send email based on operator result?

【发布时间】：2018-07-17 11:50:12

【问题描述】：

我有一个从BashOperator 调用的python 脚本。 脚本返回可以返回状态0 或1。

我只想在状态为1 时触发电子邮件。 请注意，不要将这些状态与 Failure/Success 混淆。这只是表明数据发生了变化，需要开发人员注意。

这是我的接线员：

t = BashOperator(task_id='import',
                 bash_command="python /home/ubuntu/airflow/scripts/import.py",
                 dag=dag)

我查看了文档，但所有相关的电子邮件都解决了On Failure 的问题，这与我的情况无关。

【参考方案1】：

如果您不想覆盖运算符或任何花哨的东西，您可以使用 Xcoms 和 BranchPythonOperator

如果您的条件基于 0 或 1，您只需将该值推送到 XCom（将 xcom_push 设置为 True）。

然后，您可以使用 PythonBranchOperator 检查该值，并使用该值执行相应的任务。您可以在 Airflow example_dags 中找到 BranchPythonOperator 和 pulling from XCom 的示例。

【讨论】：

不错。如何在 xcom 中发送返回值？

在初始化 BashOperator 时，您应该能够将 xcom_push 设置为 True