能否获取SQS/SNS消息属性指标？按属性统计入队消息数量

针对你需要统计SQS队列中属性为A、B的入队消息数量的需求，以下是几个轻量且不改动现有架构的实现方式：

方式1：Lambda触发器+CloudWatch自定义指标 #

• 给目标SQS队列Q配置Lambda触发器，设置合理的批量处理参数（比如一次拉取10条消息），确保每条消息被统计一次
• Lambda核心逻辑：解析每条消息的目标属性值，根据值调用CloudWatch的PutMetricData接口，分别上报AttributeA_Count和AttributeB_Count两个自定义指标
• 后续直接在CloudWatch控制台查看指标趋势、生成报表，还能按需配置告警。整个流程不干涉原有SNS过滤规则和队列消费逻辑，仅新增统计用的触发链路。

方式2：在现有消费逻辑中嵌入统计分支 #

• 如果已有消费队列Q的业务服务，可在消费代码中添加几行统计逻辑：每次处理消息时，判断属性值为A或B后，将计数上报到CloudWatch或Redis等存储
• 示例Python代码片段：

import boto3

cloudwatch_client = boto3.client('cloudwatch')

def handle_sqs_message(message):
    # 原有业务处理逻辑
    # ...
    
    # 统计逻辑
    attr_value = message.get('MessageAttributes', {}).get('your_attribute_key', {}).get('StringValue')
    if attr_value in ('A', 'B'):
        cloudwatch_client.put_metric_data(
            Namespace='SQSMsgStats',
            MetricData=[
                {
                    'MetricName': f'Attr_{attr_value}_InQueue',
                    'Value': 1,
                    'Unit': 'Count'
                }
            ]
        )

• 这种方式无额外组件开销，仅对现有消费代码做极小改动，完全不影响原有架构。

方式3：新增无过滤辅助队列做统计（可选） #

• 给SNS主题S新增一个无过滤规则的辅助SQS队列，然后给该辅助队列配置Lambda做统计：解析消息属性，仅统计A、B的数量
• 此方案中，原队列Q的过滤和消费逻辑完全不受影响，辅助队列仅用于获取全量消息并统计目标属性，适合担心统计逻辑干扰主业务的场景。

内容的提问来源于stack exchange，提问作者Arthur Ferraz