我们有一个使用亚马逊 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,
});
});
});
}