TriggerList

yaml

type: "io.kestra.plugin.redis.TriggerList"

Wait for key of type list in Redis database.

Examples

yaml

id: list-listen
namespace: io.kestra.tests

tasks:
  - id: echo
    type: io.kestra.core.tasks.log.Log
    message: "{{ trigger.uri }} containing {{ trigger.count }} lines" 

triggers:
  - id: watch
    type: io.kestra.plugin.redis.TriggerList
    url: redis://localhost:6379/0
    key: mytriggerkey
    maxRecords: 2

Properties

`key`

Type: string
Dynamic: ✔️
Required: ✔️

The redis key for the list.

`url`

Type: string
Dynamic: ✔️
Required: ✔️

The connection string.

`conditions`

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

List of conditions in order to limit the flow trigger.

`count`

Type: integer
Dynamic: ❓
Required: ❌
Default: 100

Number of elements that should be pop at once

`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.