Trigger

yaml

type: "io.kestra.plugin.mongodb.Trigger"

Wait for query on a MongoDB collection.

Examples

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

Properties

`collection`

Type: string
Dynamic: ❓
Required: ❌

`conditions`

Type: array
SubType: Condition
Dynamic: ❌
Required: ❌

List of conditions in order to limit the flow trigger.

`connection`

Type: MongoDbConnection
Dynamic: ❓
Required: ❌

`database`

Type: string
Dynamic: ❓
Required: ❌

`filter`

Type: object
Dynamic: ❓
Required: ❌

`interval`

Type: string
Dynamic: ❌
Required: ❌
Default: 60.000000000
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.