Synadia Connect

Azure CosmosDB

NAMERUNTIMETYPEVERSIONSTATUS
azure_cosmosdbwombatsourcelatestpreview

Executes a SQL query against Azure CosmosDB and creates a batch of messages from each page of items.

Configuration

nametypeoptionalsecretdescription
connection_stringstringnonoA CosmosDB connection string.
databasestringnonoThe name of the database to query.
containerstringnonoThe name of the container to query.
querystringnonoThe query to execute. The query should be a valid SQL query. The query can be parameterized using the args_mapping field.
args_mappingstringnonoA Bloblang mapping that, for each message, creates a list of arguments to use with the query.
partition_keys_mapstringnonoA Bloblang mapping which should evaluate to a single partition key value or an array of partition key values of type string, integer or boolean. Currently, hierarchical partition keys are not supported so only one value may be provided.
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 Blob Storage