已用awsServerlessExpress的Lambda如何实现SQS触发？（Node.js）

你可以通过在现有handler中判断事件类型，分发到不同处理逻辑的方式实现，不需要修改Lambda的handler配置。具体步骤如下：

1. 修改lambda.js的handler，添加事件类型判断 #

在原有的代理逻辑前，先检查事件是否来自SQS，如果是则调用index.js中导出的SQS处理函数，否则继续走API网关代理：

// lambda.js
'use strict'
const awsServerlessExpress = require('aws-serverless-express')
const app = require('./index')
const server = awsServerlessExpress.createServer(app)

exports.handler = async (event, context) => {
  // 判断是否为SQS事件：根据event结构中的eventSource字段识别
  if (event.Records?.[0]?.eventSource === 'aws:sqs') {
    return await app.handleSqsEvent(event, context)
  }
  // 非SQS事件，继续代理API网关请求
  return awsServerlessExpress.proxy(server, event, context)
}

2. 在index.js中添加并导出SQS事件处理函数 #

在你的Express应用代码中，新增处理SQS消息的逻辑，并将函数挂载到app对象上导出：

// index.js
// 保留原有的Express应用代码
const express = require('express')
const app = express()

// ... 你的路由、中间件等原有代码

// 新增SQS事件处理函数
async function handleSqsEvent(event, context) {
  try {
    // 遍历批量接收的SQS消息
    for (const record of event.Records) {
      // 解析消息体（根据你的消息格式调整，这里假设是JSON格式）
      const messageContent = JSON.parse(record.body)
      // 这里编写你的业务逻辑，比如数据入库、触发其他服务等
      console.log('处理SQS消息:', messageContent)
    }
    // 返回成功响应（SQS不需要响应，但Lambda返回状态码便于排查）
    return {
      statusCode: 200,
      body: JSON.stringify({ msg: 'SQS消息处理完成' })
    }
  } catch (err) {
    console.error('SQS消息处理失败:', err)
    return {
      statusCode: 500,
      body: JSON.stringify({ err: '处理SQS消息出错' })
    }
  }
}

// 将处理函数挂载到app上，供lambda.js调用
app.handleSqsEvent = handleSqsEvent

module.exports = app

注意事项 #

• 确保Lambda的执行角色拥有SQS的相关权限：比如sqs:ReceiveMessage、sqs:DeleteMessage、sqs:GetQueueAttributes等，否则无法正常接收和处理消息
• 根据SQS消息的处理耗时，调整Lambda的超时时间，避免处理超时导致消息重发
• 如果启用了SQS批量触发，注意处理批量消息的异常情况，比如部分消息处理失败时的重试逻辑

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