| :py:mod:`airflow.providers.redis.operators.redis_publish` |
| ========================================================= |
| |
| .. py:module:: airflow.providers.redis.operators.redis_publish |
| |
| |
| Module Contents |
| --------------- |
| |
| Classes |
| ~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.providers.redis.operators.redis_publish.RedisPublishOperator |
| |
| |
| |
| |
| .. py:class:: RedisPublishOperator(*, channel, message, redis_conn_id = 'redis_default', **kwargs) |
| |
| Bases: :py:obj:`airflow.models.BaseOperator` |
| |
| Publish a message to Redis. |
| |
| :param channel: redis channel to which the message is published (templated) |
| :param message: the message to publish (templated) |
| :param redis_conn_id: redis connection to use |
| |
| .. py:attribute:: template_fields |
| :annotation: :Sequence[str] = ['channel', 'message'] |
| |
| |
| |
| .. py:method:: execute(self, context) |
| |
| Publish the message to Redis channel |
| |
| :param context: the context object |
| |
| |
| |
