cloudera/nifi-mcp-server

Browser automation

이 페이지는 AI로 자동 번역되었습니다. 기술적인 세부 사항은 원문을 확인하세요. 원문 보기

7 stars 10 forks 품질 70 트렌드 15Apache-2.0

Repository Install

Model Context Protocol server providing selectable read and write access to Apache NiFi via Apache Knox.

개요

Model Context Protocol server providing selectable read and write access to Apache NiFi via Apache Knox. - automatic version detection and adaptation. - - Detects NiFi 1.x vs 2.x and adapts behavior - - Supports Bearer tokens, cookies, and passcode tokens for CDP deployments - - Safe exploration of NiFi flows and configuration - - Pattern recognition and requirements gathering for complex flows - for exploring NiFi: - get_nifi_version() - Version and build information - get_root_process_group() - Root process group details - list_processors(process_group_id) - List processors in a process group - list_connections(process_group_id) - List connections in a process group - get_bulletins(after_ms?) - Recent bulletins and alerts - list_parameter_contexts() - Parameter contexts - get_controller_services(process_group_id?

README

원문 README의 일부입니다. 원문 보기.

NiFi MCP Server (via Knox)

Model Context Protocol server providing selectable read and write access to Apache NiFi via Apache Knox.

Works with both NiFi 1.x and 2.x - automatic version detection and adaptation.

Features

Automatic version detection - Detects NiFi 1.x vs 2.x and adapts behavior
Knox authentication - Supports Bearer tokens, cookies, and passcode tokens for CDP deployments
Read-only by default - Safe exploration of NiFi flows and configuration
Intelligent flow building - Pattern recognition and requirements gathering for complex flows
24 read-only MCP tools for exploring NiFi:
- get_nifi_version() - Version and build information
- get_root_process_group() - Root process group details
- list_processors(process_group_id) - List processors in a process group
- list_connections(process_group_id) - List connections in a process group
- get_bulletins(after_ms?) - Recent bulletins and alerts
- list_parameter_contexts() - Parameter contexts
- get_controller_services(process_group_id?) - Controller services
- get_processor_types() - Available processor types for flow building
- search_flow(query) - Search for components in the flow
- get_connection_details(connection_id) - Detailed connection information
- get_processor_details(processor_id) - Detailed processor configuration
- list_input_ports(process_group_id) - Input ports for a process group
- list_output_ports(process_group_id) - Output ports for a process group
- get_processor_state(processor_id) - Quick processor state check
- check_connection_queue(connection_id) - Queue size (flowfiles + bytes)
- get_flow_summary(process_group_id) - Flow statistics and health overview
- analyze_flow_build_request(user_request) - Intelligent pattern recognition and requirements gathering
- get_parameter_context_details(context_id) - Get parameter context with all parameters
- get_flow_health_status(process_group_id) - Comprehensive flow health check (processors, services, connections, errors)
- find_controller_services_by_type(process_group_id, service_type) - Search for existing controller services by type (prevents 409 conflicts)
- check_configuration() - Validate current environment configuration
- get_setup_instructions() - Interactive setup guidance for NiFi MCP Server
- get_best_practices_guide() - Best practices for building NiFi flows
- get_recommended_workflow(flow_type) - Step-by-step guidance for common flow patterns
42 write operations (when NIFI_READONLY=false):
- start_processor(processor_id, version) - Start a processor
- stop_processor(processor_id, version) - Stop a processor
- create_processor(...) - Create a new processor
- update_processor_config(...) - Update processor configuration
- delete_processor(processor_id, version) - Delete a processor

GitHub에서 전체 README 보기

설치

uvx --from git+https://github.com/cloudera/nifi-mcp-server@main run-server

MCP 초보자라면? mcpskill.org 가이드부터 시작하세요 →

설정

{
      "mcpServers": {
        "nifi-mcp-server": {
          "command": "/FULL/PATH/TO/NiFi-MCP-Server/.venv/bin/python",
          "args": [
            "-m",
            "nifi_mcp_server.server"
          ],
          "env": {
            "MCP_TRANSPORT": "stdio",
            "NIFI_API_BASE": "https://nifi-2-dh-management0.yourshere.cloudera.site/nifi-2-dh/cdp-proxy/nifi-app/nifi-api",
            "KNOX_TOKEN": "<your_knox_bearer_token>",
            "NIFI_READONLY": "true"
          }
        }
      }
    }