有没有办法让 celeryd 从不同代理的队列中读取?
我有两组运行 celery 的应用程序以及它们之间的中继: APPS_A 继电器 APPS_B 中继是一个中继,在 APPS_A 和 APPS_B 之间传递消息。目前,中继在同一 R…
Rabbitmq消息发送错误
我尝试向rabbitmq-server发送消息: send_message(Channel, Host, Password, Message) -> amqp_channel:cast(Channel, #'basic.publish'{exchange = >…
帧大小如何改变不同大小消息的吞吐量
在测试 RabbitMQ 的性能时,我发现将消息大小增加到约 250 KB 以上后,吞吐量下降得非常快。然后我将帧大小从 256KB 更改为 5MB,并且吞吐量如预期增…
减少 RabbitMQ 内存使用
我正在尝试在小型 VPS(512mb RAM)上运行 RabbitMQ 以及 Nginx 和其他一些程序。我已经能够毫无困难地调整其他所有内容的内存使用情况,但我似乎无法…
RabbitMQ 中的主从
我们如何使用RabbitMQ服务器实现Master_slave配置。 我在很多地方读过并且亲自经历过 “集群下的 RabbitMQ 节点除了 cookie 文件之外不能真正共享相同…
RabbitMQ 使用立即位和强制位
我正在使用 RabbitMQ 服务器。 对于发布消息,我将 immediate 字段设置为 true 并尝试发送 50,000 条消息。使用rabbitmqctl list_queues,我看到队列…
什么开源消息队列软件可以提供严格排序的耐用性?
我们需要的是实际上作为队列工作的 RabbitMQ 并且不这样做 。消息应该保留在队列的头部,直到客户端明确地将它们出队。 这似乎是一个非常简单的场景,…
celerybeat shutdown - initscript 命令?
我正在尝试设置rabbitmq/celery/django-celery/django,以便它是“防重启”的,即它会自行恢复。一切似乎都工作正常,除了这个: 当我重新启动时,所…
FUSE ESB 支持 RabbitMQ 吗?
我正在制作一个与 RabbiMQ 集成的 Rails 应用程序。 我想在我的应用程序中集成 Fuse ESB ,但在谷歌之后我仍然不确定 RabbitMQ 支持是否熔断 ESB。 谁…
celery .delay 挂起(最近,不是身份验证问题)
我正在运行 Celery 2.2.4/djCelery 2.2.4,使用 RabbitMQ 2.1.1 作为后端。我最近上线了两台新的 celery 服务器——我一直在两台机器上运行 2 个工作…
使用 pecl-amqp 防止在 get() 上确认消息
我正在尝试将 pecl-amqp 用于我的项目。但我在 ACK 过程中遇到了困难。我需要手动确认从队列中收到的每条消息,但在检索消息时,这些消息似乎会自动确…