Airflow MCP Server
by treerootboy
The Airflow MCP Server integrates with Apache Airflow, providing tools to manage and monitor DAG runs. It supports triggering DAGs, retrieving DAG status, backfilling data, and accessing logs.
Last updated: N/A
What is Airflow MCP Server?
The Airflow MCP Server is a Model Context Protocol server designed to interact with Apache Airflow. It offers a set of functionalities to manage and monitor Airflow DAGs, simplifying common tasks and providing insights into workflow execution.
How to use Airflow MCP Server?
To use the Airflow MCP Server, configure the mcp_config.json file with the necessary Airflow API credentials and server settings. Then, use the provided commands (e.g., trigger-dag, get-dag-status) via the specified interface (e.g., uvx airflow-mcp) to interact with Airflow. Refer to the provided example configuration for guidance.
Key features of Airflow MCP Server
Trigger DAGs
Enable DAGs
Get daily reports of DAG runs
List all available DAGs
Batch retrieve DAG run records
Get DAG run status
Get DAG logs
Backfill DAG data
Use cases of Airflow MCP Server
Automated DAG triggering based on external events
Monitoring DAG execution status in real-time
Troubleshooting DAG failures using detailed logs
Backfilling historical data for DAGs
Generating daily reports on DAG performance
FAQ from Airflow MCP Server
How do I configure the Airflow API connection?
How do I configure the Airflow API connection?
Set the AIRFLOW_API_BASE, AIRFLOW_USERNAME, and AIRFLOW_PASSWORD environment variables in the mcp_config.json file.
How do I trigger a DAG using the MCP server?
How do I trigger a DAG using the MCP server?
Use the trigger-dag command with the appropriate DAG ID.
How do I retrieve the logs for a specific DAG run?
How do I retrieve the logs for a specific DAG run?
Use the get-dag-logs command with the DAG ID and run ID.
How do I backfill data for a DAG?
How do I backfill data for a DAG?
Use the backfill-dag command, specifying the DAG ID and the date range for backfilling.
What is the purpose of the enable-dag command?
What is the purpose of the enable-dag command?
The enable-dag command activates a DAG that is currently disabled in Airflow.