Trigger
Removes and returns an element from the head of a list periodically and create one execution per batch.
If you would like to consume each message from a list in real-time and create one execution per message, you can use the io.kestra.plugin.redis.list.RealtimeTrigger instead.
type: "io.kestra.plugin.redis.list.Trigger"id: list_listen
namespace: company.team
tasks:
- id: echo
type: io.kestra.plugin.core.log.Log
message: "{{ trigger.uri }} containing {{ trigger.count }} lines"
triggers:
- id: watch
type: io.kestra.plugin.redis.list.Trigger
url: redis://localhost:6379/0
key: mytriggerkey
maxRecords: 2
The redis key for the list.
Format of the data contained in Redis
The connection string.
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.
The max duration waiting for new rows.
It's not an hard limit and is evaluated every second.
List of execution states after which a trigger should be stopped (a.k.a. disabled).
Number of elements retrieved.
URI of a Kestra internal storage file.