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.EachSequential
    tasks:
      - id: return
        type: io.kestra.plugin.core.debug.Return
        format: "{{ json(taskrun.value) }}"
    value: "{{ trigger.rows }}"

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.