从外部 ruby 脚本调用控制器的方法
我正在为我的 Rails 应用程序创建一个外部服务。它始终监听rabbitmq队列，并且它们的所有消息都应该重定向到rails控制器的某些方法。 我尝试过以下方…
使用 RabbitMQ 和 APNS 的 Ruby 通知守护进程
我想创建一个 Ruby 通知守护进程，它从 RabbitMQ 获取通知作业并将该通知发送到 APNS， 通知作业的消息将采用以下 JSON 格式： { device_token: [ tok…
如何知道一组 RabbitMQ 任务何时完成？
我正在使用 RabbitMQ 让工作进程对视频文件进行编码。我想知道所有文件何时完成 - 即所有工作进程何时完成。 我能想到的唯一方法是使用数据库。当视频…
RabbitMQ 和 em-websocket
我正在努力弄清楚如何在rabbitmq和em-websocet之间进行通信。 我想将来自 Ruby on Rails 网页的消息放入队列中，并让队列处理程序处理该消息，即使浏…
如何在 RabbitMQ/pika 中实现优先级队列
我希望用 RabbitMQ 实现优先级队列。邮件列表建议使用多个队列，每个队列代表不同的优先级。 我的问题是，如何使用 pika （或者可能是其他一些 python…
Python Celery 将结果异步保存在数据库中
我使用 Python 与 Celery 和 RabbitMQ 来制作一个网络蜘蛛来计算页面上的链接数量。 MySQL等数据库可以异步写入吗？是否可以在添加每一行后提交更改，…
RabbitMQ - 无法联系统计数据库。消息速率和队列长度将不会显示
我已经设置了一个兔子经纪人集群，在管理门户插件中，我收到以下消息 “无法联系统计数据库。消息速率和队列长度将不会显示” 我已经搜索了此错误，但…
Celery 在重试任务时抛出 IOError
当我尝试重试失败的任务时，我会间歇性地（大约 20% 的时间）从 Celery 收到 IOError 异常。 这是我的任务： @task def update_data(pk_id): try: pk …
将文本日志文件流式传输到 RabbitMQ，然后在另一端重建？
要求 我们有几台服务器 (20-50) - Solaris 10 和 Linux (SLES) - 运行不同应用程序的组合，每个应用程序都会将一堆日志事件生成到文本文件中。我们需…
Node.js + socket.io +当“re”连接时，node-amqp 和队列 binginds通过 socket.io 连接
我有一个非常接近此示例的场景： 一个主屏幕： 此屏幕（客户端）将通过 server:9090/scope 连接到 socket.io 服务器（io.connect("http://server :909…
为什么 Perl 的 RabbitMQ 使用者会收到 404 错误？
RabbitMQ 已设置，我可以使用示例脚本： use Net::RabbitMQ; my $mq = Net::RabbitMQ->new(); $mq->connect("localhost", { user => "guest", passwor…
celery 获取任务数
我正在使用 python celery+rabbitmq。我找不到一种方法来获取某个队列中的任务计数。 像这样的事情： celery.queue('myqueue').count() 是否可以从某…
