API Gateway转SNS使用消息属性过滤的Node.js发布问题求助

核心问题分析 #

你当前的配置存在几个关键错误，导致消息属性无法正确传递，同时FIFO主题的必填参数缺失：

1. 映射模板的变量取值与Node.js payload字段不匹配
2. 未添加SNS FIFO主题必需的MessageDeduplicationId和MessageGroupId参数
3. 冗余且格式错误的URL查询字符串参数干扰请求处理

修正后的完整配置 #

1. API Gateway映射模板（Content-Type: application/json）

替换原有模板，确保取值与payload对应，同时补充FIFO必填参数：

Action=Publish
&TopicArn=$util.urlEncode('arn:aws:sns:你的区域:账号ID:你的主题名.fifo')
&Message=$util.urlEncode($input.json('$.message'))
&Subject=$util.urlEncode($input.json('$.subject'))
&MessageAttributes.member.1.Name=service_type
&MessageAttributes.member.1.Value.DataType=String
&MessageAttributes.member.1.Value.StringValue=$util.urlEncode($input.json('$.MessageAttributes.service_type.StringValue'))
&MessageDeduplicationId=$util.urlEncode($input.json('$.messageId'))
&MessageGroupId=$util.urlEncode($input.json('$.groupId'))

2. 删除URL查询字符串参数

直接清空所有URL查询字符串参数，避免与映射模板的参数冲突。

3. 修正后的Node.js代码

补充FIFO主题所需的必填字段，确保payload结构与映射模板取值一致：

const axios = require('axios');

const url = '你的API Gateway完整URL';
const payload = {
  message: 'First Message',
  subject: 'Test Subject',
  messageId: 'unique-dedup-001', // 唯一去重ID，可自定义生成
  groupId: 'order-service-group', // 消息组ID，按业务场景定义
  MessageAttributes: {
    service_type: {
      DataType: 'String',
      StringValue: 'order'
    }
  }
};

axios.post(url, payload)
  .then(response => {
    console.log('消息发布成功:', response.data);
  })
  .catch(error => {
    console.error('发布失败:', error.response?.data || error.message);
  });

4. SQS订阅过滤策略配置

在SNS主题的SQS订阅中，设置过滤策略为：

{"service_type": ["order"]}

这样只有携带service_type=order属性的消息才会被推送到该SQS队列。

关键注意事项 #

• FIFO主题必须同时提供MessageDeduplicationId和MessageGroupId，否则请求会直接失败
• 映射模板中所有参数必须严格遵循SNS Publish API的格式要求
• 确保API Gateway的集成请求设置为POST，并正确配置了AWS服务集成权限

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