Skip to main content
Glama
deenesjakoruzh
us-all

airflow-mcp-server

by us-all
OverviewSchemaRelated ServersScoreDiscussions
TypeScript
Remote

@us-all/airflow-mcp

Airflow MCP-сервер — чтение DAG, запусков, экземпляров задач, последних строк логов; запуск и очистка (с защитой от записи). Построен на базе @us-all/mcp-toolkit.

Специализированный MCP для стабильного REST API Airflow. По умолчанию доступно только чтение; airflow-trigger-dag и airflow-clear-task доступны только при установке AIRFLOW_ALLOW_WRITE=true.

Для более глубокой интеграции с dbt (парсинг манифеста, история результатов выполнения, актуальность источников, покрытие тестами по столбцам, анализ lineage, пользовательские таблицы результатов DQ) установите дополнительно @us-all/dbt-mcp.

  • 7 инструментов в категориях airflow + meta

  • 2 MCP-промпта для рабочих процессов сортировки DAG

  • 1 инструмент агрегации, заменяющий комбинацию list-runs → get-task-instances

Установка

pnpm add -D @us-all/airflow-mcp

Запуск

AIRFLOW_API_URL=http://airflow.example.com:8080/api/v1 \
AIRFLOW_USERNAME=admin AIRFLOW_PASSWORD=... \
npx @us-all/airflow-mcp

Сервер использует протокол MCP stdio; подключите его к Claude Desktop / Cursor / любому MCP-клиенту. Установите MCP_TRANSPORT=http для использования потоковой передачи по HTTP (Bearer-авторизация, эндпоинт /health).

Инструменты

airflow (6 + 1 агрегация)

Инструмент

Описание

airflow-list-dags

Список активных DAG с фильтрами по тегам/поиску

airflow-list-runs

Недавние запуски одного DAG (фильтр по состоянию, сортировка от новых к старым)

airflow-get-task-instances

Экземпляры задач для конкретного запуска DAG

airflow-get-task-logs

Последние строки (N КБ) лога экземпляра задачи

airflow-trigger-dag

Запуск нового выполнения (с защитой от записи)

airflow-clear-task

Очистка конкретных экземпляров задач → повторный запуск (с защитой от записи)

dag-health-rollup

Агрегированное состояние DAG: процент успеха + средняя длительность + последний неудачный запуск + сбойные задачи

meta

search-tools — поиск инструментов на естественном языке.

Промпты

Промпт

Когда использовать

dag-failure-triage

"Почему упал DAG X?" — извлекает запуски, изолирует сбой, выводит логи, предлагает исправление

dag-schedule-audit

"Проверить все DAG на низкий процент успеха и зависшие запуски"

Переменные окружения

Переменная

Обязательно

Примечания

AIRFLOW_API_URL

да

Базовый URL REST API Airflow, например http://airflow.example.com:8080/api/v1

AIRFLOW_USERNAME

нет

Имя пользователя для Basic-auth

AIRFLOW_PASSWORD

нет

Пароль для Basic-auth (секрет)

AIRFLOW_ALLOW_WRITE

нет

true включает airflow-trigger-dag / airflow-clear-task

AIRFLOW_TOOLS / AIRFLOW_DISABLE

нет

Переключатели категорий

Протестированные схемы

  • Airflow Stable REST API (2.x). Airflow 3.x предоставляет тот же интерфейс через стабильные эндпоинты /api/v1/, поэтому этот сервер работает как с развертываниями 2.x, так и 3.x.

Дополнительный сервер

Для парсинга артефактов dbt, истории результатов выполнения и таблиц результатов DQ установите @us-all/dbt-mcp вместе с этим сервером.

Сборка

pnpm install
pnpm run build      # tsc → dist/
pnpm test           # vitest
pnpm run smoke      # spawns dist/index.js, calls initialize + tools/list (set env first)

Лицензия

MIT — см. LICENSE.

Install Server
A
license - permissive license
A
quality
B
maintenance

How are these scores calculated?

Maintenance

–Maintainers
–Response time
0dRelease cycle
2Releases (12mo)

Resources

Unclaimed servers have limited discoverability.

Looking for Admin?

If you are the server author, to access and configure the admin panel.

Tools

Latest Blog Posts

MCP directory API

We provide all the information about MCP servers via our MCP API.

curl -X GET 'https://glama.ai/api/mcp/v1/servers/us-all/airflow-mcp-server'

If you have feedback or need assistance with the MCP directory API, please join our Discord server