tests.system.redis.example_redis_publish

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

属性

ENV_ID

default_args

publish_task

test_run

模块内容

tests.system.redis.example_redis_publish.ENV_ID[source]
tests.system.redis.example_redis_publish.default_args[source]
tests.system.redis.example_redis_publish.publish_task[source]
tests.system.redis.example_redis_publish.test_run[source]

此条目是否有帮助?