Redis Trigger

Redis Trigger
Certified
Batch trigger from a Redis list

Periodically pops list items in batches using LPOP (default batch size 100) until maxRecords or maxDuration is reached, then starts one Execution. Use RealtimeTrigger instead for per-message executions.

yaml
type: io.kestra.plugin.redis.list.Trigger

Examples

yaml
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

Properties

key *string

Redis list key

Rendered key passed to LPOP.

serdeType *string

DefaultSTRING

Possible Values

STRINGJSON

Format of the data contained in Redis

url *string

Redis connection string

allowConcurrent boolean

Defaultfalse

Specifies whether a trigger is allowed to start a new execution even if a previous run is still in progress.

count integerstring

Default100

Batch size per evaluation

Defaults to 100.

interval string

DefaultPT1M

Formatduration

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.

maxDuration string

Maximum duration to poll

Soft cap evaluated each loop; required when maxRecords is not set.

maxRecords integerstring

Maximum rows to fetch

Soft cap evaluated each loop; required when maxDuration is not set.

stopAfter array

SubTypestring

Possible Values

CREATEDSUBMITTEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTRESUBMITTED

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

when string

Defaulttrue

A condition that determines whether the trigger should run.

A Pebble expression evaluated at trigger time. The trigger fires only when the expression evaluates to a truthy value (true, a non-empty string, a non-zero number). Use this to gate trigger execution on dynamic runtime values such as execution labels, flow variables, or environment conditions.

Outputs

count integer

Number of elements retrieved

uri string

Formaturi

URI of a Kestra internal storage file