tests.system.redis.example_redis_publish¶

這是一個使用 RedisPublishOperator、RedisPubSubSensor 和 RedisKeySensor 的 DAG 示例。在此示例中，我們建立 3 個按順序執行的任務。第一個任務是使用 RedisPublishOperator 向 redis 釋出特定訊息。第二個任務是使用 RedisPubSubSensor 等待特定通道中的特定訊息到達 redis，第三個任務是使用 RedisKeySensor 等待特定鍵到達 redis。