问题标签 [amazon-sqs]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
2 回答
2556 浏览

php - 使用 PHP 的 AWS SQS SNS 协议

以下代码允许我SNS使用(队列)发送,SQS但我似乎无法选择亚马逊管理控制台中的协议 在此处输入图像描述


* 键都是随机字符串



问题:我会在哪里选择协议?
此链接说这subscribe()protocol定义的位置,但上面的示例将其发送到SQS

0 投票
1 回答
207 浏览

django - 设置服务以在 Web 集群环境中执行任务

我正在寻找在 Web 集群环境中可靠地执行任务(仅在某个日期/时间执行一次)的方法:例如,在初始注册后 7 天后向用户发送电子邮件提醒。我知道使用 cron/django-cron/django-chronograph 等来实现这一点的方法,但到目前为止我发现的所有东西似乎都是为单服务器场景设计的。

我想避免由于在多台服务器上运行相同的作业而发送重复的提醒,到目前为止,似乎在 Web 集群中使用锁定、过期超时等来汇总您自己的基于数据库的解决方案确实是唯一的选择。是否有任何现有的解决方案可以在 Web 集群环境中运行良好?

0 投票
2 回答
4429 浏览

php - AWS 使用 SQS 上传到 S3 - PHP 语法

使用 SQS 上传到 S3 是否会使进程更容错?

如果是这样,我很难使用语法,试图结合创建一个queue然后上传到 S3。
如果我的逻辑不正确,我将如何设置SQS用于上传到的系统S3

0 投票
1 回答
427 浏览

java - 是否可以配置多个 Timer EJB

我有一个 EJB,它使用 @Schedule 注释以类似 cron 的方式执行一些企业逻辑。

我正在使用 JBoss 7.1 final。

问题是此方法正在使用来自 AWS SQS 服务的消息,在该 API 中,一次最多只能获取 10 条消息。这会导致大量消息被添加到 SQS,但消费速度不够快。所以我想问的是,是否有一种方法可以创建一个池并让 2 或 3 个 EJB 同时处理来自 SQS 的消息。

0 投票
4 回答
6338 浏览

amazon-web-services - 是否有在 AWS ec2 上使用 SQS 的命令行工具?

如何通过命令行与 ec2 上的 SQS 交互?我在 AWS 开发人员工具中找不到 SQS 工具。

0 投票
3 回答
14194 浏览

python - 使用 boto 处理 SQS 队列

我有一个使用 ec2 实例上的 boto 库的 python 脚本,它是自动缩放组的一部分。该脚本处理来自 SQS 队列的消息:

使用 while 语句有意义吗?count() 是否实时更新为:

  1. 其他实例将消息从队列中取出(或者我要加倍)
  2. 新消息被添加到队列中(或者我会错过它们吗?)

即使队列为空,如何使此脚本不断侦听队列中的新增内容?

在这个问题Processing items in SQS queue with a php script中提到'sqs ruby​​客户端库有一个方法“poll”,它不断地轮询队列,并在队列中接收到消息时将其传递给一个块'。Python中是否有等价物?

也有人建议可以使用 SNS 来通知脚本消息队列状态,但我看不出如何使用 SNS 配置响应式系统,因为指标警报不够精细。

0 投票
1 回答
1953 浏览

amazon-web-services - 跟踪 SQS 队列中的消息

我有一个请求队列和一个响应队列。我想将消息从请求队列中取出并放入响应队列。我希望能够确定从请求队列中取出的相同消息已放入响应队列。

我在 GAE 上使用 Boto。

首先,我假设消息 id 是不变的。所以我从请求队列中读取消息,将相同的消息对象添加到响应队列并查询 id - SQS 生成了一个新的。

其次,我的消息正文是一个 json 对象,所以我添加了一个自定义字段“messageId”并生成了我自己的 id 以存储在队列中。但后来我看到,一次从队列中读取 10 条消息是有限制的。另外,由于 SQS 的分布式特性,不保证消息一定会被返回。

0 投票
2 回答
646 浏览

php - RDS 上的 MySQL 触发器

我正在尝试创建一个将调用 php 脚本的 MySQL 触发器。我有一个在 RDS 中运行的 MySQL 服务器实例,并且想使用 php 脚本向我的 SQS 消息传递系统发送消息。

  1. 我在哪里保存 php 脚本?
  2. 我是否需要在我的 EC2 实例上安装适用于 SQS 的 PHP 开发工具包?
0 投票
3 回答
10905 浏览

php - AWS SQS 实用代码 PHP

我在这里有一个问题,
但我仍然没有理解如何使用 SQS,任何人都可以帮忙提供一些代码。

问题: SQS 中的一个地方是什么?
我已经阅读了亚马逊的教程,这个概念看起来很可爱,但我错过了实用的一面。
例如,这张图很棒:http
: //awsmedia.s3.amazonaws.com/catalog/images/159-for-madhu.png SQS 里面会有什么?我了解如何上传到 S3,但对于 SQS 部分仍然是灰色的

0 投票
1 回答
1101 浏览

amazon-web-services - Amazon SQS 消息队列

我有以下情况:

  • 对于需要处理的作业,将包含作业描述的消息发送到 Amazon SQS 消息队列
  • 我有不同的流程要做这些工作

需要满足以下条件:

  1. 如果一个进程未能完成一项作业(可能是因为它正在运行的服务器崩溃),则该作业必须再次可供其他进程使用。
  2. 在处理一个作业时,具有相同描述的其他作业必须等到第一个作业完成或达到其超时时间。
  3. 系统应该可以根据消息队列长度轻松扩展。

为了确保(1),我的第一个想法是使用 Amazon SQS 队列提供的消息锁定功能,但是我如何确保(2)呢?将流程分配给工作描述将是一种选择,但是(3)会更加困难。