如何在Airflow的on_dag_failure函数中获取标签？
这是我的任务，当任务失败时，它将调用<code>...
xcom值在if / else循环中被else语句覆盖
我正在遍历包含一些sql文件的文件夹。对于每个文件，...
如何使用Apache Airflow访问电子邮件交换和下载附件
我想通过Airflow从MS Exchange Server邮箱中提取附件...
Apache Airflow中的动态FTPSensor
我想实现一种动态FTPSensor。使用贡献的FTP传感器，...
Airflow：通过XCOM创建和传递表列表不以文件形式存储在驱动器上并设置正确的依赖项吗？
这是我想要实现的预期流程和依赖项设置： START ==...
如何获取xcom作为PostgresOperator参数？
我创建了一个xcom，我希望将结果作为PostgresOperat...
如何从可调用的python返回列表到dag？
我正在尝试使用python运算符获取其中包含运行日期字...
如何将变量 task_ids 传递给 Airflow 中的 xcom.pull？
有时我发现使用循环创建任务很方便。 下面是一个 Sq...
使用 SFTPSensor 的气流 Xcom 比较时间戳
我需要在 sftp 中找到来自 <code>target_dir&...
如何使用 JDBC 运算符在气流中获取 sql 查询结果
我已经在 Airflow 连接中配置了 JDBC 连接。 DAG 的...
气流：如何仅在所有重试失败时发送电子邮件警报
我有以下气流 dag 的默认参数： <pre class="...
气流 - Xcoms 和并行作业 - 问题xcoms 覆盖自己
我有下面的管道。在我的第二级任务（第一个并行任务...
API 端点 - /xcomEntries/{xcom_key} - 不返回值
<strong>Apache Airflow 版本：2.0.0</str...
气流 dag 依赖项
我有一个气流 dag-1 大约运行一周，而 dag-2 每天运...