airflow.providers.redis.operators.redis_publish

Module Contents

Classes

RedisPublishOperator

Publish a message to Redis.
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: Sequence[str] = ('channel', 'message')[source]
execute(context)[source]

Publish the message to Redis channel.

Parameters

context (airflow.utils.context.Context) – the context object

Was this entry helpful?