Synadia Connect

MongoDB Query

NAMERUNTIMETYPEVERSIONSTATUS
mongodbwombatsourcelatestpreview

Executes a query and creates a message for each document received.

Configuration

nametypeoptionalsecretdescription
urlstringnonoThe MongoDB connection URL.
databasestringnonoThe name of the database to query.
usernamestringyesnoThe username to authenticate with. The value defaults to ``.
passwordstringyesnoThe password to authenticate with. The value defaults to ``.
collectionstringnonoThe name of the collection to query.
operationstringyesnoThe operation to perform. The value defaults to find.
querystringnonoBloblang expression describing MongoDB query.
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.
batch_sizeintyesnoA explicit number of documents to batch up before flushing them for processing. Must be greater than 0. The value defaults to 0.
sortsortyesnoAn object specifying fields to sort by, and the respective sort order (1 ascending, -1 descending). Note: The driver currently appears to support only one sorting key. Operations: find. The value defaults to map[].
limitintyesnoThe maximum number of documents to return. Operations: find. The value defaults to 0.

Sort

nametypeoptionalsecretdescription
Previous
Generate