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