MCP-Airflow-API
MCP-Airflow-API превращает запросы на обычном языке в вызовы REST API Apache Airflow 2 и 3: DAG, запуски, задачи.
- 54 ★ репозитория
- Последний коммит
- MIT
Широкий доступ
Почему такой уровень
- Запускает и приостанавливает DAG и меняет ресурсы Airflow с правами учетной записи.
- Хранит адрес и пароль Airflow в переменных окружения клиента.
Установка
- Работает в
Ручная установка
uvx --python 3.12 mcp-airflow-apiВариант PyPI с `uvx` из таблицы установки README. Для Claude Desktop есть расширение `.mcpb` в релизах.
Доступ и проверки
Как мы проверяемШирокий доступИнструмент может менять данные, выполнять команды или работать с секретами.
- Запускает и приостанавливает DAG и меняет ресурсы Airflow с правами учетной записи.
- Хранит адрес и пароль Airflow в переменных окружения клиента.
Это чужой код. Посмотрите файлы в репозитории перед установкой.
Что делает
MCP-Airflow-API — MCP-сервер, который переводит просьбы вроде «покажи упавшие задачи за сутки» в вызовы REST API Apache Airflow. Один сервер работает и с Airflow 2.x (API v1), и с Airflow 3.x (API v2): версию выбирает переменная `AIRFLOW_API_VERSION`. Агент смотрит DAG, запуски DAG, экземпляры задач, пулы, переменные, подключения и здоровье кластера. Запуск, пауза и другие операции выполняются с правами настроенной учетной записи Airflow. Транспорт stdio или Streamable HTTP, клиенты Claude Desktop, OpenWebUI и любые MCP-клиенты, плюс необязательный прокси MCPO для OpenAPI.
Для кого. Инженерам данных и платформенным командам, которые следят за Airflow и хотят спрашивать о конвейерах по-человечески.
Подходит, если
- Ночью упали задачи, и нужен список проваленных экземпляров за 24 часа.
- Нужно запустить DAG `example_etl` с сегодняшней датой обработки.
- Надо проверить здоровье кластера и пулы, не открывая веб-интерфейс.
- Команда на Airflow 3 хочет посмотреть ресурсы, обновленные конкретным DAG.
Не подходит, если
- Учетная запись Airflow имеет права администратора, а агенту нужна только проверка.
- Доступа к API Airflow из сети агента нет.
- Нужны правки кода DAG, а не управление запусками.
Пример запроса к агенту
Покажи DAG, которые сейчас выполняются, и список упавших задач за последние 24 часа.MCP
- Транспорт
- stdio, http
- Авторизация
- API-ключ
Переменные окружения
AIRFLOW_API_BASE_URLобязательная- Корень API Airflow без суффикса версии, например `http://localhost:8080/api`.
AIRFLOW_API_USERNAMEобязательная- Имя пользователя API Airflow.
AIRFLOW_API_PASSWORDобязательная, секрет- Пароль пользователя API Airflow.
AIRFLOW_API_VERSION- `v1` для Airflow 2.x (по умолчанию) или `v2` для Airflow 3.x.
Ограничения
Нужны учетная запись Airflow и сетевой доступ к его API. Адрес базы указывают без суффикса версии, например `http://localhost:8080/api`. Агент действует с правами этой учетной записи: заведите для него отдельного пользователя с минимумом прав, так как инструмент умеет запускать и приостанавливать DAG. Пароль хранится в переменных окружения, сервер по умолчанию слушает `127.0.0.1:8000` в режиме HTTP. Возможности API v2 доступны только на Airflow 3.
Как отключить. Удалите запись сервера из настроек клиента и снимите расширение в Claude Desktop. Остановите контейнеры Docker Compose, если запускали MCPO. Отдельного пользователя Airflow удалите в самом Airflow.
Частые вопросы
Как подключить к Claude Desktop?
Скачайте `.mcpb` из последнего релиза, откройте Settings, Extensions, Install Extension, выберите API `v1` или `v2` и введите адрес, имя и пароль.
Какую версию Airflow выбрать?
Для Airflow 2.x укажите `AIRFLOW_API_VERSION=v1`, это значение по умолчанию. Для Airflow 3.x укажите `v2`.
Как запустить без Claude Desktop?
Командой `uvx --python 3.12 mcp-airflow-api` или через Docker Compose с OpenWebUI. Транспорт задает `FASTMCP_TYPE`: `stdio` или `streamable-http`.
Где взять тестовый кластер?
Автор ссылается на отдельный репозиторий Airflow-Docker-Compose с готовым стендом.
Что умеет сервер кроме чтения?
Запускать и приостанавливать DAG и менять поддерживаемые ресурсы в пределах прав учетной записи Airflow.
Обсуждение
Вопросов и отзывов пока нет.
Похожие
MCP-серверыОфициальный MCP-сервер Cloudflare: агент управляет всем API Cloudflare через поиск по спецификации и выполнение кода
Самостоятельно размещаемый шлюз, который собирает несколько MCP-серверов в один эндпоинт с авторизацией и выбором инструментов
Официальный MCP-сервер Microsoft для Azure DevOps: задачи, репозитории, сборки, тест-планы и вики из агента
Планировщик задач cronstable открывает агенту список заданий, историю запусков и разбор расписаний через MCP.
Демон mcpd запускает MCP-серверы из одного файла .mcpd.toml и отдает их агентам и скриптам как обычный HTTP API на локальном порту
Локальный шлюз объединяет MCP-серверы внутренних сервисов, проверяет вход пользователя и записывает обращения в журнал.
Коротко о README
Сервер охватывает DAG, запуски, задачи, пулы, переменные и подключения и принимает запросы от любого MCP-клиента. Для OpenWebUI есть Docker Compose и прокси MCPO.