问题标签 [ironmq]

我正在对发送 500 条消息并随后使用它们的 ironmq 进行一些负载测试。

到目前为止，我可以发送 16 条 msg 的 pr。秒并消耗（读取/删除）大约 5 个味精的公关。秒。在我的本地机器上使用 ironAWSEUWest。我使用 v. 0.0.18 java 客户端 sdk。

输出 ：

这是预期的吞吐量吗？

当我将负载增加到 1000 条消息时，我在读取一批 100 条消息时收到零星的错误，然后一次删除它们。

似乎删除方法在负载下可能会失败。

该测试是 Ironmq 的 Camel 组件的一部分，可在此处找到https://github.com/pax95/camel-ironmq

负载测试在这里https://github.com/pax95/camel-ironmq/blob/master/src/test/java/org/apache/camel/component/ironmq/integrationtest/LoadTest.java

运行 Django 1.4.10、Celery 3.1.7、Python 2.7、Kombu 3.0.12，并使用 django supervisor 将 celery worker 和 celery beat 作为守护进程运行。使用 IronMQ 作为代理。

一切正常处理几天的周期性任务，然后突然之间，工人将致命地死去：

查看时间戳，似乎总是在任务全部完成后崩溃。当我有我的 supervisor.conf 文件来自动重启时，它会进入一个循环，试图重启 worker 并立即失败。但是，如果我用主管关闭所有进程并重新启动，它会再次运行几天。

主管.conf：

甚至不知道从哪里开始调试这个 - 把它扔在那里，以防其他人遇到同样的问题并且可以对此有所了解。

更新：我切换回可靠的 Erlang/Rabbit，问题完全消失了。所以它是 IronMQ。我真的无法从他们那里得到任何帮助，所以他们失去了一个客户！

我正在使用 IronIO 提供的 IronMQ 服务的警报功能来启动工作人员。

我进行了设置，以便将消息推送到推送队列中。推送队列发送一个启动工作人员的警报。工作人员在推送队列中提取消息，并保留它。有时，无论出于何种原因，作业失败，消息的保留到期，消息再次可用。但是，据我所知，当消息中的预订过期时，不会发送任何警报。因此，该消息位于队列中，直到将另一条消息添加到队列中，触发警报并启动工作程序。但是新消息没有被处理。

IronMQ 中是否为保留的消息创建了警报？有没有我错过的描述可能发生的事情的文档？

我正在努力让工作人员发送多条消息，但是在处理同一工作人员中的多条消息时遇到了与 Iron io 无关的问题。

还有一种方法可以拉出队列的顶部。为了避免删除可能导致错误的消息？我应该只修改我的工作人员以删除导致错误的消息吗？

我正在寻找可以让我推送数据的库或服务，并且每次都会有其他几个列。现在，我目前正在使用 IronMQ 将 json 推送到队列中，然后解析 json 并获取属性。但是，我想知道是否有一个队列库或服务可以让我将所有属性推送到单独的列中，以便稍后我可以在队列中执行 SQL 查询。

我曾考虑过使用 Python 和 Sqlite3 来执行此操作（与 Amazon SQS 或 IronMQ 相比有什么不同），这将使这变得非常容易。

I'm trying to do a simple aplication in java, that send and recive messages from IronMQ, but when I try to push a message or get a message or clear the queue, java show me this error:

This is the configuration code:

Thanks for the help! :)

我正在将 beanstalkd 服务器迁移到 ironmq

它在 http://dev.iron.io/mq/reference/beanstalk/#authentication中说

验证

因为 IronMQ 需要身份验证，所以您发送的第一个命令必须将消息放入队列中，其内容为：

oauth {TOKEN} {PROJECT_ID}

如果身份验证失败或在身份验证之前发送了任何其他命令，则将返回 DRAINING 响应。

但是如何做到这一点呢？我已经尝试使用

和

但仍然失败（排队真实消息时得到 DRAINING 响应）请帮助

仅供参考，我在 RoR 上使用 Backburner 作为 Beanstalkd 客户端

IronMQ 推送队列的文档描述了端点应该如何处理/响应推送消息。但是，我的印象是这是针对普通webhook 的，我找不到任何文档或示例来说明当推送队列的端点是 IronWorker 时该怎么做。

IronWorker 框架在为推送到队列的消息启动新 IronWorker 任务时是否负责响应 IronMQ 服务，或者我的 IronWorker 代码是否需要处理响应？如果我需要在我的代码中处理它，是否有任何自动提供给我的变量代表 webhook 请求和/或响应？

正如我上面提到的，我查看了示例代码，但我发现的只是 IronWorker webhook 示例，它们从 GitHub 之类的东西而不是 IronMQ 接收 POST。如果有我正在尝试做的事情的例子，请指出我！

我有一个文件上传表单，其中图像首先上传到我的服务器，然后上传到 Imgur。上传到 Imgur 应该排队。因此，一旦上传了新文件，我就会推送：

我用它来订阅队列：

现在，我可以看到这是有效的，因为我可以在 IronMQ 中看到订阅

但是，当我进行上传时，图像在我的服务器中上传正常并且没有显示错误。但是没有消息发送到 IronMQ：

因此，那些 Imgur 上传也没有发生。我已经测试了所有内容并进行了广泛搜索，但我还没有找到任何解决方案。知道发生了什么吗？

我正在尝试将新用户添加到组并发送激活电子邮件。当我在没有队列的情况下实现它时，它在早些时候工作。

这是我在 app/routes.php 中的（相关）代码：

在 UsersController.php 中，我有：

我已按照IronMq + Laravel4 的说明进行操作：如何使其工作。当我注册一个新用户时，我收到了成功，我可以在 IronMQ 仪表板中看到消息计数增加。但是 laravel.log 没有显示“元帅！”，当我做 curl --data "param1=whatever" http://livesite.com/queue/demo

另外，我有

在我的路由文件中，因此队列/演示路由在过滤器之前也有一个 csrf。

我一直在使用 Laravel 框架，最近刚刚开始使用 Laravel 内置的 IronMQ 支持来实现队列。

从 Laravel文档中可以很容易地了解如何将消息推送到队列，然后在Iron.io上设置订阅者并将队列推送到这些订阅者。但是我想将 IronMQ 用作拉取队列。我没有看到任何关于如何使用 Laravel 的内置方法从指定队列中提取消息的迹象。

在 IronMQ 站点上，他们列出了所有与拉取队列实施相关的端点。

前任：/projects/{Project ID}/queues/{Queue Name}/messages

在 Laravel 的 IronMQ 包中，我看到了似乎适用于这些端点的方法：

但是，我没有看到 Laravel 对此有任何支持。我希望能够按照以下方式做一些事情：

它将从指定队列返回下一条消息，等等。

有没有办法通过 Laravel 的内置支持来做到这一点，但没有记录在案？

谢谢！

编辑：

我已经看过有关通过 Laravel 使用Daemon Workers的文档，但是我想通过 cron 作业自己处理队列。