MongoDB Aggregate

Runs a MongoDB aggregation pipeline and outputs each result document

Processing

For each input row, the step runs an aggregation pipeline and outputs each resulting document into the row stream.

Name	Type	Description
Query
Connection	dict	The MongoDB connection to use. Evaluated for each input row
Database	string	The database to use. Evaluated for each input row
Collection	string	The collection to run the pipeline against. Set to `nil` or empty when running collection-agnostic commands. Evaluated for each input row
Pipeline	string or list	The aggregation pipeline to run. Example: `[ {$match: {"workplace.department": "Legal"}}, {$count: "lawyers"} ]` Evaluated for each input row
Processing
Batch Size	long	The batch size to set. Set to `nil` to use the driver default. Evaluated for each input row
Allow Disk Use	boolean	Sets the allowDiskUse flag for the query. Evaluated for each input row

The pipeline parameter is parsed as a BSON list when given as string.

Values and BSON are converted as per the following table:

Dicts of the form {'$oid' string} are converted to BSON ObjectIds and vice versa.

Function values cannot be converted to BSON.

Converting a dict to BSON generally results in an unspecified key order in the BSON object.

If the order of keys is important, you can supply a specially constructed dict of the form:

{
  :__bson [
    [key1, value1],
    [key2, value2],
    ...
  ]
}

Such dicts are converted to a BSON object with the order of key-value pairs preserved:

{
  key1: value1,
  key2: value2,
  ...
}

You can use the BSON widget to generate such dicts in the UI.

Name	Type	Description
record	dict	A dict containing the current result record.