Каталог MCP
yangkyeongmo
yangkyeongmo@/mcp-server-apache-airflow

yangkyeongmo@/mcp-server-apache-airflow

MCP-сервер для Apache Airflow управляет DAG, запускает задачи, настраивает переменные и мониторит выполнение через единый протокол. Полезен инженерам данных и DevOps для автоматизации CI/CD.

README

68 инструментов

Установить сервер

mcp-server-apache-airflow

PyPI - Downloads

A Model Context Protocol (MCP) server implementation for Apache Airflow, enabling seamless integration with MCP clients. This project provides a standardized way to interact with Apache Airflow through the Model Context Protocol.

About

This project implements a Model Context Protocol server that wraps Apache Airflow's REST API, allowing MCP clients to interact with Airflow in a standardized way. It uses the official Apache Airflow client library to ensure compatibility and maintainability.

Feature Implementation Status

Feature	API Path	Status
DAG Management
List DAGs	`/api/v1/dags`	✅
Get DAG Details	`/api/v1/dags/{dag_id}`	✅
Pause DAG	`/api/v1/dags/{dag_id}`	✅
Unpause DAG	`/api/v1/dags/{dag_id}`	✅
Update DAG	`/api/v1/dags/{dag_id}`	✅
Delete DAG	`/api/v1/dags/{dag_id}`	✅
Get DAG Source	`/api/v1/dagSources/{file_token}`	✅
Patch Multiple DAGs	`/api/v1/dags`	✅
Reparse DAG File	`/api/v1/dagSources/{file_token}/reparse`	✅
DAG Runs
List DAG Runs	`/api/v1/dags/{dag_id}/dagRuns`	✅
Create DAG Run	`/api/v1/dags/{dag_id}/dagRuns`	✅
Get DAG Run Details	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}`	✅
Update DAG Run	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}`	✅
Delete DAG Run	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}`	✅
Get DAG Runs Batch	`/api/v1/dags/~/dagRuns/list`	✅
Clear DAG Run	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/clear`	✅
Set DAG Run Note	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/setNote`	✅
Get Upstream Dataset Events	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/upstreamDatasetEvents`	✅
Tasks
List DAG Tasks	`/api/v1/dags/{dag_id}/tasks`	✅
Get Task Details	`/api/v1/dags/{dag_id}/tasks/{task_id}`	✅
Get Task Instance	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}`	✅
List Task Instances	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances`	✅
Update Task Instance	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}`	✅
Get Task Instance Log	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/logs/{task_try_number}`	✅
Clear Task Instances	`/api/v1/dags/{dag_id}/clearTaskInstances`	✅
Set Task Instances State	`/api/v1/dags/{dag_id}/updateTaskInstancesState`	✅
List Task Instance Tries	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/tries`	✅
Variables
List Variables	`/api/v1/variables`	✅
Create Variable	`/api/v1/variables`	✅
Get Variable	`/api/v1/variables/{variable_key}`	✅
Update Variable	`/api/v1/variables/{variable_key}`	✅
Delete Variable	`/api/v1/variables/{variable_key}`	✅
Connections
List Connections	`/api/v1/connections`	✅
Create Connection	`/api/v1/connections`	✅
Get Connection	`/api/v1/connections/{connection_id}`	✅
Update Connection	`/api/v1/connections/{connection_id}`	✅
Delete Connection	`/api/v1/connections/{connection_id}`	✅
Test Connection	`/api/v1/connections/test`	✅
Pools
List Pools	`/api/v1/pools`	✅
Create Pool	`/api/v1/pools`	✅
Get Pool	`/api/v1/pools/{pool_name}`	✅
Update Pool	`/api/v1/pools/{pool_name}`	✅
Delete Pool	`/api/v1/pools/{pool_name}`	✅
XComs
List XComs	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries`	✅
Get XCom Entry	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries/{xcom_key}`	✅
Datasets
List Datasets	`/api/v1/datasets`	✅
Get Dataset	`/api/v1/datasets/{uri}`	✅
Get Dataset Events	`/api/v1/datasetEvents`	✅
Create Dataset Event	`/api/v1/datasetEvents`	✅
Get DAG Dataset Queued Event	`/api/v1/dags/{dag_id}/dagRuns/queued/datasetEvents/{uri}`	✅
Get DAG Dataset Queued Events	`/api/v1/dags/{dag_id}/dagRuns/queued/datasetEvents`	✅
Delete DAG Dataset Queued Event	`/api/v1/dags/{dag_id}/dagRuns/queued/datasetEvents/{uri}`	✅
Delete DAG Dataset Queued Events	`/api/v1/dags/{dag_id}/dagRuns/queued/datasetEvents`	✅
Get Dataset Queued Events	`/api/v1/datasets/{uri}/dagRuns/queued/datasetEvents`	✅
Delete Dataset Queued Events	`/api/v1/datasets/{uri}/dagRuns/queued/datasetEvents`	✅
Monitoring
Get Health	`/api/v1/health`	✅
DAG Stats
Get DAG Stats	`/api/v1/dags/statistics`	✅
Config
Get Config	`/api/v1/config`	✅
Plugins
Get Plugins	`/api/v1/plugins`	✅
Providers
List Providers	`/api/v1/providers`	✅
Event Logs
List Event Logs	`/api/v1/eventLogs`	✅
Get Event Log	`/api/v1/eventLogs/{event_log_id}`	✅
System
Get Import Errors	`/api/v1/importErrors`	✅
Get Import Error Details	`/api/v1/importErrors/{import_error_id}`	✅
Get Health Status	`/api/v1/health`	✅
Get Version	`/api/v1/version`	✅

clear_dag_run

Очистить запуск DAG

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
dry_runany

clear_task_instances

Очистить набор экземпляров задач

Параметры

dag_idstringобязательный
task_idsany
start_dateany
end_dateany
include_subdagsany
include_parentdagany
include_upstreamany
include_downstreamany
include_futureany
include_pastany
dry_runany
reset_dag_runsany

create_connection

Создать подключение

Параметры

conn_idstringобязательный
conn_typestringобязательный
hostany
portany
loginany
passwordany
schemaany
extraany

create_dataset_event

Создать событие набора данных

Параметры

dataset_uristringобязательный
extraany

create_variable

Создайте переменную

Параметры

keystringобязательный
valuestringобязательный
descriptionany

delete_connection

Удалить соединение по ID

Параметры

conn_idstringобязательный

delete_dag

Удалить DAG

Параметры

dag_idstringобязательный

delete_dag_dataset_queued_event

Удалить поставленное в очередь событие Dataset для DAG

Параметры

dag_idstringобязательный
uristringобязательный

delete_dag_dataset_queued_events

Удалить поставленные в очередь события Dataset для DAG

Параметры

dag_idstringобязательный
beforeany

delete_dag_run

Удалите запуск DAG по ID DAG и ID запуска DAG.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный

delete_dataset_queued_events

Удаляет события в очереди для набора данных Dataset

Параметры

uristringобязательный
beforeany

delete_pool

Удалить пул

Параметры

pool_namestringобязательный
The pool name.

delete_variable

Удалить переменную по ключу

Параметры

keystringобязательный

fetch_dags

Получить все DAGs

Параметры

limitany
offsetany
order_byany
tagsany
only_activeany
pausedany
dag_id_patternany

get_config

Получает текущую конфигурацию

Параметры

sectionany

get_connection

Получить соединение по ID

Параметры

conn_idstringобязательный

get_dag

Получить DAG по ID

Параметры

dag_idstringобязательный

get_dag_dataset_queued_event

Получить событие Dataset, поставленное в очередь, для DAG

Параметры

dag_idstringобязательный
uristringобязательный

get_dag_dataset_queued_events

Получить события Dataset в очереди для DAG

Параметры

dag_idstringобязательный

get_dag_details

Получить упрощенное представление DAG

Параметры

dag_idstringобязательный
fieldsany

get_dag_run

Получить запуск DAG по DAG ID и DAG run ID

Параметры

dag_idstringобязательный
dag_run_idstringобязательный

get_dag_runs

Получить запуски DAG по ID

Параметры

dag_idstringобязательный
limitany
offsetany
execution_date_gteany
execution_date_lteany
start_date_gteany
start_date_lteany
end_date_gteany
end_date_lteany
updated_at_gteany
updated_at_lteany
stateany
order_byany

get_dag_runs_batch

Список запусков DAG (пакетно)

Параметры

dag_idsany
execution_date_gteany
execution_date_lteany
start_date_gteany
start_date_lteany
end_date_gteany
end_date_lteany
stateany
order_byany
page_offsetany
page_limitany

get_dag_source

Получить исходный код

Параметры

file_tokenstringобязательный

get_dag_stats

Получить статистику DAG

Параметры

dag_idsany

get_dag_tasks

Получить задачи для DAG

Параметры

dag_idstringобязательный

get_dataset

Получите набор данных по URI

Параметры

uristringобязательный

get_dataset_events

Получить события датасета

Параметры

limitany
offsetany
order_byany
dataset_idany
source_dag_idany
source_task_idany
source_run_idany
source_map_indexany

get_dataset_queued_events

Получить события в очереди для Dataset

Параметры

uristringобязательный

get_datasets

Список наборов данных

Параметры

limitany
offsetany
order_byany
uri_patternany
dag_idsany

get_event_log

Получить конкретную запись лога по ID

Параметры

event_log_idintegerобязательный

get_event_logs

Вывести записи из журнала событий.

Параметры

limitany
offsetany
order_byany
dag_idany
task_idany
run_idany
map_indexany
try_numberany
eventany
ownerany
beforeany
afterany
included_eventsany
excluded_eventsany

get_health

Получить статус инстанса

Параметры

Без параметров.

get_import_error

Получить конкретную ошибку импорта по ID

Параметры

import_error_idintegerобязательный

get_import_errors

Вывести список ошибок импорта

Параметры

limitany
offsetany
order_byany

get_log

Получить логи экземпляра задачи по DAG ID, task ID, DAG run ID и task try number

Параметры

dag_idstringобязательный
task_idstringобязательный
dag_run_idstringобязательный
task_try_numberintegerобязательный

get_plugins

Получить список загруженных плагинов.

Параметры

limitany
The numbers of items to return.
offsetany
The number of items to skip before starting to collect the result set.

get_pool

Получить пул по имени

Параметры

pool_namestringобязательный
The pool name.

get_pools

Список пулов

Параметры

limitany
The numbers of items to return.
offsetany
The number of items to skip before starting to collect the result set.
order_byany
The name of the field to order the results by. Prefix a field name with `-` to reverse the sort order.

get_providers

Получить список загруженных провайдеров

Параметры

limitany
The numbers of items to return.
offsetany
The number of items to skip before starting to collect the result set.

get_task

Получить задачу по ID

Параметры

dag_idstringобязательный
task_idstringобязательный

get_task_instance

Получите экземпляр задачи по DAG ID, task ID и DAG run ID

Параметры

dag_idstringобязательный
task_idstringобязательный
dag_run_idstringобязательный

get_tasks

Получить задачи для DAG

Параметры

dag_idstringобязательный
order_byany

get_upstream_dataset_events

Получить события датасета для запуска DAG

Параметры

dag_idstringобязательный
dag_run_idstringобязательный

get_value

Получить конкретный параметр из конфигурации

Параметры

sectionstringобязательный
optionstringобязательный

get_variable

Получить переменную по ключу

Параметры

keystringобязательный

get_version

Получить информацию о версии

Параметры

Без параметров.

get_xcom_entries

Получить все записи XCom

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
task_idstringобязательный
map_indexany
xcom_keyany
limitany
offsetany

get_xcom_entry

Получить запись XCom

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
task_idstringобязательный
xcom_keystringобязательный
map_indexany
deserializeany
stringifyany

list_connections

Вывести список всех подключений

Параметры

limitany
offsetany
order_byany

list_task_instances

Вывести список экземпляров задач по ID DAG и ID запуска DAG.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
execution_date_gteany
execution_date_lteany
start_date_gteany
start_date_lteany
end_date_gteany
end_date_lteany
updated_at_gteany
updated_at_lteany
duration_gteany
duration_lteany
stateany
poolany
queueany
limitany
offsetany

list_task_instance_tries

Выводит список попыток экземпляров задач по DAG ID, DAG run ID и task ID.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
task_idstringобязательный
limitany
offsetany
order_byany

list_variables

Перечисли все переменные.

Параметры

limitany
offsetany
order_byany

patch_dag

Обновить DAG

Параметры

dag_idstringобязательный
is_pausedany
tagsany

patch_dags

Обновить несколько DAGs

Параметры

dag_id_patternany
is_pausedany
tagsany

patch_pool

Обновить пул

Параметры

pool_namestringобязательный
The pool name.
slotsany
The number of slots.
descriptionany
The pool description.
include_deferredany
Whether to include deferred tasks in slot calculations.

pause_dag

Приостановить DAG по ID

Параметры

dag_idstringобязательный

post_dag_run

Запустить DAG по ID

Параметры

dag_idstringобязательный
dag_run_idany
data_interval_endany
data_interval_startany
execution_dateany
logical_dateany
noteany

post_pool

Создать пул

Параметры

namestringобязательный
The pool name.
slotsintegerобязательный
The number of slots.
descriptionany
The pool description.
include_deferredany
Whether to include deferred tasks in slot calculations.

reparse_dag_file

Запросить повторный разбор файла DAG

Параметры

file_tokenstringобязательный

set_dag_run_note

Обновить заметку DagRun

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
notestringобязательный

set_task_instances_state

Установить состояние экземпляров задач

Параметры

dag_idstringобязательный
statestringобязательный
task_idsany
execution_dateany
include_upstreamany
include_downstreamany
include_futureany
include_pastany
dry_runany

test_connection

Проверить подключение

Параметры

conn_typestringобязательный
hostany
portany
loginany
passwordany
schemaany
extraany

unpause_dag

Возобновить DAG по ID

Параметры

dag_idstringобязательный

update_connection

Обновить соединение по ID

Параметры

conn_idstringобязательный
conn_typeany
hostany
portany
loginany
passwordany
schemaany
extraany

update_dag_run_state

Обновить состояние выполнения DAG по ID DAG и ID запуска DAG

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
stateany

update_task_instance

Обновить экземпляр задачи по DAG ID, DAG run ID и task ID.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
task_idstringобязательный
stateany

update_variable

Обновить переменную по ключу

Параметры

keystringобязательный
valueany
descriptionany

Github Сайт сервера

Конфиг для установки сервера

{
  "command": "uvx",
  "args": [
    "mcp-server-apache-airflow"
  ],
  "env": {
    "AIRFLOW_HOST": "https://your-airflow-host",
    "AIRFLOW_USERNAME": "your-username",
    "AIRFLOW_PASSWORD": "your-password"
  }
}

Также yangkyeongmo@/mcp-server-apache-airflow можно установить в Cursor по ссылке автоматически.

FAQ

Для чего этот сервер?

Этот сервер связывает MCP-клиенты с Apache Airflow. Он берёт на себя всю работу с REST API Airflow, чтобы AI-агенты и ассистенты могли управлять дагами, запускать их, смотреть логи, менять переменные и статусы задач. Вместо ручной интеграции достаточно подключить сервер — и MCP-клиент сам выполняет повседневные операции с пайплайнами.

Что он умеет?

Сервер управляет DAG-ами: читает, приостанавливает, запускает, обновляет и удаляет их, включая прогоны и триггеры. Работает с задачами — читает, обновляет состояние, чистит инстансы и получает логи. Управляет соединениями, переменными, пулами и датасетами — создаёт, обновляет, удаляет, тестирует. Читает конфигурацию, версию, плагины, провайдеры, ошибки импорта, XCom и статистику DAG.

Информация о сервере

Номер в рейтинге: #158
Звезд на Github: 172
Форков на Github: 46
Язык реализации: Python
Лицензия: MIT
Официальный сервер: Нет
Дата обновления данных: 19.07 в 09:04
Идентификатор: -ZaJOf9JxOjndmoe
Категории: CI/CD и DevOps, Автоматизация приложений, Инструменты для разработчиков, Платформы данных

Другие проверенные MCP-сервера

line/line-bot-mcp-server

официальный

MCP-сервер для интеграции AI-агентов с LINE Official Account через Messaging API. Отправляет текстовые и гибкие сообщения, управляет богатыми меню, получает профили пользователей и список подписчик...

Aas-ee/open-webSearch

open-websearch — это MCP-сервер и CLI для веб-поиска и извлечения контента без API-ключей. Поддерживает множество поисковиков (Bing, Baidu, DuckDuckGo и др.), загружает статьи и README с GitHub. Ра...

webdriverio/mcp

официальный

Управляйте браузерами и мобильными приложениями через WebDriverIO с MCP-сервером. Автоматизируйте Chrome, Firefox, Edge, Safari, iOS и Android: навигация, клики, скриншоты. Оптимален для тестирования.

mediar-ai/screenpipe

Screenpipe - MCP сервер для локального ИИ, запоминающего всё на экране и в аудио. Записывает и распознаёт текст и речь. Ищите виденное и слышанное естественным языком. Плагины (Pipes) автоматизируют действия на основе активности. Полная приватность.

bytebase/dbhub

DBHub — легковесный MCP сервер для работы с базами данных (PostgreSQL, MySQL, SQL Server и другими). Подключает несколько БД сразу, выполняет SQL-запросы и ищет объекты схемы через два компактных инструмента. Безопасный доступ с read-only режимом, SSH-туннелями и SSL — идеально для быстрого иссле...

microsoft/azure-devops-mcp

MCP сервер для Azure DevOps предоставляет AI-агентам доступ к проектам, рабочим элементам и вики. Рекомендуется удаленная версия, доступна и локальная. Инструмент упрощает взаимодействие с DevOps-данными через естественный язык.