RealtimeTrigger
RealtimeTrigger
yaml
type: "io.kestra.plugin.redis.list.RealtimeTrigger"
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.
Examples
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
Properties
key
- Type: string
- Dynamic: ✔️
- Required: ✔️
The redis key for the list.
serdeType
- Type: object
- Dynamic: ❓
- Required: ✔️
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.
stopAfter
- Type: array
- SubType: string
- Dynamic: ❌
- Required: ❌
List of execution states after which a trigger should be stopped (a.k.a. disabled).
Outputs
value
- Type: object
- Required: ❌
The value.
Was this page helpful?