Wrapper for SQL map transform with common pipeline fields.
Sql Map🔗
Wrapper for SQL map transform with common pipeline fields.
Configuration🔗
| Field | Type | Required | Default | Description |
inputs | [string] | yes | — | List of upstream component names to receive events from. |
error_policy | ErrorPolicy | no | drop_on_error | Policy for handling events that cause errors during transformation. |
query | string | yes | — | SQL query to execute against the incoming payload. |
Telemetry🔗
This component emits the following standard telemetry metrics and events.
Metrics🔗
| Name | Type | Description |
component_received_events_total | Counter | Total number of events received from upstream. |
component_sent_events_total | Counter | Total number of events sent downstream. |
component_errors_total | Counter | Total number of errors encountered during processing. |
Events🔗
| Name | Description |
ComponentError | Emitted when an error occurs during component execution. |
ComponentEventsDropped | Emitted when events are intentionally or unintentionally dropped. |
Example🔗
transforms:
my_sql_map:
type: sql_map
inputs: # required
query: SELECT * FROM payload