execute_sql
Execute SQL queries on Kafka topics across multiple clusters using Lenses.io WebSocket API to manage, explore, transform, and join streaming data.
Instructions
Executes SQL statements/queries using Lenses WebSocket API.
Args: environment: The environment name. sql: The SQL statement/query to execute.
Returns: A list of MessageRecord objects representing the result of the SQL query.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment | Yes | ||
| sql | Yes |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
| result | Yes |