正确计算发送到死信SQS队列的消息数

2024-01-05

我希望 grafana 报告在任何给定时间死信队列中有多少消息。由于最终在此队列中的消息的性质,将评估和解析最终在此队列中的消息。

我已将 grafana 配置为读取NumberOfMessagesSent from a dead-letter队列,但是,该值始终是0, 因为;我认为最终到达这里的消息是从另一个队列发送的(通过 SQS)。

即使我可以看到消息已发送至dead-letter队列(不是以编程方式),而是通过在 X 次接收后配置的另一个队列。

有针对这个的解决方法吗?


快速回答:

您可以在 SQS DLQ 上真正监控的唯一指标是ApproximateNumberOfMessagesVisible.

TLDR:

当新消息到达 SQS DLQ 时都不会NumberOfMessagesSent or NumberOfMessagesReceived增加了。 引文来自AWS 文档 https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-dead-letter-queues.html:

如果您手动将消息发送到死信队列,则会捕获该消息 通过 NumberOfMessagesSent 指标。但是,如果消息发送到 由于处理尝试失败而导致死信队列,它不是 由该指标捕获。因此,有可能的值 NumberOfMessagesSent 和 NumberOfMessagesReceived 不同。

NumberOfMessagesSent means:

您已向队列发送了多少消息(由于失败而到达 DLQ 的消息除外)

NumberOfMessagesReceived means:

您从队列中收到了多少条消息

ApproximateNumberOfMessagesVisible means:

队列中可见的消息总数。 (记住,当你从队列中接收消息时,你必须设置可见性超时==你收到的消息对其他人不可见的时间。还要记住,你应该在成功处理后删除消息,否则它将在可见性超时后对其他人可见。 )

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

