Removes and returns an element from the head of a list in real-time and create one execution per element.
If you would like to consume multiple elements processed within a given time frame and process them in batch, you can use the io.kestra.plugin.redis.list.Trigger instead.
yaml
type: "io.kestra.plugin.redis.list.RealtimeTrigger"Consume an element from the head of a list in real-time.
yaml
id: list_listen
namespace: company.team
tasks:
- id: echo
type: io.kestra.plugin.core.log.Log
message: "Received '{{ trigger.value }}'"
triggers:
- id: watch
type: io.kestra.plugin.redis.RealtimeTrigger
url: redis://localhost:6379/0
key: mytriggerkey
The value.