PLUGINSPLUGIN-REDISTRIGGERSIO.KESTRA.PLUGIN.REDIS.TRIGGERLIST

​Trigger​List

TriggerList TriggerList

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

Wait for key of type list in Redis database

Examples

yaml
id: "trigger_list"
type: "io.kestra.plugin.redis.TriggerList"
id: list-listen
namespace: io.kestra.tests

tasks:
  - id: echo trigger file
    type: io.kestra.core.tasks.debugs.Echo
    format: "{{ trigger.uri') }} containing {{ trigger.count }} lines" 

triggers:
  - id: watch
    type: io.kestra.plugin.redis.Trigger
    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.

count

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

Number of elements that should be pop at once

interval

  • Type: string
  • Dynamic: ❌
  • Required: ❌
  • Default: PT1S
  • Format: duration

Interval between polling

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

maxDuration

  • Type: string
  • Dynamic: ❓
  • Required: ❌
  • Format: duration

The max duration waiting for new rows.

It's not an hard limit and is evaluated every second.

maxRecords

  • Type: integer
  • Dynamic: ❓
  • Required: ❌

The max number of rows to fetch before stopping.

It's not an hard limit and is evaluated every second.

serdeType

  • Type: object
  • Dynamic: ❓
  • Required: ❌

Outputs

count

  • Type: integer

Number of elements retrieved

uri

  • Type: string

URI of a kestra internal storage file