iflow-mcp_rubenszimbres-a2a_adk_mcp

# Agent-to-Agent (A2A) Security Pipeline with MCP Integration This project implements a security-focused data processing pipeline using the Agent-to-Agent (A2A) protocol combined with Model Context Protocol (MCP) integration. The system provides secure database queries through a multi-agent architecture. ## System Architecture The system utilizes a layered architecture: 1. **A2A Protocol Layer**: Provides standardized communication between clients and agent services 2. **ADK Framework Layer**: Manages agent behavior and tool integration 3. **MCP Server Layer**: Provides specialized SQL and data processing tools ### Components - **A2A Servers**: Handle client requests and agent communication - **ADK Agents**: Process natural language requests using specialized tools - **MCP Server**: Provides SQL query and database interaction tools - **Task Managers**: Coordinate task execution across agents ## Agent Pipeline The system implements a security pipeline with three specialized agents: 1. **Judge Agent**: Evaluates input for security threats (SQL injection, XSS, etc.) 2. **SQL Agent**: Performs database queries and analysis using MCP tools 3. **Mask Agent**: Applies privacy protection to sensitive data in results ## Flow Diagram ``` Client Request → A2A Server → Judge Agent → SQL Agent → Mask Agent → Client Response ``` ## Key Features - **Security Threat Detection**: Identifies and blocks malicious inputs via tool and Model Armor - **SQL Query Analysis**: Processes database queries using natural language - **PII Data Protection**: Masks personally identifiable information in results using DLP - **A2A Protocol Compliance**: Implements standardized agent communication - **MCP Integration**: Leverages Model Context Protocol tools for enhanced capabilities ## Installation ### Prerequisites - Python 3.8+ - aiohttp - FastAPI - Google ADK - Google Generative AI packages - uvicorn ### Setup 1. Clone the repository 2. Install dependencies: `pip install -r requ…