Wait for query on a MongoDB collection.

Wait for a MongoDB query to return results, and then iterate through rows.

yaml
           id: mongodb_trigger
           namespace: company.team

           tasks:
             - id: each
               type: io.kestra.plugin.core.flow.ForEach
values: "{{ trigger.rows }}"
               tasks:
                 - id: return
                   type: io.kestra.plugin.core.debug.Return
                   format: "{{ json(taskrun.value) }}"

           triggers:
             - id: watch
               type: io.kestra.plugin.mongodb.Trigger
               interval: "PT5M"
               connection:
                 uri: mongodb://root:example@localhost:27017/?authSource=admin
               database: samples
               collection: books
               filter:
                 pageCount:
                   $gte: 50
               sort:
                 pageCount: -1
               projection:
                 title: 1
                 publishedDate: 1
                 pageCount: 1

Dynamic NO

SubType

Dynamic NO

List of conditions in order to limit the flow trigger.

Dynamic NO

Default 60

Format duration

Interval between polling.

The interval between 2 different polls of schedule, this can avoid to overload the remote system with too many calls. For most of the triggers that depend on external systems, a minimal interval must be at least PT30S. See ISO_8601 Durations for more information of available interval values.

Dynamic NO

SubType string

Dynamic NO

List of execution states after which a trigger should be stopped (a.k.a. disabled).

Dynamic NO

Default false

List containing the fetched data.

Only populated if store parameter is set to false.

The number of rows fetched.

Format uri

URI of the file containing the fetched results.

Only populated if store parameter is set to true.

Dynamic YES

Min length 1

Connection string to MongoDB server.

URL format like mongodb://mongodb0.example.com:27017

​Trigger

Trigger