回答情况：
提问时间：
问题标签：
通过生产者/消费者模型，我使用kombu来管理RabbitMQ。我启动了我的生产者，它将100个作业放在一个队列中(我只有一个队列，一个交换)。
浏览 3提问于2014-05-30得票数 1
回答已采纳
我已经通过pip安装了kombu (甚至尝试了-U选项以获得最新版本)：Downloading/unpacking kombu Running setup.py egg_info for package kombu
Uninstalling kombu:
浏览 1提问于2013-01-17得票数 0
我正在寻找一种用kombu在rabbitmq中创建和配置vhosts的方法，但在文档中什么也没有找到。有没有办法做到这一点？
浏览 1提问于2016-05-10得票数 0
其他的是Kombu吗？我知道我需要在"x/2“处调用"Connection.heartbeat_check()”。我应该创建一个周期性的任务来称之为这一点吗？连接是如何重新建立的？我在用：
我的代码现在看起来是这样的。
浏览 1修改于2013-01-30得票数 3
回答已采纳
B运行RabbitMQ，而A通过Kombu连接到RabbitMQ。如果我在B上重新启动RabbitMQ，则kombu连接断开，消息不再传递。然后，我必须重置A上的进程以重新建立连接。有没有更好的方法，也就是说，有没有一种方法可以让Kombu自动重新连接，即使RabbitMQ进程重新启动了？ global rabbitmq_producer
incoming_exchange = komb
浏览 6提问于2016-06-02得票数 1
>>> from kombu.messaging import Consumer, Producer>>> x/kombu-1.0.6-py2.6.egg/kombu/messaging.py", line 241, in declareFile "/usr/lib&#
浏览 2修改于2011-04-27得票数 0
回答已采纳
我在使用kombu 4.1发布消息时遇到了问题。我的用例是，我有一个服务器，它从rabbitmq队列(队列1)收集消息，执行一些处理任务，然后将它们重新发布到另一个队列(队列2)。我也在kombu github页面上发布了这一期，但没有用：- 谢谢
浏览 2提问于2018-05-16得票数 1
我在代码中使用kombu，有时我从kombu的生产者发布方法中得到以下异常。我认为它更多地是在压力条件下复制的，所以可能是多线程问题，而异常描述似乎也指出了这一点。使用python 2.7.18，kombu 4.6.11，amqp 2.6.1，gevent 20.6.2File "C:\Python27\lib\site-pac
浏览 5提问于2020-09-06得票数 0
回答已采纳
我正在安装airflow版本1.9.0，并收到以下错误 Traceback (most recent call last):bcpmrstbssapp1 airflow: from kombu.entityimport Exchange, Queueairflow", line 456, in
浏览 43提问于2019-09-18得票数 0
我在kombu中有两个队列；一个用于提交请求(做某事)，另一个用于通过pub/sub显示所述请求的增量状态。因此，在我的流程中，它将发布到请求队列，并在响应队列上使用。由于该任务可能需要一些时间，因此我希望为用户提供关于后端发生的情况的反馈；所有这些都在命令行上工作，因为我的kombu consume回调允许我添加一条logging.info()语句，将信息传回给我的用户对象的输入： HttpResponse( gen() )
yield 'streamin
浏览 0提问于2011-06-10得票数 0
回答已采纳
然而，我不知道如何完成第一步:将kombu降级到2.5.16版本。我已经卸载了当前版本的kombu，我正在尝试使用："pip install kombu-2.5.16“失败，我的提示符提示它找不到满足此要求的版本。
浏览 8提问于2017-06-07得票数 0
建议按照AMQP规范将额外的AMQP属性作为关键字参数传递给publish，但是correlationId="foo"似乎没有达到预期的效果。
浏览 5提问于2013-11-20得票数 1
回答已采纳
我已经解决了这一问题，使用了一个经典的生产者-消费者架构与Kombu和RabbitMQ。生产者每隔几秒钟从数据库中获取记录，由使用者处理它们。
使用RabbitMQ REST：http://<host>:<port/api/queues/<vhost>/<queue_name>它可以工作，但它是另一个需要维护的机制，我更喜欢Kombu内部的一个优雅的解决方
浏览 6修改于2016-11-07得票数 4
我收到了一个kombu错误，不允许使用泡菜。kombu.exceptions.ContentDisallowed: Refusing to deserialize untrusted content of type pickle (application芹菜文档说(https://docs.celeryproject.org/projects/kombu/en/master/userguide/serialization.html#guide-serializa
浏览 62修改于2021-07-14得票数 1
我不知道如何用Kombu的ConsumerMixin来表达这一点。exchange=exchange, routing_key='foo.#')...but每次我试着得到：from kombu import Connection, Exchange, Queue
from kombu.mixins
浏览 16修改于2016-05-13得票数 4
回答已采纳
有什么好方法可以说服Celery+Kombu使用simplejson而不是标准库的json模块？我在听：celery5.2.3 /usr/local/lib/python3.10/site-packages pip
kombu 5.2.4 /
浏览 8修改于2022-09-30得票数 1
我如何关闭连接到扇出交换的Kombu ConsumerMixin队列，以便在我的消费者处于非活动状态时不会从发布者累积数据？我在Python2.7中使用Kombu 3.0.24 (带RabbitMQ)。from kombu.mixins import ConsumerMixin
from kombu import Queue, Exchange, Connection
浏览 5提问于2015-03-09得票数 0
我正在寻找一种方法来使用kombu作为tornado-sockjs和Django应用服务器之间的MQ适配器。我知道用于Tornado的Pika库适配器，但我想使用kombu，因为它已经在项目中使用，并且具有灵活的传输方式。
浏览 0修改于2015-06-17得票数 6
回答已采纳
我正在测试kombu是如何工作的。我计划在几个项目中替换pika。我看到kombu有很多文档，但是根据我在文档中找到的文档，一些消息丢失了。下面是代码：conn = Connection('amqp://localhost:5672')
def errback(
浏览 3提问于2014-01-07得票数 6
msg=publish_kombu()File "/usr/local/lib/python2.6/dist-packages/
浏览 1修改于2016-04-29得票数 1
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号