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.

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

Dynamic YES

The redis key for the list.

Dynamic YES

Default STRING

Possible Values

STRINGJSON

Format of the data contained in Redis

Dynamic YES

The connection string.

SubType

Dynamic NO

List of conditions in order to limit the flow trigger.

SubType string

Dynamic NO

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPED

List of execution states after which a trigger should be stopped (a.k.a. disabled).

The value.

​Realtime​Trigger

RealtimeTrigger