python - 基于动态变量值触发气流任务

Question

我有一个气流 DAG，它的任务是发送电子邮件。

在脚本中生成了一个熊猫数据框 (df) 作为查询输出。

我只想在 df 不为空的情况下发送电子邮件。

如何根据某个变量值（在任何 if 条件下）触发/取消任务？

标签： pythonpandasdataframeairflow

Answer 1

您可以使用 aBranchPythonOperator来确定是跳过还是运行发送电子邮件任务。这是有关如何设置它的一个很好的答案/示例。

Airflow 的 BranchPythonOperator 是如何工作的？.

您将需要此运算符的 python_callable（函数）来确定您的数据框是否为空/已填充。