问题标签 [cloudamqp]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
django - RabbitMQ 保持连接运行很长时间
我正在使用托管的 RabbitMQ 提供程序，即CloudAMQP，并在 heroku 上运行 django 应用程序服务器。在本地环境中，一切似乎都运行良好，但在 CloudAMQP 对与代理的同时连接数有限制的 Heroku 上，连接似乎永远持续存在，最终导致应用程序用尽可用的打开连接。即使订阅者（即 heroku 工作者）执行了与早期连接相关的任务，也会发生这种情况。
如果你已经能够成功地将 CloudAMQP 与 Heroku 和 django celery 一起使用，你能发布对你有用的东西吗？
django - 用芹菜花监测
由于 Celery 文档建议使用花进行监控，我试图让它与托管的 RabbitMQ 提供程序 (CloudAMQP) 一起使用
我可以在 CloudAMQP 管理控制台中看到如下所示的 500 Internal Server 错误，这似乎表明密码错误，而我没有。
那么如何使用 cloudamqp 监控 celery 呢？
有没有更好的解决方案（监控/任务队列）呢？
logging - cloudamqp/Heroku/Play2：在 Web 进程中创建连接会导致日志记录在当前线程中停止
在我的 play 2/heroku 应用程序的网络进程中，我有以下代码：
它产生输出：
换句话说，在调用 newConnection() 之后，我再也看不到该线程产生的任何输出。自然地，我以为是抛出了异常之类的，但事实上，我已经确认线程继续运行，它只是停止记录。（例如，我可以接收消息并且可以调用 System.exit() ）。
到底是怎么回事？我该如何解决？
更新：我忘了提，这是一个 scala 项目，带有一些 java 代码（amqp 的东西是用 java 编写的），记录器是这样创建的：
rabbitmq - EC2 上的 Amazon SQS 或 CloudAmqp 或 RabbitMq 设置
我们必须为我们的 ROR 应用程序实现一个排队系统。我们评估了以下选项：
Amazon SQS：高可用性，但性能相对较慢。需要不断轮询。
CloudAmqp：看起来很有希望，但对支持持怀疑态度。
EC2 上的 RabbitMq 设置：需要用户带宽来管理设置，如果设置中出现问题，可能会导致停机。
目前不会有任何专门的团队/人员来全职管理设置，因此在 Ec2 上实施我们自己的 RabbitMq 设置可能会导致停机，以防出现问题。
我想知道考虑到哪种情况是我们最好的选择？
rabbitmq - 与 CloudAMQP 一起使用时，MassTransit 引发异常“指定的端点均不可访问”
MT服务总线的初始化代码如下：
应用设置设置为：
在 CloudAMQP 的管理站点中创建名为my_queue的队列。
我使用 nuget 的 MT v2.8.0。我试图从我的本地 PC 和 AppHarbor 站点运行它，并且都抛出异常。
当我更改应用程序设置值以将其指向 RabbitMQ 的本地安装（rabbitmq://localhost/my_queue）时，一切正常。
难道我做错了什么？任何建议将不胜感激。
提前致谢。
python - Heroku Flask 应用程序中的 Celery/CloudAMQP 错误
我在 Heroku（免费层）上运行 Flask 应用程序，在使用 apply_async 调度任务时遇到了一些麻烦。如果我安排了两个以上的任务，我会得到一个很长的堆栈跟踪，但有以下例外：
AccessRefused(403, u"ACCESS_REFUSED - 用户 'rthtwchf' 拒绝访问虚拟主机 'rthtwchf' 中的交换 'celeryresults'", (40, 10), 'Exchange.declare')
奇怪的是前两个任务（在重新启动我的所有进程之前）似乎总是毫无问题地完成。
一点点搜索引擎侦查让我找到了https://stackoverflow.com/questions/21071906/celery-cannot-connect-remote-worker-with-new-username这使它看起来像一个权限问题，但我会假设 Heroku CloudAMPQ 服务已经解决了这个问题。
任何建议表示赞赏！
java - AMQP 1.0 主题非持久消费者
一段时间以来，我正在尝试创建不需要订阅的主题消费者。所以我想实现与 JMS 非持久主题订阅者类似的行为。
我正在使用 MS Azure AMQP 1.0 服务总线和 apache qpid amqp 1.0 客户端（JMS 实现）。
谢谢
django - Heroku 上的 Celery 和 Cloudamqp 引发错误：[Errno 111] 连接被拒绝
我有 Django 应用程序，它使用 Celery 执行异步任务。此外，我在本地使用 RabbitMQ，但在 Heroku 上我正在尝试设置 CloudAMQP 插件。应用程序启动时没有任何错误，但是发送到 Celery 的任何任务都失败并出现错误：[Errno 111] Connection denied以下是 heroku 日志开始时的样子：
我有一个简单的任务，调用它时失败：
这是heroku日志：
settings.py 的一部分：
先感谢您。
python - Celery Cloudamqp 为每个任务创建新连接
我目前正在使用 nitrous.io 运行带有 Celery 的 Django，然后使用 Cloudamqp 作为我的免费计划代理（最多 3 个连接）。我能够很好地连接并很好地启动定期任务。
当我跑
在 Cloudamqp 上立即创建了 2 个连接，我能够在第 3 个连接上手动创建多个任务，一切都很好。但是，当我运行 celery beat 时
使用所有 3 个连接，如果 celery beat 创建 1 个或多个新任务，则将创建另一个第 4 个连接，从而超出允许的最大连接数。
我已经尝试过，目前已经设置
但这似乎并没有限制我也尝试过的连接
没有运气。
为什么立即建立了 2 个什么都不做的连接？是否以某种方式将初始 celery 连接限制为 0 或 1，或者让任务在 celery beat 连接上共享/运行？
python - Heroku 上未使用 Celery RabbitMQ CloudAMQP 任务队列
此示例适用于开发环境。在 Heroku 上，任务会排队但不会被消耗。有什么想法我可能做错了吗？
RabbitMQ 仪表板显示：
Name Parameters Policy State Ready Unacked Total
1f49ea51a56049f7a68082c6297ea080 Exp D AD HA idle 1 0 1 253eb525c95944d2b742f1f112cdc0e5 Exp D AD HA idle 1 0 1