-
0 votesanswersviews
Python Kombu - 阻止
我正在使用kombu通过 生产环境 者/消费者模型管理RabbitMQ . 我启动了我的 生产环境 者，它在队列中放置了100个作业（我只有一个队列和一个交换） . 我想同时启动多个消费者，让每个消费者一次处理一个工作 . 不幸的是，消费者互相阻塞（即，当一个消费者从队列中抓取一份工作时，其他消费者只是闲置着） . 如果我杀死了工作消费者，那么其他一个消费者就会开始工作并开始工作 . 有没有办法让... -
4 votesanswersviews
Kombu RabbitMQ：检查队列是否为空
架构 考虑具有DB记录的系统 . 每条记录可以是 live 或 expired 状态;应使用外部软件模块定期处理 live 记录 . 我使用Kombu和RabbitMQ的经典制作人 - 消费者架构解决了这个问题 . 生产环境 者每隔几秒从DB中提取记录，消费者处理它们 . 问题 live 事件的数量变化很大，在高峰时段，消费者无法处理负载，并且队列被数千个项目堵塞 . 我想使系统自适应，以便 ... -
1 votesanswersviews
异步AMQP 生产环境 者和消费者
我有一个双向AMQP服务，它既消耗来自队列的消息，又发布到扇出交换 . 对称的客户端从交换中消耗并发布到队列 . （这不是聊天服务器，但可以很容易地将其视为聊天服务器 . ）传入和传出消息不是1：1 . 传出消息可以响应于传入消息，或者可以基于时间或诸如数据库的改变之类的其他异步因素来生成 . 我目前使用带有BlockingConnection的Pika内置Python，但它需要两个完整的连接（... -
3 votesanswersviews
当EC2实例停止或终止时，RabbitMQ Connections不会自动关闭
我正在使用python的Kombu（3.0.26）和librabbitmq连接器在EC2实例上连接到AWS中的rabbitmq . 当我启动和停止应用程序时，与兔子的连接出现并按预期消失 . 当我再次使用TERM或KILL杀死应用程序时，连接会像Rabbitmq上的预期一样消失 . 但是，如果我使用AWS控制台停止或终止实例，则连接将永久保留在rabbitmq上，直到我进入并强制关闭连接 . 我可... -
7 votesanswersviews
使用具有多个线程的rabbitmq消息队列（Python Kombu）
我有一个RabbitMQ交换与一个队列 . 我希望创建一个运行多个线程的守护进程，并尽快通过此队列 . “工作”涉及与外部服务进行通信，因此每个消费者中将会有相当多的阻止 . 因此，我想让多个线程处理来自同一队列的消息 . 我可以通过在我的主线程上使用队列来实现这一点，然后将传入的工作转移到其他线程池中，但是有没有办法在每个线程的上下文中启动多个使用者？ -
0 votesanswersviews
获取ImportError：无法导入名称OrderedDict
我收到了错误 ImportError：无法导入名称OrderedDict 在我的ubuntu 14.04机器上本地安装服务器 .我已经尝试手动安装ordereddict并尝试升级kombu但它仍然给出了错误 . 完整的追溯添加在下面 - rishav @ Swastik：〜/ open-event-orga-server $ sudo python create_db.py Tracebac...