`airflow.providers.redis.sensors.redis_pub_sub`¶

模組內容¶

類別¶

RedisPubSubSensor

用於從 pub sub 頻道讀取訊息的 Redis 感測器。

class airflow.providers.redis.sensors.redis_pub_sub.RedisPubSubSensor(*, channels, redis_conn_id, **kwargs)[原始碼]¶

基底類別: airflow.sensors.base.BaseSensorOperator

用於從 pub sub 頻道讀取訊息的 Redis 感測器。

參數

channels (list[str] | str) – 要訂閱的頻道 (樣板化)
redis_conn_id (str) – redis 連線 ID

template_fields: collections.abc.Sequence[str] = ('channels',)[原始碼]¶

ui_color = '#f0eee4'[原始碼]¶

pubsub()[原始碼]¶

poke(context)[原始碼]¶

檢查訂閱頻道上是否有訊息，並將訊息寫入 xcom，鍵值為 message。

訊息範例 {'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'hello'}

參數: context (airflow.utils.context.Context) – context 物件
回傳: 如果訊息 (類型為 'message') 可用則回傳 True，否則回傳 False
回傳類型: bool

此條目是否有幫助？