tests.system.redis.example_redis_publish
¶
这是一个示例 DAG,它使用 RedisPublishOperator、RedisPubSubSensor 和 RedisKeySensor。在此示例中,我们创建了 3 个按顺序执行的任务。第一个任务是使用 RedisPublishOperator 将特定消息发布到 redis。第二个任务是使用 RedisPubSubSensor 等待特定通道上的特定消息到达 redis,第三个任务是使用 RedisKeySensor 等待特定键到达 redis。