我想使用Airflow生成客户报告，我希望有一个DAG遍历所有客户并启动一个任务来生成他们的报告。客户列表是由DAG中的第一个任务收集的，不能进行硬编码。
基本上，我有一个任务，该任务使用python运算符中的数据库挂钩来生成列表。然后对于列表中的每个项目，我想使用python运算符执行任务，并将该项目作为参数传递给python函数。我可以使用某种模式来实现这一目标吗？
Trigger_dag概念
让使用 python 运算符中的数据库挂钩生成列表的任务作为控制器 dag中的任务，并将列表中的每个项目传递给params 部分中的trigger_dag 。
您可以在气流安装的示例文件夹中找到参考
祝你好运！