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(self, context)[source]

Publish the message to Redis channel

Parameters

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

Was this entry helpful?