我们有一个 Lambda 事件源，它轮询 SQS 的消息并将它们传递给 Lambda 函数。
SQS 有一个Visibility Timeout，它指示消费者 (lambda) 在多长时间内收到一条消息，如果未成功完成，它将重新出现在队列中。
Lambda 函数有没有办法在我们检测到错误后立即强制执行此操作？
例如，假设 Lambda 有 10 分钟的超时。 SQS Visibility Timeout 需要更长。
但如果 Lambda 函数提前检测到问题并抛出错误 - 这将导致消息失败，但我们必须等待 SQS Visibility Timeout 消息可供其他消费者重试。
有没有办法让 Lambda 函数告诉 SQS 消息已失败并且应该立即返回队列？
【问题讨论】：
标签： amazon-web-services aws-lambda amazon-sqs
如果您使用的是内置 AWS Lambda SQS 集成，那么只需抛出异常（从 Lambda 函数返回非成功状态）将导致该调用的 event 中的所有 SQS 消息被立即放回队列中。
当 Lambda 读取一个批次时，消息保留在队列中，但变为 隐藏队列的可见性超时长度。如果你的 函数成功处理批处理，Lambda 删除消息 从队列中。如果您的函数受到限制，则返回错误，或者 没有响应，消息再次变为可见。一个中的所有消息 失败的批量返回队列，所以你的函数代码必须能够 多次处理同一条消息而不会产生副作用。
【讨论】：
error字段，它会抛出一个标准的JSError。 if(data.error) { throw new Error('Fail lambda:' + data.error); }。返回是一个简单的对象return { data:{ ... } }。但我假设抛出错误会阻止返回运行？
调用ChangeMessageVisibility API 并将每条失败消息的可见性超时设置为 0 秒。然后抛出异常。
如果您收到一批 SQS 消息并且能够成功处理其中一些消息，则从底层 SQS 队列中显式删除这些（成功）消息，然后将每个剩余失败消息的可见性超时设置为 0 秒，然后抛出异常。
将消息的可见性超时设置为 0 terminates the visibility timeout for that message 并使该消息立即对其他消费者可见。
【讨论】：