get_dataset
Retrieve detailed information about a specific dataset from a Kafka connection, including fields, policies, permissions, and metadata for data management and exploration.
Instructions
Get a single dataset by connection/name.
Args: environment: The environment name. connection: The connection name (e.g., "kafka"). dataset: The dataset name.
Returns: Dataset details including fields, policies, permissions, and metadata.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment | Yes | ||
| connection | Yes | ||
| dataset | Yes |
Output Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||
Implementation Reference
- src/lenses_mcp/tools/topics.py:384-398 (handler)Handler function implementing the get_dataset tool logic. It makes an API request to retrieve dataset details.
@mcp.tool() async def get_dataset(environment: str, connection: str, dataset: str) -> Dict[str, Any]: """ Get a single dataset by connection/name. Args: environment: The environment name. connection: The connection name (e.g., "kafka"). dataset: The dataset name. Returns: Dataset details including fields, policies, permissions, and metadata. """ endpoint = f"/api/v1/environments/{environment}/proxy/api/v1/datasets/{connection}/{dataset}" return await api_client._make_request("GET", endpoint) - src/lenses_mcp/server.py:33-33 (registration)Registration of the topics module, which includes the get_dataset tool via the register_topics function call.
register_topics(mcp)