airflow.providers.redis.operators.redis_publish¶

Classes¶

RedisPublishOperator

Publish a message to Redis.

Module Contents¶

class airflow.providers.redis.operators.redis_publish.RedisPublishOperator(*, channel, message, redis_conn_id='redis_default', **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Publish a message to Redis.

Parameters:

channel (str) – redis channel to which the message is published (templated)
message (str) – the message to publish (templated)
redis_conn_id (str) – redis connection to use

template_fields: collections.abc.Sequence[str] = ('channel', 'message')[source]¶

redis_conn_id = 'redis_default'[source]¶

channel[source]¶

message[source]¶

execute(context)[source]¶

Publish the message to Redis channel.

Parameters:: context (airflow.sdk.definitions.context.Context) – the context object