Redis ListPop

Redis ListPop
Certified
Pop elements from a Redis list

Consumes list items with repeated LPOP calls in batches (default batch size 100) until maxRecords or maxDuration is reached, then writes the results to Kestra internal storage.

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

Examples

yaml
id: redis_list_pop
namespace: company.team

tasks:
  - id: list_pop
    type: io.kestra.plugin.redis.list.ListPop
    url: redis://:redis@localhost:6379/0
    key: mypopkeyjson
    serdeType: JSON
    maxRecords: 1
    maxDuration: PT10S
    count: 50

Properties

key *string

Redis list key

Rendered key passed to LPOP.

serdeType *string

DefaultSTRING

Possible Values

STRINGJSON

Serialization format

Defaults to STRING; controls how items are decoded.

url *string

Redis connection string

count integerstring

Default100

Batch size per pop

Defaults to 100.

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.

pluginDefaultsRef string

Reference (ref) of the pluginDefaults to apply to this task.

Outputs

count integer

Number of elements retrieved

uri string

Formaturi

URI of a Kestra internal storage file

Metrics

popped.records.count counter

Unitrecords

Number of records retrieved from Redis List.

Liquibase

Tasks that run Liquibase change management commands.

Data

PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

Redis ListPopCertifiedPop elements from a Redis list

More Plugins in this Category

Liquibase

PostgreSQL

Redis ListPop
Certified
Pop elements from a Redis list