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.

Definitions

Was this page helpful?