ESC
Ask Kestra AI
ESC
Kestra AI

Hi! I'm your Kestra AI assistant.
Ask me anything about workflows.

EXAMPLE QUESTIONS

How to set up CI/CD for kestra flows?
How to run dbt?
How to trigger a flow after another one?

Redis Publish

Redis Publish

Certified

Publish values to a Redis channel

Serializes values with the selected serde (STRING by default) and publishes each to the rendered channel; accepts inline lists or a Kestra storage URI.

yaml
type: io.kestra.plugin.redis.pubsub.Publish
yaml
id: redis_publish
namespace: company.team

tasks:
  - id: publish
    type: io.kestra.plugin.redis.pubsub.Publish
    url: redis://:redis@localhost:6379/0
    channel: mych
    from:
      - id: 1
        name: alice
      - id: 2
        name: bob
    serdeType: JSON
Properties

Redis channel

Rendered before publishing.

Values to publish

String or list; a string may point to a storage URI to stream values.

DefaultSTRING
Possible Values
STRINGJSON

Serialization format

Defaults to STRING; controls encoding before PUBLISH.

Redis connection string

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.

Definitions
assetFailureBehaviorstring
Possible Values
IGNOREFAILWARN

Asset 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.

enableAutobooleanstring

Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.

inputsarray

The assets consumed as inputs.

id*string
Min length1
typestring
outputs

The assets produced as outputs.

id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*string
Min length1

Custom asset type

descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150

Count

The number of values published

Unitrecords

Number of records published to a Redis channel.

More Plugins in this Category

Arrow Flight
Arrow Flight

Tasks that connect to Apache Arrow Flight SQL via JDBC to run queries and loads.

DataInfrastructure

3 tasks

Twilio
Twilio

Tasks that integrate with the Twilio ecosystem.

BusinessData

9 tasks

3 blueprints