TriggerList
type: "io.kestra.plugin.redis.TriggerList"
Wait for key of type list in Redis database
Examples
id: list-listen
namespace: io.kestra.tests
tasks:
- id: echo trigger file
type: io.kestra.core.tasks.log.Log
message: "{{ trigger.uri }} containing {{ trigger.count }} lines"
triggers:
- id: watch
type: io.kestra.plugin.redis.TriggerList
url: redis://localhost:6379/0
key: mytriggerkey
maxRecords: 2
Properties
key
- Type: string
- Dynamic: ✔️
- Required: ✔️
The redis key for the list.
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.
count
- Type: integer
- Dynamic: ❓
- Required: ❌
- Default:
100
Number of elements that should be pop at once
interval
- Type: string
- Dynamic: ❌
- Required: ❌
- Default:
60.000000000
- Format:
duration
Interval between polling
The interval between 2 different test of schedule, this can avoid to overload the remote system with too many call. For most of trigger that depend on external system, a minimal interval must be at least PT30S. See ISO_8601 Durations for more information of available interval value
maxDuration
- Type: string
- Dynamic: ❓
- Required: ❌
- Format:
duration
The max duration waiting for new rows.
It's not an hard limit and is evaluated every second.
maxRecords
- Type: integer
- Dynamic: ❓
- Required: ❌
The max number of rows to fetch before stopping.
It's not an hard limit and is evaluated every second.
serdeType
- Type: object
- Dynamic: ❓
- Required: ❌
Outputs
count
- Type: integer
Number of elements retrieved
uri
- Type: string
URI of a kestra internal storage file