SQS 搬家公司
将消息从一个 SQS 队列移动到另一个队列的工具,使用多线程来加快进程。
流程快速说明
该工具将触发 X 个线程,其中每个线程将不断从源 SQS 队列中取出消息并将其放入目标 SQS 队列中。 所有队列操作都在“Batch”(“EnqueueBatch”、“DequeueBatch”和“DeleteBatch”)中执行,确保不仅速度会提高,而且成本也会降低(因为 AWS 对每个队列操作收费)。
一旦来自源 SQS 队列的所有消息都被消耗掉,所有线程都会停止并结束进程。 此外,为了避免达到“传输中的消息”(120.000)的限制,每个线程每 1000 条删除它出列的消息。
请记住,根据主机的网络速度,您必须调整队列的“默认可见性超时”,以确保消息在被删除之前不会返回到它的源队列。过程。 通常情况下,1000 条消息可以在不到 1 分钟的时间内出队、重新入队和删除,但这仍