问题标签 [python-pika]

我需要使用 python 中的 pika 客户端方法在 rabbitmq 中创建具有不同权限的用户。任何文档都会有所帮助。pika 客户端中的支持方法是什么？

我正在尝试从 python 向 RabbitMQ 发送 XML 文件，但出现以下错误

错误

我的代码

上面的代码有什么问题？

我有一个 RabbitMQ 消费者。我想让该消费者进行一些消息处理，由 模拟time.sleep(10)，然后将消息发布到不同的队列。我知道消费者回调有一个理论上可以用来进行发布的通道，但这似乎是一个糟糕的实现，因为如果以basic_publish()某种方式设法强制关闭通道，那么消费者就会死亡。处理这个问题的最佳方法是什么？

我正进入（状态：ssl.SSLCertVerificationError: [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed: unable to get local issuer certificate (_ssl.c:1056)

我知道服务器有一个自签名证书。我错过了哪些步骤？

文件“C:venv\lib\site-packages\pika\adapters\blocking_connection.py”，第 1858 行，在 start_sumption 'start_sumption 不能从'范围内调用

pika.exceptions.ReentrancyError：不能从另一个 BlockingConnection 或 BlockingChannel 回调的范围调用start_sumption

使用三个线程时发生错误。仅使用一个连接创建了两个通道。但无法使用相同的连接创建更多频道。

请提出解决此问题的方法。提前致谢。

异步行为的一个特点是它不会在处理下一个请求之前等待当前请求的处理完成。

SelectConnection()在我最近对 ​​Pika + RabbitMQ 的探索中，我想通过使用 Pika适配器来验证上述内容。我已经为实验编写了发布者代码 ( pub.py )和消费者代码 ( cons.py )。

我计划在 shell 终端中分别运行pub.py和cons.py一次，发布者将在其中快速连续发送任意消息，并看到它被消费者实时接收。为了查看实际的异步行为，消费者将time.sleep(10)在收到后缀为“-10s”的消息时伪造一个长进程（使用 10 秒延迟）。

我期待消费者显示在消费者仍在处理“-10s”消息时发送的后续消息。然而，事实并非如此。

我看到的是消费者在“-10s”消息上暂停，仅在“-10s”消息的工作完成后才显示后续消息。这表明了同步行为。

我的理解或我编写的测试代码有问题吗？我想我真的可以在这里使用一些建议。

我是ansibleand的新手RabbitMQ。我刚开始Hello World。下面是我的阅读和检索消息的剧本RabbitMQ。

在我执行上述剧本之后。该消息正在保存在队列中，但是当我检索该消息时，我遇到了错误。

fatal: [localhost]: FAILED! => {"msg": "An unhandled exception occurred while running the lookup plugin 'rabbitmq'. Error was a <class 'ansible.errors.AnsibleError'>, original message: pika python package is required for rabbitmq lookup."}

pika本地主机上已经安装了 python 包。证明是它能够产生消息到队列。但是我在尝试使用它时遇到了错误。谁能帮我这个？谷歌会告诉我pika在主机上安装，但我已经这样做了。

我有一个微服务（用 Python 编写），它公开了一些端点，每个端点都可以由 http 请求（flask）执行。

我有一个特定的端点需要很长时间才能完成，所以我想一旦触发这个入口点就运行一个后台作业，以减少它的响应时间。

例如，我希望flask通过http请求启动进程，当它启动时，我想将任务推送到rabbitMQ队列中。消费者应该在同一个应用程序中还是在不同的服务中？

在使用 pika for rabbitmq 的烧瓶应用程序中观察到以下错误，

使用 pika 1.1.0 版 rabbitmq 3.8.5 版

注意：配置的心跳值是 900（由于长时间运行操作设置了更高的值，所以我必须保持 pika 和 rabbitmq 之间的连接处于活动状态）

一段时间后发生连接丢失，我必须重新启动应用程序才能再次连接rabbitmq。有人可以指出我到底出了什么问题！

我在 kubernetes 集群中使用 pika 并使用队列中的消息，这会触发在新线程中启动函数。但是 RabbitMQ 似乎崩溃了，这些是迄今为止我发现的最好的日志：

我的消费者有以下定义：

在导致这种情况发生的不同线程中处理消息和工作负载的实现和策略是否存在固有的错误？