Node.js编写的AWS Lambda无法推送数据到DynamoDB问题求助

• 代码结构错误：GraphQL请求逻辑定义在handler函数外部，属于模块初始化阶段执行的代码，和handler内的DynamoDB写入逻辑完全脱节，没有执行顺序关联。
• 异步逻辑未正确等待：使用回调风格的request库发起请求，未包装为Promise也未做等待处理，Lambda会在handler返回后直接冻结运行环境，未完成的异步操作会被强制中断。
• async handler与callback混用：AWS Lambda的async类型handler不需要使用callback返回结果，直接return响应即可，混用两种返回方式会导致逻辑提前终止，你测试返回的null就是混用导致的响应异常。
• 无错误日志输出：写入DynamoDB的操作如果报错（比如权限不足、表不存在），你仅在catch中做了console.error，测试时没有查看完整错误日志，无法定位写入失败的具体原因。

以下代码调整了结构，将API请求逻辑移入handler，改用Promise风格异步处理，先拉取API响应再写入DynamoDB，测试阶段可先注释API请求部分直接验证写入逻辑：

const AWS = require('aws-sdk');
const axios = require('axios'); // 替换已废弃的request库，需要在部署包中安装axios依赖
const ddb = new AWS.DynamoDB.DocumentClient({region: 'eu-west-2'});

exports.handler = async (event, context) => {
  // 测试阶段可以先注释下面的API请求部分，直接验证写入逻辑
  // ========== API请求逻辑开始 ==========
  const options = {
    method: 'POST',
    url: 'myurl',
    headers: {
      'x-api-key': 'my-api-key',
      'Content-Type': 'text/plain'
    },
    data: 'query my graphql query'
  };
  let apiResponse;
  try {
    apiResponse = await axios(options);
    console.log('API响应内容：', apiResponse.data);
  } catch (err) {
    console.error('API请求失败：', err);
    return {
      statusCode: 500,
      body: JSON.stringify({msg: 'API请求失败'}),
      headers: {'Access-Control-Allow-Origin': '*'}
    };
  }
  // 解析响应中的items字段，替换静态写入内容
  const items = apiResponse.data.items || [];
  // ========== API请求逻辑结束 ==========

  // ========== DynamoDB写入逻辑 ==========
  // 测试阶段直接用静态参数验证，上线后替换为上面拿到的items循环写入
  const params = {
    TableName: 'splunk-lambda',
    Item: {
      'id': '101',
      'message': 'Hello from lambda'
    }
  };
  try {
    await ddb.put(params).promise();
    console.log('DynamoDB写入成功');
    return {
      statusCode: 201,
      body: '',
      headers: {'Access-Control-Allow-Origin': '*'}
    };
  } catch (err) {
    console.error('DynamoDB写入失败：', err);
    return {
      statusCode: 500,
      body: JSON.stringify({msg: '写入失败', error: err.message}),
      headers: {'Access-Control-Allow-Origin': '*'}
    };
  }
};

• 部署前需要给Lambda的执行角色添加DynamoDB写入权限，IAM策略示例如下：

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": "dynamodb:PutItem",
      "Resource": "arn:aws:dynamodb:eu-west-2:<你的AWS账号ID>:table/splunk-lambda"
    }
  ]
}

• 如果需要批量写入多条items，使用ddb.batchWrite方法替代单条put，提高执行效率。
• 确认你的DynamoDB表的主键名和写入的Item中的主键字段名一致，你示例中用的主键是id，需要和表定义保持一致。

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