create_sql_processor
Create SQL processors to query and transform Kafka data streams across clusters using Lenses.io, with configurable deployment options.
Instructions
Creates a new SQL processor.
Args: environment: The environment name. name: The name of the SQL processor. sql: The SQL query/statement for the processor. deployment: Deployment configuration including details like mode, runners, cluster, namespace, etc. If there are no available deployment targets (Kubernetes or Connect clusters), use 'in process' mode: {{mode: "IN_PROC"}} sql_processor_id: Optional processor ID. If not provided, will be auto-generated. description: Optional description of the processor. tags: Optional list of tags for the processor.
Returns: The created SQL processor object with its ID.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment | Yes | ||
| name | Yes | ||
| sql | Yes | ||
| deployment | No | ||
| sql_processor_id | No | ||
| description | No | ||
| tags | No |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||