Apache Airflow 日志与监控架构深度解析默认日志器、配置机制与云端扩展【免费下载链接】airflowApache Airflow - A platform to programmatically author, schedule, and monitor workflows项目地址: https://gitcode.com/GitHub_Trending/ai/airflow数据管道通常无人值守地运行因此可观测性是生产级 Airflow 的硬性要求。Apache Airflow 内置了多层日志与监控机制Web Server、Scheduler、Worker 均可通过统一的 Pythonlogging框架输出日志默认落盘到本地文件系统也可借助社区维护的 task handlers 将任务日志写往 AWS、Google Cloud、Azure 等云存储同时通过 StatsD 对外发布指标。本文以 logging-architecture.rst 为骨架结合本仓库源码系统讲解日志与监控的整体架构、默认 Logger 清单、日志配置的加载链路、敏感信息过滤机制以及远程日志与生产监控落地方案帮助你快速定位问题并搭建自己的可观测性体系。Airflow 日志与监控架构图来源airflow-core/docs/img/arch-diag-logging.png数据工程师通过 UI/Web Server 管理 DAGScheduler 调度、Worker 执行任务Worker 的运行日志经 Logging 模块写向本地日志文件、云存储 HooksS3/GS/Azure或 FluentD→ElasticSearch任务指标则经 StatsD→StatsD Exporter→Prometheus 汇聚。一、整体架构三类日志来源与两条可观测链路架构图清晰地展示了 Airflow 的可观测性布局。在数据面DAGs、Web Server、Scheduler、Worker 与 Metadata DB默认 Postgres共同构成调度与执行核心在可观测面信息被组织为两个方向日志Logging链路Logging 模块接收来自 Web Server、Scheduler 与执行任务的 Worker 的日志默认写入Local Log Files在云端部署时可通过Cloud Storage Hooks针对 S3、Google Cloud Storage、Azure 等写往对象存储在生产环境中还推荐用FluentD捕获日志并转发到ElasticSearch或 Splunk 等集中式检索平台。指标Monitoring Metrics链路Worker 与 Scheduler 等组件发布指标到StatsD经Statsd Exporter转换为 Prometheus 可消费的格式最终进入Prometheus做存储、可视化与告警。默认情况下Airflow 支持将日志写入本地文件系统覆盖 Web Server、Scheduler 以及运行任务的 Worker 产生的全部日志。这种开箱即用的方案非常适合开发环境和快速调试而在云部署Kubernetes 等中由于容器生命周期短、日志易丢失通常会配合云端 task handlers 将日志持久化到对象存储。二、日志配置的作用域与配置项入口所有日志设置都通过Airflow 配置文件即airflow.cfg其完整参数参考见 configurations-ref.rst中的[logging]区指定配置项集中在日志模板、日志文件夹、远程日志开关等键上。一个关键前提是该配置文件必须对所有 Airflow 进程可用——Web Server、Scheduler、Worker 各自都可能产生日志任一进程读不到统一配置都会导致日志行为不一致。以本仓库默认配置模板 airflow_local_settings.py 为例它从配置文件读取的核心日志变量包括LOG_FORMAT默认日志格式DAG_PROCESSOR_LOG_FORMATDAG 文件解析processor专用的日志格式LOG_FORMATTER_CLASSformatter 类默认为airflow.utils.log.timezone_aware.TimezoneAware输出带时区的时间DAG_PROCESSOR_LOG_TARGETDAG processor 日志的输出目标BASE_LOG_FOLDER本地日志根目录os.path.expanduser展开任务日志落盘位置由此决定REMOTE_LOGGING是否启用远程日志布尔值EXTRA_LOGGER_NAMES逗号分隔的额外 logger 名供需要在默认配置之外登记更多 logger 时使用。日志配置的加载机制logging_config_classAirflow 允许通过配置项[logging] logging_config_class指向一个返回dictConfig格式字典的可导入对象从而整体替换默认日志配置。其加载链路位于 logging_config.py通过conf.get(logging, logging_config_class, fallback...)读取配置项未配置时使用仓库 factory.py 中定义的默认路径airflow.config_templates.airflow_local_settings.DEFAULT_LOGGING_CONFIG即上文提到的模板字典若配置了自定义类则使用import_string动态导入并要求该对象是一个dict类型否则抛出ValueError若导入或校验失败统一封装为ImportError报错信息中会明确给出是“自定义”还是“默认”日志配置加载失败以及原始异常类型——这一点在排查airflow.cfg写坏时非常有用。也就是说从“默认配置即一个 Python 字典”的角度看用户可以很自然地从 airflow_local_settings.py 拷贝 DEFAULT_LOGGING_CONFIG 作为起点进行二次开发详见下文“高级定制”一节。三、默认 Logger 清单读懂日志该看哪个命名空间Airflow 基于 Python 标准库logging框架绝大多数 logger 遵循“Python 包名.模块名”的命名约定。因此阅读日志或定制行为前只需记住少数几个特殊的 logger 名Logger 名用途与关键特征rootPython 根 logger。任务执行期间 Airflow 会配置根 logger使所有向上传播的标准 Python logger 都能写入任务日志从而保证用户在任务代码里的logging.getLogger()输出可被捕获。airflow.task任务日志的父级 logger。Operators 与 Hooks 会使用其子命名空间如airflow.task.operators、airflow.task.hooks。在默认配置字典中它是显式声明的核心 logger。airflow.processorDAG 文件处理代码使用包括解析 DAG 文件时产生的消息如语法警告、导入错误等。airflow.processor_manager供 Scheduler 的 DAG processor manager 上报 DAG 处理活动用于排查“为什么某 DAG 没被调度/解析失败”。flask_appbuilderWeb Server 中 Flask-AppBuilder 框架使用的 logger。Airflow 的默认日志配置会刻意将其日志级别控制得比 Airflow 自身组件日志更不啰嗦默认配置中单独指定其level为FAB_LOG_LEVEL避免刷屏。这些 logger 大体遵循 Python 模块命名约定未显式声明者也会按需由对应组件创建而在默认配置字典中显式登记的 logger 只有airflow.task、flask_appbuilder以及root见 airflow_local_settings.pyairflow.task挂载taskhandler即 FileTaskHandler日志级别用LOG_LEVELpropagate: True——这样即使文件写入失败如磁盘满、远程存储不可用仍能把日志向上传播并输出flask_appbuilder挂载consolehandler独立控制级别root挂载consolehandler级别为LOG_LEVEL。值得一提的是airflow.processor/airflow.processor_manager所对应“DAG 文件解析活动”这类信息是判断调度器健康状况与 DAG 解析进度的重要日志来源排查调度问题时建议优先按这两个命名空间过滤。四、默认日志处理链格式化、敏感信息掩码与两类 Handler默认日志配置DEFAULT_LOGGING_CONFIG见 airflow_local_settings.py在源码层面展示了完整的 PythondictConfig结构formattersairflow使用LOG_FORMAT与source_processor使用DAG_PROCESSOR_LOG_FORMAT两者的 formatter 类都取LOG_FORMATTER_CLASS默认时区感知 formatter。filtersmask_secrets_core指向airflow._shared.secrets_masker._secrets_masker——这是 Airflow 内置的连接/变量密钥掩码过滤器凡是登记为 secret 的值连接密码、变量等在日志落盘前都会被替换为***避免敏感信息进入日志文件或 UI 展示。handlersconsolelogging.StreamHandler写入sys.stdout供 Web Server、Scheduler 等进程在标准输出查看taskairflow.utils.log.file_task_handler.FileTaskHandlerbase_log_folder取BASE_LOG_FOLDER——任务日志专用的文件 handler。这条链路回答了“为什么任务日志能单独出现在 UI 中”任务日志不走通用 stdout而是由FileTaskHandler依据任务实例dag_id / run_id / task_id / attempt组织目录结构落盘因而能被 日志任务文档 中描述的读取逻辑定位、并按任务实例分组展示。五、任务日志与组件日志为何分开配置Airflow 将task logs与其他组件日志分开配置原因在于两者消费方式不同组件日志Web Server、Scheduler、DAG processor 等是进程维度的连续日志流任务日志必须按 task instance 分组并能在 Airflow UI 的 Task Instance 详情页被实时读取与展示。因此任务日志拥有独立的文件布局、独立的 handlerFileTaskHandler与独立的远程日志设置。任务日志文件命名布局、远程任务日志配置以及“把任务日志写到 S3 / GCS / Azure Blob”的完整方案见 logging-tasks.rst。六、云端远程日志社区贡献的 Task Handlers对于云部署Airflow 提供了由社区贡献的task handlers可将日志写入 AWS、Google Cloud、Azure 等云存储。其核心开关是[logging] remote_logging True远程根目录由remote_base_log_folder指定。从 airflow_local_settings.py 的远程日志分支可以看出remote_base_log_folder通过URL scheme 自动识别后端支持以下前缀Scheme对应云/后端关键点s3://AWS S3需要对应 provider 及remote_log_conn_id连接cloudwatch://AWS CloudWatch日志组等由 URL path 解析gs://Google Cloud Storage需要 google provider 连接wasb://Azure Blob Storage容器名另有remote_wasb_log_container回退项stackdriver://Google Cloud LoggingStackdriverremote_base_log_folderpath 作为 log nameoss://阿里云 OSS走 alibaba providerhdfs://HDFSpath 作为远端基路径远程 handler 的连接信息由[logging] remote_log_conn_id提供读取逻辑见 logging_config.py。这一“scheme 驱动”的设计使得新增云端后端时只需在模板分支中扩展 URL 前缀即可而任务日志的读写统一抽象为RemoteLogIO接口实现位于 airflow/logging/remote.py。当remote_logging关闭时仍以本地FileTaskHandler为主。七、高级定制日志级别、自定义 Handler 与逐 Operator 控制在默认“本地文件系统 console”之外Airflow 支持三类典型定制详见 advanced-logging-configuration.rst自定义 handler例如将日志发往 Syslog、Kafka、Splunk 等可通过logging_config_class指向自定义的 dict 返回函数实现整体替换。自定义日志级别通过配置文件控制LOG_LEVELAirflow 组件与FAB_LOG_LEVELWeb Server 的 Flask-AppBuilder等不同粒度的级别如需为特定 logger 追加 console 输出可直接使用EXTRA_LOGGER_NAMES模板会据此在DEFAULT_LOGGING_CONFIG[loggers]中动态追加同名 logger见 airflow_local_settings.py。逐 Operator / 逐 Task 的日志控制airflow.task.operators、airflow.task.hooks等子命名空间天然支持为单个 Operator 类型或某个任务单独调级别、挂 handler。从源码结构看扩展 handler 时保持对mask_secrets_core过滤器的挂载是一种稳妥实践它能延续默认配置的密钥掩码保护。八、生产落地FluentD 聚合日志、StatsD 发布指标对于生产部署官方文档与架构图给出了两条被广泛验证的推荐路径日志使用FluentD捕获 Airflow 各进程与任务日志并转发到ElasticSearch或Splunk等集中存储与检索平台解决多副本、多节点场景下日志分散的问题。指标使用StatsD收集来自 Airflow 的 metrics并通过 StatsD Exporter 转成 Prometheus 格式最终在 Prometheus 中做时序存储、面板与告警。Airflow 内建的指标项清单可在仓库 airflow-core/src/airflow/METRICS.md 查阅StatsD 指标的配置项statsd 主机/端口、指标前缀等在 Airflow 配置文件的[metrics]区完整参数与常用指标说明见 metrics.rst。九、监控体系的其余拼图日志与指标只是可观测性的一部分。围绕“无人值守数据管道”的运行保障本仓库的监控主题文档还覆盖了更广的边界可在阅读本文后按需深入metrics.rstMetrics 配置与指标清单traces.rst链路追踪trace支持callbacks.rst状态变更回调/通知check-health.rstAirflow 自身的健康检查用于探测 Scheduler 与 Metadata DB 是否存活errors.rst错误检测与告警集成logging-tasks.rst任务日志文件布局与远程任务日志配置。结合该监控主题目录页可以看到Airflow 的完整可观测性 日志本地/远程/聚合检索 指标StatsD→Prometheus 链路追踪 健康检查 错误实时通知本文所讲的日志与监控架构正是这整套体系的入口。开发与运维团队可按“先本地调试、再接入云存储、最后搭建 FluentD/Prometheus 生产链路”的节奏逐步把默认日志配置演进为适合自身规模的生产监控方案。【免费下载链接】airflowApache Airflow - A platform to programmatically author, schedule, and monitor workflows项目地址: https://gitcode.com/GitHub_Trending/ai/airflow创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考 
长河君 · 2026/9/9 20:30:27 · 阅读 1.2k Apache Airflow 日志与监控架构深度解析：默认日志器、配置机制与云端扩展
Apache Airflow 日志与监控架构深度解析默认日志器、配置机制与云端扩展【免费下载链接】airflowApache Airflow - A platform to programmatically author, schedule, and monitor workflows项目地址: https://gitcode.com/GitHub_Trending/ai/airflow数据管道通常无人值守地运行因此可观测性是生产级 Airflow 的硬性要求。Apache Airflow 内置了多层日志与监控机制Web Server、Scheduler、Worker 均可通过统一的 Pythonlogging框架输出日志默认落盘到本地文件系统也可借助社区维护的 task handlers 将任务日志写往 AWS、Google Cloud、Azure 等云存储同时通过 StatsD 对外发布指标。本文以 logging-architecture.rst 为骨架结合本仓库源码系统讲解日志与监控的整体架构、默认 Logger 清单、日志配置的加载链路、敏感信息过滤机制以及远程日志与生产监控落地方案帮助你快速定位问题并搭建自己的可观测性体系。Airflow 日志与监控架构图来源airflow-core/docs/img/arch-diag-logging.png数据工程师通过 UI/Web Server 管理 DAGScheduler 调度、Worker 执行任务Worker 的运行日志经 Logging 模块写向本地日志文件、云存储 HooksS3/GS/Azure或 FluentD→ElasticSearch任务指标则经 StatsD→StatsD Exporter→Prometheus 汇聚。一、整体架构三类日志来源与两条可观测链路架构图清晰地展示了 Airflow 的可观测性布局。在数据面DAGs、Web Server、Scheduler、Worker 与 Metadata DB默认 Postgres共同构成调度与执行核心在可观测面信息被组织为两个方向日志Logging链路Logging 模块接收来自 Web Server、Scheduler 与执行任务的 Worker 的日志默认写入Local Log Files在云端部署时可通过Cloud Storage Hooks针对 S3、Google Cloud Storage、Azure 等写往对象存储在生产环境中还推荐用FluentD捕获日志并转发到ElasticSearch或 Splunk 等集中式检索平台。指标Monitoring Metrics链路Worker 与 Scheduler 等组件发布指标到StatsD经Statsd Exporter转换为 Prometheus 可消费的格式最终进入Prometheus做存储、可视化与告警。默认情况下Airflow 支持将日志写入本地文件系统覆盖 Web Server、Scheduler 以及运行任务的 Worker 产生的全部日志。这种开箱即用的方案非常适合开发环境和快速调试而在云部署Kubernetes 等中由于容器生命周期短、日志易丢失通常会配合云端 task handlers 将日志持久化到对象存储。二、日志配置的作用域与配置项入口所有日志设置都通过Airflow 配置文件即airflow.cfg其完整参数参考见 configurations-ref.rst中的[logging]区指定配置项集中在日志模板、日志文件夹、远程日志开关等键上。一个关键前提是该配置文件必须对所有 Airflow 进程可用——Web Server、Scheduler、Worker 各自都可能产生日志任一进程读不到统一配置都会导致日志行为不一致。以本仓库默认配置模板 airflow_local_settings.py 为例它从配置文件读取的核心日志变量包括LOG_FORMAT默认日志格式DAG_PROCESSOR_LOG_FORMATDAG 文件解析processor专用的日志格式LOG_FORMATTER_CLASSformatter 类默认为airflow.utils.log.timezone_aware.TimezoneAware输出带时区的时间DAG_PROCESSOR_LOG_TARGETDAG processor 日志的输出目标BASE_LOG_FOLDER本地日志根目录os.path.expanduser展开任务日志落盘位置由此决定REMOTE_LOGGING是否启用远程日志布尔值EXTRA_LOGGER_NAMES逗号分隔的额外 logger 名供需要在默认配置之外登记更多 logger 时使用。日志配置的加载机制logging_config_classAirflow 允许通过配置项[logging] logging_config_class指向一个返回dictConfig格式字典的可导入对象从而整体替换默认日志配置。其加载链路位于 logging_config.py通过conf.get(logging, logging_config_class, fallback...)读取配置项未配置时使用仓库 factory.py 中定义的默认路径airflow.config_templates.airflow_local_settings.DEFAULT_LOGGING_CONFIG即上文提到的模板字典若配置了自定义类则使用import_string动态导入并要求该对象是一个dict类型否则抛出ValueError若导入或校验失败统一封装为ImportError报错信息中会明确给出是“自定义”还是“默认”日志配置加载失败以及原始异常类型——这一点在排查airflow.cfg写坏时非常有用。也就是说从“默认配置即一个 Python 字典”的角度看用户可以很自然地从 airflow_local_settings.py 拷贝 DEFAULT_LOGGING_CONFIG 作为起点进行二次开发详见下文“高级定制”一节。三、默认 Logger 清单读懂日志该看哪个命名空间Airflow 基于 Python 标准库logging框架绝大多数 logger 遵循“Python 包名.模块名”的命名约定。因此阅读日志或定制行为前只需记住少数几个特殊的 logger 名Logger 名用途与关键特征rootPython 根 logger。任务执行期间 Airflow 会配置根 logger使所有向上传播的标准 Python logger 都能写入任务日志从而保证用户在任务代码里的logging.getLogger()输出可被捕获。airflow.task任务日志的父级 logger。Operators 与 Hooks 会使用其子命名空间如airflow.task.operators、airflow.task.hooks。在默认配置字典中它是显式声明的核心 logger。airflow.processorDAG 文件处理代码使用包括解析 DAG 文件时产生的消息如语法警告、导入错误等。airflow.processor_manager供 Scheduler 的 DAG processor manager 上报 DAG 处理活动用于排查“为什么某 DAG 没被调度/解析失败”。flask_appbuilderWeb Server 中 Flask-AppBuilder 框架使用的 logger。Airflow 的默认日志配置会刻意将其日志级别控制得比 Airflow 自身组件日志更不啰嗦默认配置中单独指定其level为FAB_LOG_LEVEL避免刷屏。这些 logger 大体遵循 Python 模块命名约定未显式声明者也会按需由对应组件创建而在默认配置字典中显式登记的 logger 只有airflow.task、flask_appbuilder以及root见 airflow_local_settings.pyairflow.task挂载taskhandler即 FileTaskHandler日志级别用LOG_LEVELpropagate: True——这样即使文件写入失败如磁盘满、远程存储不可用仍能把日志向上传播并输出flask_appbuilder挂载consolehandler独立控制级别root挂载consolehandler级别为LOG_LEVEL。值得一提的是airflow.processor/airflow.processor_manager所对应“DAG 文件解析活动”这类信息是判断调度器健康状况与 DAG 解析进度的重要日志来源排查调度问题时建议优先按这两个命名空间过滤。四、默认日志处理链格式化、敏感信息掩码与两类 Handler默认日志配置DEFAULT_LOGGING_CONFIG见 airflow_local_settings.py在源码层面展示了完整的 PythondictConfig结构formattersairflow使用LOG_FORMAT与source_processor使用DAG_PROCESSOR_LOG_FORMAT两者的 formatter 类都取LOG_FORMATTER_CLASS默认时区感知 formatter。filtersmask_secrets_core指向airflow._shared.secrets_masker._secrets_masker——这是 Airflow 内置的连接/变量密钥掩码过滤器凡是登记为 secret 的值连接密码、变量等在日志落盘前都会被替换为***避免敏感信息进入日志文件或 UI 展示。handlersconsolelogging.StreamHandler写入sys.stdout供 Web Server、Scheduler 等进程在标准输出查看taskairflow.utils.log.file_task_handler.FileTaskHandlerbase_log_folder取BASE_LOG_FOLDER——任务日志专用的文件 handler。这条链路回答了“为什么任务日志能单独出现在 UI 中”任务日志不走通用 stdout而是由FileTaskHandler依据任务实例dag_id / run_id / task_id / attempt组织目录结构落盘因而能被 日志任务文档 中描述的读取逻辑定位、并按任务实例分组展示。五、任务日志与组件日志为何分开配置Airflow 将task logs与其他组件日志分开配置原因在于两者消费方式不同组件日志Web Server、Scheduler、DAG processor 等是进程维度的连续日志流任务日志必须按 task instance 分组并能在 Airflow UI 的 Task Instance 详情页被实时读取与展示。因此任务日志拥有独立的文件布局、独立的 handlerFileTaskHandler与独立的远程日志设置。任务日志文件命名布局、远程任务日志配置以及“把任务日志写到 S3 / GCS / Azure Blob”的完整方案见 logging-tasks.rst。六、云端远程日志社区贡献的 Task Handlers对于云部署Airflow 提供了由社区贡献的task handlers可将日志写入 AWS、Google Cloud、Azure 等云存储。其核心开关是[logging] remote_logging True远程根目录由remote_base_log_folder指定。从 airflow_local_settings.py 的远程日志分支可以看出remote_base_log_folder通过URL scheme 自动识别后端支持以下前缀Scheme对应云/后端关键点s3://AWS S3需要对应 provider 及remote_log_conn_id连接cloudwatch://AWS CloudWatch日志组等由 URL path 解析gs://Google Cloud Storage需要 google provider 连接wasb://Azure Blob Storage容器名另有remote_wasb_log_container回退项stackdriver://Google Cloud LoggingStackdriverremote_base_log_folderpath 作为 log nameoss://阿里云 OSS走 alibaba providerhdfs://HDFSpath 作为远端基路径远程 handler 的连接信息由[logging] remote_log_conn_id提供读取逻辑见 logging_config.py。这一“scheme 驱动”的设计使得新增云端后端时只需在模板分支中扩展 URL 前缀即可而任务日志的读写统一抽象为RemoteLogIO接口实现位于 airflow/logging/remote.py。当remote_logging关闭时仍以本地FileTaskHandler为主。七、高级定制日志级别、自定义 Handler 与逐 Operator 控制在默认“本地文件系统 console”之外Airflow 支持三类典型定制详见 advanced-logging-configuration.rst自定义 handler例如将日志发往 Syslog、Kafka、Splunk 等可通过logging_config_class指向自定义的 dict 返回函数实现整体替换。自定义日志级别通过配置文件控制LOG_LEVELAirflow 组件与FAB_LOG_LEVELWeb Server 的 Flask-AppBuilder等不同粒度的级别如需为特定 logger 追加 console 输出可直接使用EXTRA_LOGGER_NAMES模板会据此在DEFAULT_LOGGING_CONFIG[loggers]中动态追加同名 logger见 airflow_local_settings.py。逐 Operator / 逐 Task 的日志控制airflow.task.operators、airflow.task.hooks等子命名空间天然支持为单个 Operator 类型或某个任务单独调级别、挂 handler。从源码结构看扩展 handler 时保持对mask_secrets_core过滤器的挂载是一种稳妥实践它能延续默认配置的密钥掩码保护。八、生产落地FluentD 聚合日志、StatsD 发布指标对于生产部署官方文档与架构图给出了两条被广泛验证的推荐路径日志使用FluentD捕获 Airflow 各进程与任务日志并转发到ElasticSearch或Splunk等集中存储与检索平台解决多副本、多节点场景下日志分散的问题。指标使用StatsD收集来自 Airflow 的 metrics并通过 StatsD Exporter 转成 Prometheus 格式最终在 Prometheus 中做时序存储、面板与告警。Airflow 内建的指标项清单可在仓库 airflow-core/src/airflow/METRICS.md 查阅StatsD 指标的配置项statsd 主机/端口、指标前缀等在 Airflow 配置文件的[metrics]区完整参数与常用指标说明见 metrics.rst。九、监控体系的其余拼图日志与指标只是可观测性的一部分。围绕“无人值守数据管道”的运行保障本仓库的监控主题文档还覆盖了更广的边界可在阅读本文后按需深入metrics.rstMetrics 配置与指标清单traces.rst链路追踪trace支持callbacks.rst状态变更回调/通知check-health.rstAirflow 自身的健康检查用于探测 Scheduler 与 Metadata DB 是否存活errors.rst错误检测与告警集成logging-tasks.rst任务日志文件布局与远程任务日志配置。结合该监控主题目录页可以看到Airflow 的完整可观测性 日志本地/远程/聚合检索 指标StatsD→Prometheus 链路追踪 健康检查 错误实时通知本文所讲的日志与监控架构正是这整套体系的入口。开发与运维团队可按“先本地调试、再接入云存储、最后搭建 FluentD/Prometheus 生产链路”的节奏逐步把默认日志配置演进为适合自身规模的生产监控方案。【免费下载链接】airflowApache Airflow - A platform to programmatically author, schedule, and monitor workflows项目地址: https://gitcode.com/GitHub_Trending/ai/airflow创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考