正确计算发送到死信SQS队列的消息数 的相关文章

  • 如何修改 Amazon RDS 实例的 my.ini 参数

    在启动 MySQL 5 5 RDS 实例时 Amazon 使用默认参数组来配置 my ini 参数 但控制台不允许我修改它们 我怎样才能实现这个目标 例如默认将存储引擎设置为MyISAM或设置字符集 此处记录了这一点 http aws am
  • 我试图根据 Prometheus 黑盒导出器的成功响应来计算 Grafana 的正常运行时间

    我尝试计算probe success的数量 并将其乘以探测间隔 试图获得以秒为单位的正常运行时间 并将值类型设置为总数 问题是随着时间范围的变化 最小步骤发生变化 无法给我们正确的读数并使该选项无效 我们实际上想做的是根据仪表板设置的时间范
  • 从 Amazon S3 存储桶下载文件的脚本

    尝试编写脚本以从 Amazon S3 存储桶下载文件 cURL 网站上的示例遇到问题 下面的脚本产生 我们计算的请求签名与您的签名不匹配 假如 检查您的密钥和签名方法 感谢任何帮助 bin sh file filename php buck
  • 今天从 GitHub 操作构建 SAM 突然失败:模块“lib”没有属性“OpenSSL_add_all_algorithms”

    昨天 我的 SAM 构建正在使用以下 GitHub 操作 今天突然开始失败并出现错误 AttributeError 模块 lib 没有属性 OpenSSL add all algorithms 经我验证 SAM 模板没有任何错误 还有其他人
  • 从 API 网关自定义授权方返回的 401 缺少“Access-Control-Allow-Origin”标头

    为了防止未登录的用户通过 AWS API Gateway 调用我的 lambda 函数 我使用自定义授权者 lambda 解决方案 如果请求被授权 200 并且我从被调用的 lambda 得到响应 一切正常并且我得到Access Contr
  • Spring JMS监听器即使在异常时也会确认

    我正在使用 JMS 向 SQS 队列发送 接收消息 但是即使在使用 client acknowledge 时出现异常 我也无法重新传递消息 如何实现这一目标 我尝试了一个简单的测试 JmsListener destination test
  • 如何在AWS策略中提供多个StringNotEquals条件?

    我正在尝试编写 AWS S3 存储桶策略 拒绝所有流量 除非来自两个 VPC 的流量 我正在尝试编写的策略如下所示 两者之间有逻辑与StringNotEquals 除非这是无效的政策 Version 2012 10 17 Id Policy
  • 将消息从 AWS Lambda 发布到 AWS IoT

    我正在尝试使用 Nodejs 将消息从 AWS Lamba 发布到 AWS IoT 我已压缩该项目并上传到 AWS IoT 下面是代码片段 var awsIot require aws iot device sdk var device a
  • AWS DynamoDB 写后读一致性 - 理论上它是如何工作的?

    大多数nosql解决方案仅使用最终一致性 并且考虑到DynamoDB将数据复制到三个数据中心 如何保持写后读一致性 解决此类问题的通用方法是什么 我认为这很有趣 因为即使在 MySQL 复制中 数据也是异步复制的 我将详细告诉您 Dynam
  • 更新项目时,NUMBER_VALUE 无法转换为字符串

    我在 DynamoDB 上遇到了这个奇怪的问题 我似乎无法更新项目 这是我的命令 TableName UserTable Key UID S h4XJj3YRxZiF7TDcGkxAhc UpdateExpression SET numRa
  • WCF服务健康状况监控

    我刚刚实现了 WCF 服务 目前正在研究服务监控选项 我们的服务器团队目前仅托管 java 服务 希望我们的实例始终运行 因此它可以在该实例的生命周期内收集数据 他们表示将使用我们的 webmon 操作之一来获取统计信息 但我们正在使用每次
  • 如何在AWS中从快照创建Windows实例

    我的公司想要在 Amazon Web Service 中拍摄窗口的每日快照 我们可以毫无问题地拍摄快照 但是当我尝试从快照创建实例时 它总是创建一个 Linux ami 所以当服务器启动时 它总是无法通过健康检查 是否可以从快照创建 Win
  • Nginx url 限制 502 网关

    我有一个问题 但我接受绕过此功能的其他建议 基本上 我在 get 请求中向我的服务器发送大约 3000 个字符的大行文本 然后服务器将其作为 url 中的参数发送到谷歌翻译 问题 当 url gt 1900 个字符时 Nginx 会抛出 5
  • 检查SQS队列是否为空的有效方法

    我有一个SQS Queue多个主机从中读取消息 我想在处理队列中的所有消息后运行一些作业 业务逻辑 如何检查队列是否为空 是的 我可以检查ApproximateNumberOfMessages and ApproximateNumberOf
  • AWS Route 53 如何实现基于延迟的路由?

    AWS Route 53 可以提供基于延迟的路由策略 请参阅AWS Route 53 的延迟路由策略 http docs aws amazon com Route53 latest DeveloperGuide routing policy
  • 通过 Amazon SQS 将压缩文本从 PHP 发送到 NodeJS

    我似乎一直坚持通过 Amazon SQS 将压缩消息从 PHP 发送到 NodeJS 在 PHP 方面我有 SQS gt sendMessage Array QueueUrl gt queueUrl MessageBody gt artic
  • AWS Lambda 和 S3 - 上传的 pdf 文件为空/损坏

    我有一个 Spring 应用程序 在 AWS Lambda 上运行 它获取文件并将其上传到 AWS S3 Spring控制器发送一个MultipartFile到我的方法 使用 Amazon API Gateway 将其上传到 AWS S3
  • Amazon S3 - 一个对象的多个键

    我有一个 S3 存储桶 其中包含超过 1 亿个对象 每个对象像往常一样都有一个唯一的密钥 我想知道是否有办法为其中一些对象分配另一个键 像这样的东西 键1 gt 对象1 键2 gt 对象2 Key3 gt Object2 我想添加这个 我在
  • 如何在 Lambda 中将对象上传到 S3?

    似乎无法将对象上传到 Lambda 中的 S3 本地一切正常 日志中没有错误可以显示出了什么问题 代码如下 console log Loading function var AWS require aws sdk var s3 new AW
  • 使用 Boto3 以字符串形式打开 S3 对象

    我知道使用 Boto 2 可以使用以下命令将 S3 对象作为字符串打开 get contents as string http boto readthedocs org en latest ref file html highlight c

