get_sql_processor
Retrieve detailed information about a specific SQL processor in Apache Kafka environments, including application metadata and deployment status.
Instructions
Retrieves a single SQL processor by ID.
Args: environment: The environment name. sql_processor_id: SQL processor unique identifier.
Returns: Detailed SQL processor information including application, metadata, and deployment status.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment | Yes | ||
| sql_processor_id | Yes |
Output Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||
Implementation Reference
- The handler function for the 'get_sql_processor' MCP tool. It is decorated with @mcp.tool() which registers it with FastMCP. The function makes a GET request to the Lenses API to retrieve details of a specific SQL processor by its ID in the given environment.
@mcp.tool() async def get_sql_processor(environment: str, sql_processor_id: str) -> Dict[str, Any]: """ Retrieves a single SQL processor by ID. Args: environment: The environment name. sql_processor_id: SQL processor unique identifier. Returns: Detailed SQL processor information including application, metadata, and deployment status. """ endpoint = f"/api/v1/environments/{environment}/proxy/api/v2/streams/{sql_processor_id}" return await api_client._make_request("GET", endpoint)