问题标签 [cloudamqp]

我正在尝试使用云 AMQP 设置 celery 代理。

由于云 AMQP 服务只提供 Java SDK，所以我用 Python 重写了加密代码，连接工作正常。

但是，producer发送任务有一个问题：我的项目启动一段时间后，与云AMQP服务的连接将失效，因为Celery amqp pruducer/connection无法刷新连接参数。错误是 .530 Time Expired这意味着密码无效

这是我的芹菜配置：

我在发送任务时更新了 broker_url，但 amqp 连接参数没有更新。

环境：
Python 2.7 kombu 4.0.2 celery 4.1.0 rabbitmq 0.2.0

Celery 是否提供了在运行时更新 amqp 连接参数的方法？
谁能给我建议？提前致谢..

一些链接：

Celery 为每个任务创建一个新连接

https://www.cloudamqp.com/docs/celery.html

补充：
调试结果
amqp 连接密码（从未更改）
芹菜更新 conf

我一直在努力弄清楚我打算如何配置 MassTransit 和我们新的专用 cloudamqp 实例以使用 SSL（注意：一切都在没有 SSL 的情况下正常工作）。

我尝试在下面的代码中添加 UseSsl 行，这是我在一些旧文档中找到的，但这不起作用：

在 cloudamqp 中，我也将其设置为允许 ampqs，并且我的服务/API 使用 HTTPs 在 IIS 中设置和运行，没有任何问题。

我怀疑我在这里遗漏了一些基本的东西，但我找不到任何关于它的文档。

我正在为我的 Spring Boot 应用程序使用 CloudAMQP Heroku Add On。我正在本地和 Heroku 上使用“CLOUDAMQP_URL”环境变量连接到服务。

在本地我的环境变量是：amqp://guest:guest@localhost:5672

在 Heroku 上，我的环境变量由 Heroku 生成，类似于：amqp://oilpmoxc:rGoLFAKEPASSWORDhhqwwk6g@lion.rmq.cloudamqp.com/oilpmoxc

我知道 Heroku 生成的环境变量是正确的，因为我抓到它并在本地使用它。我能够很好地连接到 Heroku 提供的 CloudAWQP 实例。

有一次，我在 Heroku 上的应用程序可以很好地连接到 CloudAMQP。没有任何问题。现在，我根本无法连接。我不断收到拒绝连接错误。

以下是日志的转储。

有人知道发生了什么吗？

谢谢！

禁用八卦、交际和心跳对我的芹菜工人有什么影响？

为了减少发送到 CloudAMQP 的消息数量以保持在免费计划内，我决定遵循这些建议。因此，我使用了 options --without-gossip --without-mingle --without-heartbeat。从那时起，我在所有 celery 项目中默认使用这些选项，但我不确定是否有任何我不知道的副作用。

请注意：

• 我们现在转移到了 Redis 代理，并且对发送到代理的消息数量没有太多限制
• 我们有几个实例运行多个具有多个队列的芹菜工人

我无法在 CloudAMQP 上将 MassTransit 与 RabbitMq 连接起来。下面是我的代码

h.Password并且h.Username是正确的。当我尝试启动总线时，出现以下错误：

RabbitMQ 连接失败：代理无法访问：my_username@llama-01.rmq.cloudamqp.com:5672/

我怀疑问题出在 URI 地址中，但我找不到正确的地址。

所以我想创建一个简单的队列，每次向其中发送文本消息时，我只发送数据。

我正在使用 CloudAMQP，他们的文档为我提供了一个 Java 代码供我使用，它在单独运行时确实有效，当我将 Spring Boot 添加到组合中时，问题就出现了，这是类：

我实际上可以在无框架的 Java 应用程序上运行它时发送消息，但是如果我尝试使用 Spring Boot 调用它，我会收到此错误：

尝试将 restTemplate 添加为类的自动装配，但无济于事，它仍然给我一个错误，不知道发生了什么

我的站点使用基于 RabbitMQ 的 Python 3.5.6、Django 1.11.20、Celery 4.3.0、CloudAMQP（通过 Heroku）运行。当应用程序部署到 Heroku 时，Celery 返回以下错误：

消费者：无法连接到 amqp://dfmngfek:*@salamander.rmq.cloudamqp.com:5672/dfmngfek: [Errno 104] 对等方重置连接

我找不到这个问题来自哪里。

这是我的设置：

settings_remote.py：

__ init.py __ ：

celery_tasks.py：

gautocomplete/tasks.py：

错误信息 ：

任何帮助都会非常有用！

我有一个集成了 celery 的 heroku 的 django 项目。我已经通过 heroku 获得了 rabbitmq 插件，并在本地测试了我的任务以取得成功。我遇到的问题是将我的远程服务器连接到rabbitmq/cloudamqp。

我相信我使用的凭据是问题的罪魁祸首，但我不确定我哪里出错了。我正在使用通过 cloudamqp 仪表板提供给我的凭据。这包括：

在我的 settings.py 中，我有：

我尝试了多种其他形式，结果相似。最新的错误输出是：

我是否使用了正确的凭据？我是否需要通过命令行而不是管理仪表板创建 rabbitmq 用户？

我正在尝试从 springboot 应用程序向 RabbitMQ 发送消息。使用的依赖项（springboot & amqp）：

我可以使用具有以下访问权限（读取、写入和配置）的用户凭据将消息发布到交换：

但是当我使用没有配置权限的用户时它会失败，如下所示：

调用时收到错误rabbitTemplate.convertAndSend(exchange, null, message);：

我认为这是因为 Spring 它试图创建交换或检查交换是否存在（使用管理 API）。如果是这种情况，我们可以使用某些属性禁用它吗？

我正在尝试接收来自我的鼠兔生产者的消息。我正在关注本教程：https ://www.youtube.com/watch?v=0iB5IPoTDts 。

我可以看到，当我手动运行docker-compose exec backend bash然后运行python consumer.py时，我可以接收消息，并且它们正在通过该print()函数记录到标准输出。但是，当我将以下服务添加到 mydocker-compose.yml时，容器不会记录到标准输出：

没有错误。当我将命令更改为 时echo hello，容器会很好地将 hello 打印到标准输出。为什么我的服务没有记录到标准输出？此外，它似乎运行正常 - 当我尝试抛出异常时，我的服务错误。当它出错时，它也会开始打印消息。否则它不会打印错误消息。

有没有办法解决这个问题？

consumer.py：