问题标签 [amazon-sqs]

我对 Amazon SQS 和 Zend(1.11.2) 有一个相当令人费解的问题。我正在向我设置的队列发送一条消息，该消息如下所示：

消息进入远端的应用程序，被视为：

接收应用程序是使用 com.xerox.amazonws.sqs2 库以 Java 编写的，现在已投入生产。

在 Drupal 下使用 Tarzan 的旧 php 模块中有类似的发送代码，效果很好。我到处搜索并阅读了 Zend、Amazon 和 Java 库的文档，但我被困住了。

字符串的编码是可以理解的，但我不认识正在使用的方法。进一步的测试表明，单引号、尖括号等也被转义为十六进制。

有任何想法吗？

肯

我在Tropo（云电话）Ruby 脚本的酷但非常受限的环境中工作。整个应用程序是一个 JRuby 文件。没有宝石，没有要求。

我需要将简单消息发送到单个 SQS 队列。我不需要做任何其他 SQS 操作。在我开始从现有 gem 中提取代码来执行此操作之前，我想看看是否有人拥有用于发送 SQS 消息的独立代码或执行 SQS 所需的 HTTP 请求签名的代码。

我正在尝试用我自己的等效 SQS 替换 Amazon 的 SQS，它基本上使用 mysql 来持久存储消息。多个线程将尝试同时访问 mysql。我在 2GB RAM 系统中将 MAX_CONNECTIONS 参数设置为 5000。mysql会允许并行打开5000个连接吗？否则mysql可以支持多少个连接？

或者有没有其他更好的方式来持久存储消息？请帮忙。提前致谢。

我在 SQS 中创建了一个队列，添加了两条消息（序列化的 PHP 数组：array('filename' => 0, ...)和array('filename' => 1, ...)）。我正在使用来自他们的 git repo 的最新版本的 amazon SDK for PHP。

问题是当我使用带有这些选项的 receive_message 函数时：

我只收到第一条消息，重复了 10 次：

我 100% 认为队列中只有 2 条消息（我删除它并重新创建以确保），但我只得到第一个，填充了很多次。这会不时发生变化，有时我会在列表中混合第二个。如果我保留VisibilityTimeout默认值 3（或其他非零值），第一个会消失一段时间（如预期的那样），然后我会得到第二个重复多次。

get_queue_size返回 2，这是真的。

我还尝试了 Amazon Scratchpad，只是进行了 API 调用，结果相同。那么，是 SQS 坏了还是我做错了什么？

我目前正在开发一个使用 Amazon SQS 的用 Python 编写的分布式处理应用程序。

在 Python 中正确创建和托管队列使用者的最 Pythonic 方式是什么：

• 可靠：如果出现问题并且消费者终止，应该执行一些反应性代码并重新启动处理
• 重用代码：必须有一些包可以帮助解决这个问题，而且不必重新发明轮子会很棒:)

提前致谢！

有什么方法可以模拟 mysql 上的 Amazon SQS 消息选择机制（独占选择）？我需要这个来为多个 ec2 实例使用一个 mysql 表，这些实例将处理和删除其中的行。

select ... for update不是我想要的，因为它在选择时锁定了一个线程，而不是返回未锁定的实例。

我正在 My Rails 应用程序中实现 Amazon 的 SQS 服务。
我正在尝试制作一个轮询器，它将持续监控传入队列。
我想要做的是当我启动我的 Rails 服务器时，应该启动轮询器并开始监视传入队列。

在我的 Rails 应用程序中实现此代码的最佳方法是什么？

你的建议会适合我。

我正在尝试使用 SNS 和 SQS 对分布式应用程序进行原型设计。我有这个主题：

arn:aws:sns:us-east-1:574008783416:us-east-1-live-auction

这个队列：

arn:aws:sqs:us-east-1:574008783416:queue4

我使用 JS Scratchpad 创建了队列。我使用控制台添加了订阅。我使用暂存器将权限添加到队列。队列策略现在是：

我有关于同一主题的电子邮件订阅，并且电子邮件可以正常到达，但消息永远不会到达队列。我已经尝试使用 Scratchpad 将 SendMessage 直接发送到队列 - 而不是通过 SNS - 它工作正常。任何想法为什么它不会发送到队列？

我将制作集成亚马逊云服务的 Rails 应用程序。

• 我已经探索了亚马逊的 SNS 服务，它提供了我不想做的公共订阅设施。我只想通知特定的订阅者。例如，如果我在一个主题中有 5 个订阅者，那么通知应该发送给特定的订阅者。
• 我还探索了亚马逊的 SQS，我必须在其中编写一个轮询器来监控消息队列。SQS 也有一个锁定机制，但问题是它是分布式的，因此有可能从另一个队列副本中获取相同的消息以进行处理。

我想知道可能的方法是什么。

我正在实施 Amazon SQS 服务以处理大量消息以将其保存在数据库中。我可以使用 right_aws gem 推送消息。我还可以通过为 gem 提供的示例提取消息。

我最终可能会拥有多个 ruby​​/rails 服务器拉取和处理消息的实例（使用 SQS 的锁定和超时功能）。我想探索使用一些启动脚本提取消息的机会，或者在启动 ruby​​/rails 服务器期间进行初始化，并让组件始终运行并处理消息，直到服务器停止。

有人可以分享一些关于如何实施的参考吗？