tests.system.redis.example_redis_publish
这是一个使用 RedisPublishOperator、RedisPubSubSensor 和 RedisKeySensor 的 DAG 示例。在此示例中,我们创建 3 个按顺序执行的任务。第一个任务是使用 RedisPublishOperator 向 redis 发布特定消息。第二个任务是使用 RedisPubSubSensor 等待特定通道中的特定消息到达 redis,第三个任务是使用 RedisKeySensor 等待特定键到达 redis。
模块内容
-
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]