如何从Lambda调用SNS Topic向所有订阅用户批量推送通知？

你要的批量推送效果SNS本身就支持，只要你的用户设备端点确实已经订阅到目标SNS Topic，完全不需要自行拉取全量用户遍历发送，改造逻辑如下：

1 提前确认订阅配置 #

你需要确保用户注册/登录引导订阅的环节，确实调用了SNS的subscribe接口，将用户的设备Endpoint ARN（也就是你存在数据库里的device ARN）绑定到目标SNS Topic，SNS会自动维护全量订阅列表，不需要你自己存储管理：

// 新用户订阅示例逻辑，可放在用户登录/注册流程中
const subscribeParams = {
  Protocol: 'application', // 移动端推送固定取值为application
  TopicArn: '替换为你的SNS Topic ARN',
  Endpoint: '当前用户的设备Endpoint ARN'
};
await sns.subscribe(subscribeParams).promise();

如果之前仅把订阅状态存在自有数据库、没有调用SNS订阅接口，补一下老用户的批量订阅逻辑即可。

2 替换原有推送代码 #

原有遍历发送的代码全部替换为单次SNS Topic发布调用即可，消息结构不需要调整，仅把参数里的TargetArn替换为TopicArn：

const snsTopicArn = "替换为你的SNS Topic ARN";

const publishNotificationParams = { 
  "TopicArn": snsTopicArn, // 仅此处修改，替换原有TargetArn参数
  "Message": JSON.stringify({
    "default": JSON.stringify({
        "category" : title,
        "alert" : {
          "title" : title,
          "body" : 'New product is launced',
          "data" : product
        },
        "badge" : 1,
        "sound" : "chime.aiff"
      }),
      "APNS_SANDBOX": JSON.stringify(params),
      "APNS": JSON.stringify(params)
  }),
  "MessageStructure": "json"
};

try {
  const publishResult = await sns.publish(publishNotificationParams).promise();
  console.log(`消息已推送至Topic，消息ID: ${publishResult.MessageId}`);
} catch (err) {
  console.error('推送失败:', err, err.stack);
}

3 优化收益 #

• 不需要再查询全量用户数据，Lambda运行时长从秒级/分钟级降到毫秒级，大幅降低计算成本
• 仅需要调用1次SNS接口，完全避免批量调用的限流风险
• SNS内置推送重试机制，推送成功率比自行遍历发送更高
• 如果后续需要做分人群推送，可以直接用SNS的消息过滤功能，订阅时给用户打标签、发消息时带对应属性，SNS会自动匹配符合条件的用户推送，不需要自行做人群筛选。

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