1

我们有一个使用亚马逊 SQS 的队列,其中包含消息。

我们有多个从该队列读取的工作人员,这些工作人员是无状态的,这意味着他们无法记住每条消息有多少次重试,除非我们用重试次数更新消息。

目前,如果一个worker处理一条消息失败,消息会在我们设置的X秒后返回队列,因为我们不删除它,我们设置VisisiblityTimeout参数表示如果消息在X设置的秒后返回队列没有被工人删除。

SQS 队列或消息设置中是否有创建重试次数的选项,例如,如果消息返回队列超过或等于 3 次,它将从队列中删除?

public async pollMessage(queueName: string): Promise<QueueMessagePollResponse> {

    const parameters = {
        VisibilityTimeout: this.configService.queueVisibilityTimeoutSec,
        QueueUrl: this.buildQueueUrl(queueName),
    };

    return new Promise<QueueMessagePollResponse>((resolve, reject) => {
        this.sqs.receiveMessage(parameters, (error, data) => {
            if (error) {
                this.logger.error(`Failed polling from queue with error: ${error.message}`);
                reject(error);
            }

            if (!data.Messages) {
                return resolve(null);
            }

            resolve({
                messageDeletionId: data.Messages[0].ReceiptHandle,
                data: data.Messages[0].Body,
            });
        });
    });

}
4

1 回答 1

4

您可以使用 A DLQ(死信队列)。将 SQS 的重新驱动策略设置为 no。你想要的尝试,比如

在此处输入图像描述

更多详细信息https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-configure-dead-letter-queue.html

于 2020-02-26T12:49:32.957 回答