python - 我应该如何在 Airflow 中创建 DAG 子计划？

Question

我有一个基于多维 Python 字典中定义的设置的功能性 Airflow DAG 生成和电子邮件图表。该 DAG 每天运行。

但是，根据定义的设置，需要对单独的图表电子邮件进行子调度。

例如：

• 图表 A，每周一通过电子邮件发送。
• 图表 B，每三个月通过电子邮件发送一次。
• 图表 C，在每个月的最后一天通过电子邮件发送。

这本身很容易用 cron 来完成，但我不能将这些时间表中的任何一个作为 DAG 时间表，而且我绝对不想为每个图表创建一个新的 DAG。

我的想法是，当 DAG 每天运行时，它每天都会检查应该在特定日期生成哪些图表。谁能想到比用 Python 编写一个类似 cron 的调度系统更好的方法？

标签： pythonscheduled-tasksairflow