python-pika

0热度

1回答

我有一个简单的码头构建，我想实现。拉基本图像odoo：9和安装鼠库 FROM odoo：9 RUN PIP安装鼠，但无法继续，因为我得到这个错误。 enter image description here btw，我在Windows环境中使用docker。

0热度

1回答

rabbitmq中的多个消费者为多个队列

我有2个队列，比如说q1和q2，它对应于e1和e2与绑定密钥b1和b2交换。我想要并行运行消费者功能，比如c1和c2，它们将分别监听q1和q2。我试了下面的方法： def c1(): connection = pika.BlockingConnection(pika.ConnectionParameters(host=constants.rmqHostIp)) channel

1热度

2回答

由于身份验证错误，无法从网络上的其他客户端访问RabbitMQ服务器

我在Ubuntu 14.04上安装了RabbitMQ，并且无法从网络上的其他计算机连接到RabbitMQ服务器。从安装了RabbitMQ的机器连接到服务器时，没有任何问题，只能从网络上的其他计算机连接到服务器。 This page指出“默认情况下，RabbitMQ将在所有可用接口上监听端口5672”。当试图从另一个serverusing鼠兔在python连接，我收到以下错误： ERROR:pi

0热度

2回答

Python中获取变量值的功能之外的RabbitMQ

下面是功能正在使用摆脱producer.py def callback(ch, method, properties, body): result = body.decode() resp = JSONEncoder().encode(result) json_resp = json.loads(resp) print(json_resp) ch.basic_ack(delivery_t

1热度

1回答

Python - 在独立线程中运行的函数之间传递函数（回调）变量

我正在尝试开发一个使用pika和线程模块的Python 3.6脚本。我有一个问题，我认为是由我的A）是非常新的Python和编码一般，和B）我不理解如何在函数之间传递变量时，他们在单独的线程中运行，并已通过接收函数名称末尾的括号中的参数。我认为这是因为当我不使用线程时，我可以简单地通过调用接收函数名称并提供要传递的变量，在括号中显示一个基本示例如下： def send_variable():

0热度

1回答

RabbitMQ - 套接字关闭异常 - Windows Server 2012

因此，我有一个发布商正在使用计划 python包来读取文件中的数据和每隔5-10分钟并将每行发布到队列中。在我一直在使用一些消费者喜欢的另一面： self.connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) self.channel = self.connection.channel

0热度

1回答

Pika可以在Ubuntu上连接到RabbitMq，但不能在Centos上工作？

相同的代码可以在Ubuntu上运行，而不是在Centos上运行！防火墙已关闭！ Ubuntu 16.04，python版本3.5.2。 Centos 7，python版本3.5.2。 Ubuntu和centos是virtualbox中新安装的！ RabbitMq config tls！在Centos上，如果连接rabbitmq disable ssl是可以的，但是如果连接rabbitmq ena

0热度

1回答

为什么这个全局变量在Python 2.7中更新，即使我使用全局关键字？

我有一个回调函数，它在收到每条消息时返回AMQP消息的主体。我希望能够将正文的内容分配给全局变量，然后在我的程序中进一步处理它。我在脚本的顶部创建了一个全局变量，并且在回调函数中使用了global关键字，我知道应该允许我更新脚本顶部的全局变量，但是当我导入' “从另一个脚本，我得到的原始值‘测试全局变量’返回，而不是身体的从回调函数中的当前值... Consumer.py **python/pi

1热度

1回答

pika.BlockingConnection（）失败容器内，在虚拟机内运行良好

我想在我的容器中使用rabbitmq。我安装了所需的库，然后尝试创建BlockingConnection，但失败。当我在任何虚拟机或物理主机上尝试它时，也是如此。它仅以容器失败。具体操作步骤如下： - 安装所需的软件包： - $ docker run -it ubuntu:15.10 /bin/bash [email protected]# [email protected]# sudo ap

1热度

1回答

的Python 3.6：如何创建使用SelectConnection适配器鼠消费者不使用类？

我是新来的Python和鼠兔和我遇到了从使用BlockingConnection适配器，它保持了几个小时后抛出异常队列消耗的问题。我为此尝试使用SelectConnection（异步）适配器，但我只能找到在类中使用此适配器类型的示例，并且使用基于类的代码稍微超出了我目前的理解范围。我确实找到了一个例子，展示了如何使用SelectConnection创建一个生产者，但是我找不到一个消费者的例子，