kombu生产者是否可以在rabbitmq上将消息排队,然后由celery worker处理?看来celery 工人不明白kombu生产商提出的信息。
628mspwn1#
我知道要与RabbitMQ通信,您需要遵守AMQP规范的任何库。Kombu就是这样一个库,它可以绑定到RabbitMQ交换,通过产生大量消费者来监听和处理消息。Celery只不过是一个异步任务生成器,它有许多附加组件,如内存处理,写入DB/Redis缓存,执行复杂操作等。说现在可以使用kombu在RMQ中读写消息,并使用celery worker处理消息。
u5rb5r592#
celery 工人处理消息需要更多的信息。任务名称、标题中的id等。
2条答案
按热度按时间628mspwn1#
我知道要与RabbitMQ通信,您需要遵守AMQP规范的任何库。Kombu就是这样一个库,它可以绑定到RabbitMQ交换,通过产生大量消费者来监听和处理消息。Celery只不过是一个异步任务生成器,它有许多附加组件,如内存处理,写入DB/Redis缓存,执行复杂操作等。说现在可以使用kombu在RMQ中读写消息,并使用celery worker处理消息。
u5rb5r592#
celery 工人处理消息需要更多的信息。任务名称、标题中的id等。