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