-
0 votesanswersviews
Python Kombu - 阻止
我正在使用kombu通过 生产环境 者/消费者模型管理RabbitMQ . 我启动了我的 生产环境 者，它在队列中放置了100个作业（我只有一个队列和一个交换） . 我想同时启动多个消费者，让每个消费者一次处理一个工作 . 不幸的是，消费者互相阻塞（即，当一个消费者从队列中抓取一份工作时，其他消费者只是闲置着） . 如果我杀死了工作消费者，那么其他一个消费者就会开始工作并开始工作 . 有没有办法让... -
3 votesanswersviews
Python Pika - 消费者线程
我正在开发一个带有后台线程的Python应用程序，用于消费来自RabbitMQ队列的消息（主题场景） . 我在Button的on_click事件上启动线程 . 这是我的代码，请注意“＃self.receive_command（）” . def on_click_start_call(self,widget): t_msg = threading.Thread(target=self.r... -
1 votesanswersviews
RabbitMQ - 使用多个队列
我正在使用Python，RabbitMQ和Pika . 我有多个消费者和队列 . 我希望一个消费者从每个队列中获取消息 . 假设我有2个消费者和3个队列 . 我希望我的每个消费者都能从队列号1,2和3中读取消息 . 我已经设法使用basic_get： basic_get（队列1） basic_get（队列2） basic_get（队列3） =>从队列1获取一条消息，从队列2获取一条消息，从队... -
1 votesanswersviews
AMQP中的消息路由
我想用AMQP做一些路由魔术 . 我的设置是消费者/ 生产环境 者方面的Pika和针对AMQP服务器的RabbitMQ . 我想要实现的目标： 向单个交易所发送消息 （在这里插入魔法） 使用如下消息： 一组订户应该能够基于路由密钥进行检索 一组订阅者应该只获取所有消息 . 棘手的部分是，如果第二组中的任何服务器已收到消息，则第二组中的其他服务器将不会接收到该消息 . 第一组... -
0 votesanswersviews
队列最大长度或TTL使用get但不消耗
我看到许多帖子询问限制队列长度 . 在我对Pika和RabbitMQ的实验中，如果我使用 arguments={'x-message-ttl': 1000, 'x-max-length': 2, 'x-overflow': 'drop-head'} 声明队列，甚至在生成消息属性时将 expiration='1000' 添加到消息属性中，我可以看到所有这三个单独贡献从队列中删除消息 . 我的目标是确... -
0 votesanswersviews
使用RabbitMQ重置连接
直升机， 我是兔子的新手 . 我试图 Build 一个rabbitmq路由器，并使用鼠标在python中向他发送HelloWorld . 在终端我做sudo rabbitmq-server启动 . 我可以输入localhost：15672 . 但是当我尝试连接到localhost时：5672出现“AMQP”一秒钟，然后“连接被重置” . 在做sudo rabbitmqctl list_connec... -
0 votesanswersviews
连接RabbitMQ |皮卡| Kubernetes
我有一个kubernetes集群正在运行 . 在这里我有一个作为pod运行的python应用程序 . 这个应用程序正在与 rabbitmq 交谈，这也是同一群集的其中一个 . 因此整个连接使用内部IP完成 . 问题是我有一个rabbitmq服务，所以我提供服务IP连接 . 它看起来像这样（与鼠兔） credentials = pika.PlainCredentials(rabbituser, ra... -
0 votesanswersviews
RabbitMQ：从多个队列一次只消耗一条消息
我正试图在RabbitMQ中保持与多个队列的连接 . 每次我从其中一个队列中弹出一条新消息时，我都想生成一个外部进程 . 此过程将花费一些时间来处理消息，并且我不想开始处理来自该特定队列的另一条消息，直到我之前弹出的消息完成为止 . 如果可能的话，我不想让一个进程/线程只是等待外部进程完成并确认服务器 . 理想情况下，我想在这个外部进程中，可能会传递一些标识符，以便它可以连接到RabbitMQ并确... -
1 votesanswersviews
异步AMQP 生产环境 者和消费者
我有一个双向AMQP服务，它既消耗来自队列的消息，又发布到扇出交换 . 对称的客户端从交换中消耗并发布到队列 . （这不是聊天服务器，但可以很容易地将其视为聊天服务器 . ）传入和传出消息不是1：1 . 传出消息可以响应于传入消息，或者可以基于时间或诸如数据库的改变之类的其他异步因素来生成 . 我目前使用带有BlockingConnection的Pika内置Python，但它需要两个完整的连接（... -
7 votesanswersviews
AMQP：确认和预取
我尝试了解AMQP协议的某些方面 . 目前我有RabbitMQ的项目并使用python pika库 . 所以问题是关于确认和消息预取 . 考虑我们只有消费者队列（确定这个队列被声明为独占） . 所以我理解正确：无论我是否使用ack标志？无论如何，我不应该同时处理多个消息，并且没有其他消费者可以采取其他一些仍然排队的消息 . 最好不要打开确认，因为这可能会降低AMQP服务器负载 . 如果没有...