Servidor MCP Prefect

Una implementación de servidor de Protocolo de contexto de modelo (MCP) para Prefect , que permite a los asistentes de IA interactuar con Prefect a través del lenguaje natural.

Características

Este servidor MCP proporciona acceso a las siguientes API de Prefect:

Gestión de flujos : enumerar, obtener y eliminar flujos
Gestión de ejecuciones de flujo : crear, supervisar y controlar ejecuciones de flujo
Gestión de implementaciones : administre las implementaciones y sus programaciones
Gestión de ejecución de tareas : supervisar y controlar las ejecuciones de tareas
Gestión de colas de trabajo : crear y gestionar colas de trabajo
Gestión de bloques : acceso a tipos de bloques y documentos
Gestión de variables : crear y gestionar variables
Gestión de espacios de trabajo : Obtenga información sobre los espacios de trabajo

Related MCP server: n8n MCP Server

Configuración

Establezca las siguientes variables de entorno:

export PREFECT_API_URL="http://localhost:4200/api" # URL of your Prefect API export PREFECT_API_KEY="your_api_key" # Your Prefect API key (if using Prefect Cloud)

Uso

Ejecute el servidor MCP y perfeccione:

docker compose up

Ejemplo de entrada

Una vez conectado, un asistente de IA puede ayudar a los usuarios a interactuar con Prefect usando lenguaje natural. Ejemplos:

"Muéstrame todos mis flujos"
"Enumerar todos los flujos fallidos de ayer"
Activar la implementación del 'procesamiento de datos'
"Pausar la programación para la implementación de 'informes diarios'"
"¿Cuál es el estado de mi última ejecución de flujo ETL?"

Desarrollo

Varios de los puntos finales aún no se han implementado

Agregar nuevas funciones

Para agregar una nueva función a una API existente:

Agregue la función al módulo apropiado en src/mcp_prefect
Agregue la función a la lista get_all_functions() en el módulo

Para agregar un nuevo tipo de API:

Agregue el nuevo tipo a APIType en enums.py
Crea un nuevo módulo en src/prefect/
Actualice main.py para incluir el nuevo tipo de API

Ejemplo de uso:

{ "mcpServers": { "mcp-prefect": { "command": "mcp-prefect", "args": [ "--transport", "sse" ], "env": { "PYTHONPATH": "/path/to/your/project/directory" }, "cwd": "/path/to/your/project/directory" } } }