问题标签 [carrot]

我正在使用 Ruby AMQP Carrot 库，并且正在尝试与虚拟机上的测试 RabbitMQ 服务器对话。机器上的 AMQP 端口已打开，但我无法让 Carrot 建立外部连接。我尝试了以下方法：

Carrot.queue('消息', :durable => true, :server => '192.168.162.176')

Carrot.queue('消息', :durable => true, :host => '192.168.162.176')

在 Rails 中初始化 Singleton 的最佳位置在哪里？

我在 Ruby on Rails 应用程序中使用 Carrot AMQP 库，我只想初始化一次设置，而不是对生成的每个任务进行初始化。

我目前在我的 environment.rb 中有它，它似乎可以工作，但我不完全确定这是最好的地方。

只有在 Rails 启动后才初始化 Carrot 是一个好主意，还是应该为每个创建的任务创建一个新的 Carrot 对象？

我们在 Python 项目中使用 Carrot。我编写了一个 Python 脚本作为消息队列的消费者。我在 Windows 7 中使用命令行 shell 调用了这个 Python 脚本

但是，过了一会儿，正在运行的会话被中止，错误是：

生产者会话在 Linux 服务器上仍然运行良好。只是想知道如何解决这个问题并在 Windows 上进行长时间运行的消费者会话。

如何使用 Kombu 发送文件和其他数据？我使用rabbitmq 作为经纪人。

例如 file.pdf 沿字典 {'author': 'user'}

如果可能的话，我想在一条消息中做到这一点。但是，如果您认为使用 Kombu 的标准序列化程序，您将如何绑定单独的消息？

我正在使用 Celery 处理多个数据挖掘任务。其中一项任务连接到远程服务，该服务允许每个用户最多同时连接 10 个（或者换句话说，它可以在全局范围内超过 10 个连接，但每个作业不能超过 10 个连接）。

我认为 令牌桶（速率限制）是我正在寻找的，但我似乎找不到它的任何实现。

我有一个（不完美的）集群字符串数据，其中一个集群中的项目可能如下所示：

最佳标题是“黄熟香蕉”。

目前，我正在使用简单的启发式方法——在 SQL GROUP BY 的帮助下选择最常见或最短的名称。我的数据包含大量此类簇，它们经常变化，并且每次在簇中添加或删除新水果时，都必须重新计算簇的标题。

我想改进两点：

(1)效率——例如，只将新的水果名称与聚类的标题进行比较，避免每次对所有水果标题进行分组/词组聚类。

(2)精确度——我想提取最常见的短语，而不是寻找最常见的完整名称。当前的算法会选择'Yellow成熟'，重复2次，是最常见的完整短语；然而，正如短语“黄熟香蕉”是给定集合中最常见的。

我正在考虑使用 Solr + Carrot2（没有第二个经验）。此时，我不需要对文档进行聚类——它们已经根据其他参数进行了聚类——我只需要选择中心短语作为聚类的中心/标题。

非常感谢任何输入，谢谢！

我在 Heroku 上有两种进程类型：Ruby 中的 web dyno 和 Node.js 中的 worker。我正在使用 RabbitMQ 插件（目前是测试版）将消息从 Ruby 传递到 Node。Node 正确连接和消费，而Ruby 只要是第一个连接/创建队列就正确连接和发布。

显然，当您尝试创建一个已经存在的队列时，Carrot 会抛出一些有趣的错误，这就是我发现无法传达我的消息的原因（我本可以在昨晚测试时发誓它有效）是我在我的 Ruby 之前开始了我的 Node 进程。

由于我在 Heroku 上，我将有多个 Ruby 和 Node 线程同时工作，并且它们每个都需要支持成为第一个启动队列并连接到现有队列的人，没有问题。

这让我想到了我的问题：

如何使用 Ruby 连接到现有的 RabbitMQ 队列，以便向已经连接并等待接收消息的消费者发布消息？

好的，我是 python 的新手，一直在研究这个问题，但我找不到类似的东西，所以我不确定发生了什么。

我正在创建一个涉及鼠尾草的程序，它有一个消息提示。我们在开发机器上设置了这个，所以我知道它可以工作，但我想在我自己的计算机上设置它，这样我就可以更好地了解它是如何工作的，并且更容易为自己开发。

要启动 sage，我们运行一个脚本，该脚本调用 sages 主二进制文件并将其传递给可执行的 .py 文件。(./sage/sage ./sage_server.py) 这会在 sage_server.py 文件中产生错误：

但是每当我在终端（./sage_server）中运行该文件时，导入工作正常，直到第 27 行它尝试从 sage 导入某些内容时出现错误。

有谁知道当它被其他东西调用时会导致错误的原因是什么？我对导致这种情况的原因感到非常迷茫。

我正在尝试连接到我的 rabbitmq 服务器。我在用

我收到此错误

如何检查我的服务器是否已关闭？以及如何重新启动它？

我正在使用胡萝卜 gem 在 ruby​​ 中发布消息，我的示例代码如下：

代码 ：

请有人告诉我如何使用路由键发布相同的数据？