随机推荐

  • SharedPreferences.getStringSet() 未找到?

    我对 SharedPreference 有一些不明白的地方 In 这个文件 http developer android com reference android content SharedPreferences html它说 API
  • 使用带有 lxml 前缀的 fromstring()

    我有一个变量 ele 我试图将一个子节点附加到 ele 上 该节点的标签中包含名称空间前缀 称为 style ele 似乎知道这个前缀 如以下行 print ele nsmap style outputs urn oasis names t
  • 在哪里可以找到 SimpleITK 文档和参考信息?

    我有兴趣尝试使用 SimpleITK 来解决我的成像问题 您能告诉我文档和培训材料在哪里吗 SimpleITK 已记录here http www itk org SimpleITKDoxygen html annotated html 并且
  • JavaScript 正则表达式 URL 仅提取域

    目前我可以使用以下正则表达式从任何 URL 中提取 域 https n www n im 不过 我也得到了我想避免的子域名 例如 如果我有网站 www google com yahoo com 某事 freds meatmarket co
  • 为什么“sail up”命令没有构建我的 laravel docker 容器?

    我正在尝试 Laravel Sail 因为我已经成功使用 Laradock 几年了 并希望简化我的开发环境设置 我使用的是 Windows 10 64 使用 WSL 2 安装了 Docker Desktop 3 0 并且我的 Laravel
  • 如何在刷新后让用户保持登录到 Firebase 应用程序?

    我有一个内置于 firebase 和 Angular 的应用程序 并且希望能够在刷新页面后保持用户登录 现在我有一个登录屏幕 其中有两个绑定到控制器的基本输入字段 this email this pass this emessage thi
  • Spring Security有Ip地址问题

    我在控制器中有一个使用以下配置的方法 RequestMapping value encore userName token method RequestMethod GET ResponseBody PreAuthorize hasIpAd
  • 使用新的 Google Jetpack 组件的最低 Android API 级别是多少

    我已经开始学习 RxJava 我知道有一些新的 Google 组件 如 LiveData 数据绑定等 我想知道使用它们的最低 Android API 级别是多少 我可以在 21 或 23 等较旧的 API 中利用它们吗 直接从文档中http
  • 无法使用 EPPlus 删除工作表

    我正在使用这段代码 ExcelPackage pck new ExcelPackage newFile var wk pck Workbook Worksheets SingleOrDefault x gt x Name Content p
  • jquery validate 添加方法来验证日期时间

    我正在使用我找到的日期时间选择器插件here http trentrichardson com examples timepicker 效果很好 现在唯一的问题是它破坏了包含的标准日期验证jquery 验证插件 http docs jque
  • 在调试器中查看 DLL 中的 pimpl

    我使用 pimpl 习惯用法来隐藏接口的实现细节 以便我可以采取某种 ABI 保护措施 我不太熟悉 MS 的来龙去脉 我的大部分开发生涯都使用 Linux 我无法从调试器检查窗口查看 pimpl 的内部 我的类型仅扩展至 impl 的原始指
  • Google App Engine ( Java ):URL 提取响应太大问题

    我正在尝试在谷歌应用程序上构建某种网络服务 现在的问题是 我需要从网站获取数据 HTML 抓取 该请求如下所示 URL url new URL p url con HttpURLConnection url openConnection I
  • 计算循环空间复杂度的基础是什么? [关闭]

    Closed 这个问题不符合堆栈溢出指南 help closed questions 目前不接受答案 想象一下 您循环 n 次 并且每次迭代都会创建一个空间 n 的字符串 其范围仅在该迭代内 因此在下一次迭代中不再可访问 我会说我使用 O
  • 在插入大量数据时关闭node.js中的mongodb连接

    我正在尝试编写一个程序来解析 iis 日志数据并将其插入到 mongodb 中 文件不是那么大 大约 600 行 试图说服我的管理 Nodejs 和 mongodb 比 net 和 sql server 更好 在nodejs中看一下下面的代
  • 在 React Bootstrap 中设置 Form.Check(复选框)控件的样式

    我是反应和引导程序的初学者 我想知道 如何设计 Form Check 复选框 的样式 以便可以用更好的样式覆盖默认的外观和感觉 比如开关或任何其他外观和感觉 这就是我尝试过的 我使用了 css 样式 但它没有按预期工作 MyForm js
  • iOS 5 JSON 解析导致 Cocoa 错误 3840

    我很难在 iOS 5 上解析下面的 JSON 字符串 States Name Arizona Cities Name Phoenix Name California Cities Name Orange County Name Rivers
  • 如何访问Android应用程序的classes.dex?

    当活动启动时 系统会加载classes dex文件并开始执行指令 我需要对当前活动正在执行的同一应用程序的classes dex 进行只读访问 在网上搜索了几个小时后 我只能推断Android安全系统不允许访问应用程序沙箱 但是 我需要对c
  • WebMethod 自动将类对象返回为 JSON

    谁能解释一下 ASP NET 如何处理从类对象到 WebMethods 中的 JSON 对象的转换 例如 您有以下 WebMethod 它返回一个Person object WebMethod public static Person Ge
  • scala:跟踪隐式选择和其他代码魔法

    当试图弄清楚库如何工作时 隐式转换会令人困惑 例如 查看像 val foo Foo 1 这样的表达式 什么将 1 转换为 Foo 是否可以指示 scala 库 或 REPL 打印出在计算表达式时正在执行的代码路径 您可以将 Xprint t
  • 正确计算发送到死信SQS队列的消息数

    我希望 grafana 报告在任何给定时间死信队列中有多少消息 由于最终在此队列中的消息的性质 将评估和解析最终在此队列中的消息 我已将 grafana 配置为读取NumberOfMessagesSent from a dead lette