Redis List ListPop
CertifiedPop elements from a Redis list
Redis List ListPop
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.
type: io.kestra.plugin.redis.list.ListPopExamples
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
Installation
Our standard Docker images already include this plugin. If you use a -slim image or another setup, install it with the following command:
kestractl plugins get io.kestra.plugin:plugin-redis --compatible-for $KESTRA_VERSION For kestractl, use your Kestra version with --compatible-for, or specify an exact plugin version.
For Kestra CLI, replace LATEST with a specific version or version range to pin the plugin version.
Properties
key *string
Redis list key
Rendered key passed to LPOP.
serdeType *string
STRINGSTRINGJSONSerialization format
Defaults to STRING. Controls how list elements are decoded. With JSON, an element that is not valid JSON is kept as a string and a warning is logged.
url *string
Redis connection string
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150count integerstring
100Batch 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.
Outputs
count integer
Number of elements retrieved
uri string
uriURI of a Kestra internal storage file
Metrics
popped.records.count counter
recordsNumber of records retrieved from Redis List.
popped.records.undecodable.count counter
recordsNumber of records that could not be decoded with serdeType and were kept as strings.
