Synadia Connect

GCP BigQuery Select

NAMERUNTIMETYPEVERSIONSTATUS
gcp_bigquery_selectwombatsourcelatestpreview

Executes a SELECT query against BigQuery and creates a message for each row received.

Configuration

nametypeoptionalsecretdescription
projectstringnonoGCP project where the query job will execute.
credentials_jsonstringnonoJSON credentials for authenticating with GCP.
tablestringnonoFully-qualified BigQuery table name to query.
columns[]stringnonoList of columns to select from the table.
wherestringyesnoOptional WHERE clause to filter rows. Placeholder arguments are populated with the args_mapping field. Placeholders should always be question marks (?). The value defaults to ``.
args_mappingstringyesnoAn optional Bloblang mapping which should evaluate to an array of values matching in size to the number of placeholder arguments in the field where. The value defaults to ``.
auto_replay_nacksboolyesnoWhether messages that are rejected (nacked) at the output level should be automatically replayed indefinitely, eventually resulting in back pressure if the cause of the rejections is persistent. If set to false these messages will instead be deleted. Disabling auto replays can greatly improve memory efficiency of high throughput streams as the original shape of the data can be discarded immediately upon consumption and mutation. The value defaults to true.
Previous
Azure Table Storage