一旦pika库中的消息队列为空,如何在Rabbit MQ中停止消费者



因此,我基本上是在RabbitMQ中尝试使用python客户端(Pika Library(从生产者向消费者发送一些消息,但默认情况下,接收器即使在读取消息后也会继续运行,因为它在等待更多消息,但根据我的要求,接收器应该在从队列中读取所有消息后停止一次队列是空的,或者至少它应该一个接一个地读取消息,当我再次打开它或在定义的时间段后,它应该再次读取消息,但主要关注的是停止接收器。那么我该如何在python的pika库中做到这一点呢。

接收器在从队列中读取所有消息后,基本上在队列为空时,应该停止一次

由于队列总是可以发布到,所以它们真的"吗;空的";?你需要提出一个条件来定义";"空";,类似于";在过去5秒内没有消息";或";消费者看到特定的CCD_ 1消息";。

我最近回答了一个类似的问题:

关闭在rabbitmq-pika 中处理长时间运行任务的空闲消费者

请参阅此代码,它演示了一个消费者在不活动5秒后停止:

https://github.com/lukebakken/so-pika-idle-consumer-72792217/blob/master/consumer.py


注意:RabbitMQ团队监控rabbitmq-users邮件列表,有时只回答StackOverflow上的问题

相关内容

  • 没有找到相关文章

最新更新