python - 应该如何使用 Amazon SQS？导入/处理场景

Question

我想协调告诉服务器 B 从服务器 A 启动一个进程，然后当它完成时，在服务器 A 上运行一个导入脚本。我很难弄清楚我应该如何正确使用 SQS在这种情况下。

服务器 A:主专用服务器服务器B:云进程服务器

• 服务器A通过SNS向SQS发送消息说“开始进程”
• 服务器 B 不断轮询 SQS 以获取“启动进程”消息
• 服务器 B 在 SQS 上发现“启动进程”消息
• 服务器B运行“process.sh”文件
• 服务器B完成运行“process.sh”文件
• 服务器 B 从 SQS 中删除“启动进程”
• 服务器 B 通过 SNS 向 SQS 发送消息说“开始导入”
• 服务器 A 不断轮询 SQS 以获取“开始导入”消息
• 服务器 A 在 SQS 上发现“开始导入”消息
• 服务器A运行import.sh
• 服务器A完成运行“import.sh”
• 服务器 A 从 SQS 中删除“开始导入”

这是应该如何使用 SQS 还是我完全忽略了这一点？

Answer 1

对于 Amazon 提供 SQS 作为服务，我感到非常抱歉。它不是一个“简单队列”，并且可能不是您情况下的最佳选择。具体来说:

• 它在低容量消息传递方面表现糟糕(有些消息需要 90 秒才能到达)
• 不保留消息顺序
• 它喜欢不止一次传递信息
• 他们向您收取投票费用

好消息是它的扩展性很好。但是你猜怎么着，你没有规模问题，所以处理 SQS 的古怪行为只会让你无缘无故地痛苦。我强烈建议您查看 RabbitMQ，它的行为与您希望简单队列的行为完全一样。