tests.system.redis.example_redis_publish

這是一個範例 DAG,它使用 RedisPublishOperator、RedisPubSubSensor 和 RedisKeySensor。在這個範例中,我們建立 3 個循序執行的任務。第一個任務是使用 RedisPublishOperator 將特定訊息發佈到 redis。第二個任務是使用 RedisPubSubSensor 等待特定訊息在特定通道到達 redis,第三個任務是使用 RedisKeySensor 等待特定鍵到達 redis。

模組內容

tests.system.redis.example_redis_publish.ENV_ID[原始碼]
tests.system.redis.example_redis_publish.default_args[原始碼]
tests.system.redis.example_redis_publish.publish_task[原始碼]
tests.system.redis.example_redis_publish.test_run[原始碼]

這個條目是否有幫助?