问题标签 [amazon-sqs]

使用 SDK，我可以创建一个队列并获取队列列表 - 但不知何故，我无法将消息发送到任何队列。使用了以下内容：

但是，我收到了错误：

$queues 如下：（xxxxx 是一个数字）

有任何想法吗？

我正在使用 Celery 2.4.6 和 django-celery 2.4.2。

当我根据这个问题的解决方案配置 Celery 以使用 Amazon SQS 时：Celery with Amazon SQS

我在 Django 管理员的 celerycam 表中看不到任何内容。如果我切换回 RabbitMQ，任务会再次出现。

我在 SQS 中有很多（现在 40 多个）队列，名称如下：“celeryev-92e068c4-9390-4c97-bc1d-13fd6e309e19”，看起来它们可能是相关的（一些较旧的甚至有一个事件在其中)，但是数据库中没有显示任何内容，并且我在 celerycam 日志中没有看到任何错误。

任何关于问题可能是什么或如何进一步调试的建议将不胜感激。

给定一个在 AWS Elastic Beanstalk 上运行的简单 Web 应用程序（即负载均衡器后面的 1..n 个相同实例），我如何才能有一个仅在一个实例上运行的计划后台操作？

我在 Web 应用程序中确实有一个类似 cron 的调度机制，并且可以使用例如 AWS 简单队列服务对任务进行排队（并确保每个任务只执行一次）。但是如何确保只有一个实例创建任务（以避免重复）？

显然，我可以有一个专门的实例来负责创建任务，但我正在寻找一种更动态的机制，让一个普通实例自动承担该角色。有任何想法吗？

我是亚马逊 MapReduce 的新手。谁能告诉我如何轻松地从 Hive 作业向 Amazon 的 SQS（简单队列服务）提交消息？我想将指向我工作的 S3 结果的指针放入 SQS 以便更简单的自动检索。

我目前正在做一个与 AWS 相关的项目，在某些时候需要将不同类型的消息传递给 SQS 队列。我不想将消息作为字符串传递，而是宁愿放置由 jaxb 转换为 xml 格式的对象，例如 writer。有什么建议么？

谢谢

我目前正在做一个与亚马逊云计算相关的项目。我正在用 Java 编程。

我需要传递一条消息（String包含 xml 数据），并且需要在将其放入 sqs 队列之前对其进行序列化。

有什么办法可以将它序列化并保持为字符串格式？我无法以任何其他格式传递消息，例如InputStream，等。

马上：

• 应用 #1 向 SQS 插入消息
• .Net worker 角色轮询队列，如果发现消息将其发送到 App #2 进行处理，则等待 App #2 完成并重新开始轮询队列
• App #2 处理消息，这是一项漫长而繁重的任务

由于 App #2 处理消息可能需要很长时间，而且我无法预测 App #1 同时发送了多少消息，队列系统保证 App #2 不会耗尽资源，并且系统可以轻松扩展. 但是有一个我想解决的问题：我不希望有一台机器来运行辅助角色（现在在 Azure 上）只是为了轮询队列（所有东西都托管在其他地方，辅助角色不是一个选项）。此外，由于轮询之间的暂停，轮询永远不会像推送那样响应迅速。

从 poll 切换到 push 听起来是正确的路径，但我需要保证即使在一秒钟内从 App #1 发送了 1k 条消息，App #2 也会一个接一个地处理它们，并且每秒不会被击中 1k 次。

我正在计划一个设计，其中 App #1 发布到 SNS 主题，其订阅者是 SQS 和 App #2。App #2 检查 SQS 队列，如果为空则退出，如果不是，则一一处理消息然后退出。但是我如何编码 App #2（现在是一个 .Net Web/Web 服务），以便如果它已经在处理消息并从 SNS 接收通知，它什么也不做并退出（如果不运行多个处理）。

有什么建议如何设计吗？我阅读了这篇博文，但我不知道如何避免处理应用程序同时处理多条消息。

我目前有一个将项目添加到 sql 表中的队列 - 它很容易出错，因为处理一个项目可能需要 5 到 35 秒。我正在使用 cron 作业来做这件事，但这似乎非常浪费，因为 cron 作业页面可能在每个项目都被处理之前超时，或者一个项目可能已经处理了一半并且没有从队列中删除

我正在寻找使用这种方法的替代方法 - 并且遇到了 amazon sqs - 当新项目添加到队列中时是否可以让 sqs 发出 http 请求？

与在处理长请求时挂起它相比，发出单个 http 请求对 apache 的负担要少得多。

我正在寻找一个示例 .Net 应用程序，该应用程序不断检查 Amazon SQS 是否有新消息，当找到新消息时，执行一项操作并将其从队列中删除。

我的目标是在 EC2 上运行一个应用程序来监视我的 SQS 队列中的新消息。当找到一个时，将调用几个基于 Web 的 API 之一，并且该消息将从队列中删除。

有人可以指点我一个类似的例子吗？

编辑 这种类型的应用程序最好创建为 Windows 服务吗？

我们希望为公司内部需要队列的任何应用程序提供队列即服务（类似于Amazon SQS）。

在重新发明轮子之前，我们正在寻找一些符合以下条件的产品：

• 水平缩放
• 高可用性胜过性能
• 基于高级功能的简单队列 REST API（发布、双端队列、确认、确认）

背景：我们主要使用 Java/Groovy，我们在 RabbitMQ 和 ActiveMQ 方面有经验，但我们对任何产品/语言都持开放态度。

我将不胜感激任何经验、产品或代理适配器建议。