Wrapper for SQL map transform with common pipeline fields.

Sql Map🔗

Wrapper for SQL map transform with common pipeline fields.

Configuration🔗

FieldTypeRequiredDefaultDescription
inputs[string]yesList of upstream component names to receive events from.
error_policyErrorPolicynodrop_on_errorPolicy for handling events that cause errors during transformation.
querystringyesSQL query to execute against the incoming payload.

Telemetry🔗

This component emits the following standard telemetry metrics and events.

Metrics🔗

NameTypeDescription
component_received_events_totalCounterTotal number of events received from upstream.
component_sent_events_totalCounterTotal number of events sent downstream.
component_errors_totalCounterTotal number of errors encountered during processing.

Events🔗

NameDescription
ComponentErrorEmitted when an error occurs during component execution.
ComponentEventsDroppedEmitted when events are intentionally or unintentionally dropped.

Example🔗

transforms:
  my_sql_map:
    type: sql_map
    inputs: # required
    query: SELECT * FROM payload