delete_sql_processor
Remove SQL processors from Kafka environments to manage data processing resources. Specify environment and processor ID to delete.
Instructions
Removes an existing SQL processor.
Args: environment: The environment name. sql_processor_id: SQL processor unique identifier.
Returns: Success message confirming the deletion.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment | Yes | ||
| sql_processor_id | Yes |
Implementation Reference
- The core handler function for the 'delete_sql_processor' tool. It constructs the API endpoint and performs a DELETE request via api_client to remove the specified SQL processor.@mcp.tool() async def delete_sql_processor(environment: str, sql_processor_id: str) -> str: """ Removes an existing SQL processor. Args: environment: The environment name. sql_processor_id: SQL processor unique identifier. Returns: Success message confirming the deletion. """ endpoint = f"/api/v1/environments/{environment}/proxy/api/v1/streams/{sql_processor_id}" return await api_client._make_request("DELETE", endpoint)
- src/lenses_mcp/server.py:32-32 (registration)Registers the SQL processors tools, including 'delete_sql_processor', by calling the register_sql_processors function with the MCP instance.register_sql_processors(mcp)
- src/lenses_mcp/server.py:16-16 (registration)Imports the register_sql_processors function used to register the delete_sql_processor tool.from tools.sql_processors import register_sql_processors