用途:提供 Airflow 适配器模式,使同一套 MCP 工具代码可兼容 Airflow 2.x(/api/v1)与 Airflow 3.x(/api/v2)两套 API,适合需要跨版本调用 Airflow 的场景。
主要能力:版本在启动时自动检测;通过统一适配器接口调用不同版本 API。架构为 MCP Tool → _get_adapter() → AirflowV2Adapter 或 AirflowV3Adapter → Airflow API。
关键文件:adapters/base.py 为抽象接口;adapters/airflow_v2.py 对应 Airflow 2.x(/api/v1);adapters/airflow_v3.py 对应 Airflow 3.x(/api/v2)。相关文件包括 @api-differences.md(V2 与 V3 字段/端点差异)与 @patterns.md(实现模式)。
用法示例: adapter = _get_adapter() dags = adapter.list_dags(limit=100) run = adapter.trigger_dag_run("my_dag", conf={"key": "value"})
限制:资料未提供具体安装方式、最低版本要求、错误处理细节或收费信息。