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[源代码]

此条目是否有帮助?