如何在AWS SNS中通过Regex或子串实现消息过滤？

这个问题问得好！咱们先把核心结论说在前头：AWS SNS原生的消息过滤策略并不直接支持正则（Regex）或任意子串匹配——官方文档提到的三种字符串过滤规则（精确匹配、排除匹配、前缀匹配）就是当前原生支持的全部选项。不过针对你这种S3事件触发的场景，有几个非常实用的替代方案，我来给你详细拆解：

方案1：通过Lambda中间层实现精准过滤 #

这是最灵活、最可靠的解决方案，思路是在S3和目标SNS主题之间加一层Lambda函数，先解析并过滤消息，再把符合条件的消息转发到SNS。

具体步骤： #

1. 调整S3事件通知目标：把原本直接发送到SNS的S3事件，改成发送到Lambda函数（如果消息量较大或需要更高可靠性，也可以先发送到SQS再触发Lambda）。
2. Lambda函数核心逻辑：
   • 将S3发送的文本格式消息解析为JSON对象（你提到S3发送的整条消息是文本，所以这一步必不可少）。
   • 提取出s3.object.key字段，检查是否包含目标子串（比如filteringText）。
   • 仅将符合条件的消息通过SNS的Publish API转发到目标主题。

示例Lambda代码（Python）： #

import json
import boto3

# 初始化SNS客户端
sns_client = boto3.client('sns')
# 替换成你的目标SNS主题ARN
TARGET_TOPIC_ARN = 'arn:aws:sns:你的区域ID:你的账号ID:目标主题名称'

def lambda_handler(event, context):
    try:
        # 适配不同触发源的消息格式（S3直接触发/SQS中转）
        if 'Records' in event and len(event['Records']) > 0:
            if 'body' in event['Records'][0]:
                # SQS触发时，消息体是文本格式的JSON，需要先解析
                s3_event = json.loads(event['Records'][0]['body'])
            else:
                # S3直接触发Lambda时，event本身就是解析后的JSON结构
                s3_event = event
        
        # 提取S3对象的Key
        object_key = s3_event['Records'][0]['s3']['object']['key']
        
        # 判断Key是否包含目标子串
        if 'filteringText' in object_key:
            # 转发符合条件的消息到SNS
            sns_client.publish(
                TopicArn=TARGET_TOPIC_ARN,
                Message=json.dumps(s3_event),
                Subject="过滤后的S3对象创建事件"
            )
            return {
                'statusCode': 200,
                'body': "符合条件的消息已转发到SNS"
            }
        else:
            return {
                'statusCode': 200,
                'body': "消息不符合过滤规则，已丢弃"
            }
    
    except Exception as e:
        print(f"处理消息时出错: {str(e)}")
        return {
            'statusCode': 500,
            'body': f"处理失败: {str(e)}"
        }

方案2：S3事件过滤+SNS（仅适用于特定场景） #

如果你的目标子串刚好在S3对象Key的前缀或后缀位置，那可以直接用S3本身的事件过滤规则（前缀/后缀匹配），再把过滤后的事件直接发送到SNS。但如果子串在Key的中间位置，这个方案就不适用了，还是得用方案1。

为什么原生SNS做不到？ #

SNS的消息过滤策略基于消息属性或消息体的JSON路径匹配，但针对字符串类型的匹配，官方目前只开放了精确匹配、排除匹配、前缀匹配三种规则，没有提供contains（包含）或Regex匹配的选项。所以必须借助中间服务来实现自定义过滤逻辑。

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