`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) – 上下文对象
返回: 如果有消息（类型为“message”），则返回 True，否则返回 False
返回类型: bool

此条目是否有帮助？