airflow.providers.redis.sensors.redis_pub_sub¶

類¶

RedisPubSubSensor

用於從釋出/訂閱通道讀取訊息的 Redis 感測器。

模組內容¶

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

基類： airflow.sensors.base.BaseSensorOperator

用於從釋出/訂閱通道讀取訊息的 Redis 感測器。

引數：

channels (list[str] | str) – 要訂閱的通道（可模板化）
redis_conn_id (str) – redis 連線 ID

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

ui_color = '#f0eee4'[source]¶

channels[source]¶

redis_conn_id[source]¶

property pubsub[source]¶

poke(context)[source]¶

檢查已訂閱通道上的訊息，並將型別為“message”的訊息及其鍵 message 寫入 xcom。

一個訊息示例： {'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'hello'}

引數：: context (airflow.sdk.definitions.context.Context) – 上下文物件
返回：: 如果訊息（型別為“message”）可用則返回 True，否則返回 False
返回型別：: bool

此條目是否有幫助？