list_sql_processors
Retrieve SQL processor details from Kafka environments to manage and monitor data processing pipelines in Lenses.io.
Instructions
Retrieves all SQL processor details.
Args: environment: The environment name.
Returns: A dictionary containing a list of all SQL processors with their details.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment | Yes |
Implementation Reference
- The handler function decorated with @mcp.tool() that implements the logic for listing SQL processors by making an API GET request to the specified endpoint.@mcp.tool() async def list_sql_processors(environment: str) -> Dict[str, Any]: """ Retrieves all SQL processor details. Args: environment: The environment name. Returns: A dictionary containing a list of all SQL processors with their details. """ endpoint = f"/api/v1/environments/{environment}/proxy/api/v2/streams" return await api_client._make_request("GET", endpoint)
- src/lenses_mcp/server.py:32-32 (registration)The call to register_sql_processors(mcp) which registers the list_sql_processors tool along with other SQL processor tools.register_sql_processors(mcp)
- src/lenses_mcp/tools/sql_processors.py:10-10 (registration)The registration function that defines and registers the SQL processors tools, including list_sql_processors, using FastMCP decorators.def register_sql_processors(mcp: FastMCP):