Stable (4.0.2)4.0.24.0.14.0.03.8.03.7.13.7.03.6.13.6.03.5.03.4.13.4.03.3.23.3.13.3.03.2.13.2.03.1.03.0.02.0.42.0.32.0.22.0.12.0.01.0.11.0.0
Stable (4.0.2)4.0.24.0.14.0.03.8.03.7.13.7.03.6.13.6.03.5.03.4.13.4.03.3.23.3.13.3.03.2.13.2.03.1.03.0.02.0.42.0.32.0.22.0.12.0.01.0.11.0.0

airflow.providers.redis.operators.redis_publish

Module Contents

class airflow.providers.redis.operators.redis_publish.RedisPublishOperator(*, channel: str, message: str, redis_conn_id: str = '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 = ['channel', 'message'][source]
execute(self, context: Dict)[source]

Publish the message to Redis channel

Parameters

context (dict) -- the context object

Was this entry helpful?