airflow.providers.redis.operators.redis_publish

模組內容

類別

RedisPublishOperator

發布訊息至 Redis。
class airflow.providers.redis.operators.redis_publish.RedisPublishOperator(*, channel, message, redis_conn_id='redis_default', **kwargs)[原始碼]

基底類別： airflow.models.BaseOperator

發布訊息至 Redis。

參數

  • channel (str) – 要發布訊息的 redis 頻道 (可使用 Jinja 模板)

  • message (str) – 要發布的訊息 (可使用 Jinja 模板)

  • redis_conn_id (str) – 要使用的 redis 連線

template_fields: collections.abc.Sequence[str] = ('channel', 'message')[原始碼]
execute(context)[原始碼]

發布訊息至 Redis 頻道。

參數

context (airflow.utils.context.Context) – context 物件

此條目是否有幫助？