airflow - 如何组合 Airflow 算子？

Question

几乎我所有的 DAG 都会有一个重复运算符的子集。由于我的用例，创建新的包装器操作符非常有效，它结合了多个操作符以减少样板。

我的问题是如何将它们结合起来？

一个示例是查询数据库，然后发送 Slack 消息。

postgres_operator_task >> slack_operator_task->query_then_slack_operator_task

标签： airflow

Answer 1

检查 subdags 的想法。
资源：

• SubDAG - Ariflow 文档。
• 在 Airflow -Astronomer 中使用 SubDAG。
• 示例 subdag。