:mod:`airflow.providers.redis.operators.redis_publish`
======================================================

.. py:module:: airflow.providers.redis.operators.redis_publish


Module Contents
---------------

.. py:class:: RedisPublishOperator(*, channel: str, message: str, redis_conn_id: str = 'redis_default', **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: Dict)

      Publish the message to Redis channel

      :param context: the context object
      :type context: dict