本地serverless-offline环境下SNS消息触发Lambda函数测试咨询

我来一步步教你完成这个本地测试流程，从配置完善到验证结果都给你捋清楚：

1. 补全serverless.yml配置 #

你提供的配置片段不全，得把SNS主题、订阅关系和权限都补上，不然本地环境没法识别SNS资源：

service: sns-local-test

plugins:
  - serverless-offline
  - serverless-offline-sns

custom:
  serverless-offline-sns:
    port: 4002 # 本地SNS服务端口，默认值，可自定义
    debug: true # 开启调试日志，方便排查问题

resources:
  Resources:
    MyTestTopic: # 定义本地SNS主题
      Type: AWS::SNS::Topic
      Properties:
        TopicName: my-test-topic

functions:
  publisher:
    handler: publisher.main
    events:
      - http:
          path: publish
          method: post
          cors: 
            origins: '*' # 补全跨域配置，根据你的需求调整
    iamRoleStatements:
      - Effect: Allow
        Action:
          - sns:Publish
        Resource: !Ref MyTestTopic # 给publisher函数发布消息到主题的权限
    environment:
      TOPIC_ARN: !Ref MyTestTopic # 传递主题ARN到函数环境变量

  subscriber1: # 第一个订阅主题的Lambda
    handler: subscriber1.main
    events:
      - sns:
          arn: !Ref MyTestTopic
          topicName: my-test-topic

  subscriber2: # 第二个订阅主题的Lambda
    handler: subscriber2.main
    events:
      - sns:
          arn: !Ref MyTestTopic
          topicName: my-test-topic

2. 调整Lambda代码适配本地环境 #

重点是publisher函数里的SNS客户端要指向本地的SNS服务端点，不然会默认调用AWS线上服务：

比如Node.js的publisher代码示例：

const AWS = require('aws-sdk');

// 本地开发时指向serverless-offline-sns的端点，线上环境自动使用默认配置
const sns = new AWS.SNS({
  endpoint: process.env.IS_OFFLINE ? 'http://localhost:4002' : undefined,
  region: 'us-east-1' // 本地环境无需真实region，随便填一个即可
});

exports.main = async (event) => {
  try {
    const requestBody = JSON.parse(event.body);
    const message = requestBody.message || 'Hello from local SNS!';
    
    await sns.publish({
      TopicArn: process.env.TOPIC_ARN,
      Message: message
    }).promise();

    return { statusCode: 200, body: JSON.stringify({ message: 'Message published successfully' }) };
  } catch (err) {
    console.error('Publish error:', err);
    return { statusCode: 500, body: JSON.stringify({ error: 'Failed to publish message' }) };
  }
};

订阅的Lambda函数（subscriber1、subscriber2）只需正常编写消息处理逻辑即可，比如加日志打印确认收到消息：

// subscriber1.js示例
exports.main = async (event) => {
  const receivedMessage = event.Records[0].Sns.Message;
  console.log('✅ Subscriber 1 received message:', receivedMessage);
  // 这里可以加你的业务处理逻辑
  return { statusCode: 200 };
};

3. 安装依赖并启动本地服务 #

首先确保所有插件都安装完成：

npm install serverless-offline serverless-offline-sns --save-dev

然后启动本地Serverless服务：

sls offline start

启动成功后，控制台会输出本地HTTP服务端口（默认3000）、本地SNS服务端口（4002），以及各个Lambda函数的注册状态日志。

4. 测试流程并验证结果 #

调用API触发publisher函数 #

用curl、Postman或者你的前端按钮调用本地API：

curl -X POST http://localhost:3000/publish \
  -H "Content-Type: application/json" \
  -d '{"message": "Test local SNS trigger flow"}'

如果返回{"message":"Message published successfully"}，说明publisher已经成功向本地SNS主题发布了消息。

验证订阅Lambda是否被触发 #

查看serverless-offline的控制台日志，你会看到subscriber1和subscriber2的日志输出，比如：

✅ Subscriber 1 received message: Test local SNS trigger flow
✅ Subscriber 2 received message: Test local SNS trigger flow

这就说明订阅的Lambda已经被本地SNS主题成功触发了。

常见问题排查 #

• 如果publisher报错"Could not connect to the endpoint URL"：检查SNS客户端的endpoint是否和serverless-offline-sns配置的端口一致。
• 如果订阅Lambda没触发：检查serverless.yml里的SNS事件配置是否正确，ARN和topicName是否匹配，以及服务启动日志里是否加载了SNS主题和订阅关系。
• 跨域问题：确保http事件的cors配置符合前端请求的要求，比如允许对应的origin。

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