AWS Lambda中DynamoDB getItem与batchGetItem无法执行问题排查

从你的日志表现来看，batchGetItem和S3.getObject的回调完全没执行——连错误日志都没输出，这大概率是异步操作还没完成，程序就提前终止了，如果这段代码运行在AWS Lambda环境下，这个问题尤为常见。

Lambda的执行逻辑是：当处理函数（比如index.js里的主逻辑）执行完毕返回后，Runtime会立刻冻结甚至终止进程，所有未完成的异步操作都会被中断，自然不会触发回调函数。

下面是具体的修复方案：

1. 改用Async/Await替代回调（核心修复） #

AWS SDK的所有方法都支持通过.promise()转换为Promise，用async/await可以确保异步操作完成后再继续执行，避免程序提前结束。

修改你的storageEvents.js：

'use strict';
var AWS = require("aws-sdk");
var storageEvents = (function () {
    var dynamodb = new AWS.DynamoDB({apiVersion: '2012-08-10', region: 'us-east-1'});
    var s3 = new AWS.S3({apiVersion: '2012-08-10', region: 'us-east-1'});
    var myBucket = 'my.events';
    var myObject = 'events.txt';
    return {
        // 改为async函数，返回Promise
        loadEvents: async function (session) {
            console.log('loadEvents');
            try {
                const data = await dynamodb.batchGetItem({
                    RequestItems: {
                        'EventsData': {
                            Keys: [
                                {'country': {S: 'USA'}}
                            ],
                        }
                    }
                }).promise();
                console.log('batchGetItem completed');
                var currentEventsList = "test";
                return currentEventsList;
            } catch (err) {
                console.error('batchGetItem error:', err);
                throw err; // 抛出错误让调用方处理
            }
        },
        loadEvent: async function(session) {
            console.log('loadEvent');
            try {
                const data = await dynamodb.getItem({
                    TableName: 'EventsData',
                    Key: {
                        event_name: { S: 'Fun Event' }
                    }
                }).promise();
                console.log('getItem completed');
                var currentEventsList = "test";
                return currentEventsList;
            } catch (err) {
                console.error('getItem error:', err);
                throw err;
            }
        },
        loadS3events: async function(session) {
            console.log('loadS3events');
            try {
                const data = await s3.getObject({
                    Bucket: myBucket,
                    Key: myObject
                }).promise();
                console.log('getObject completed');
                var currentEventsList = "test";
                return currentEventsList;
            } catch (err) {
                console.error('getObject error:', err);
                throw err;
            }
        }
    };
})();
module.exports = storageEvents;

然后修改index.js的调用逻辑，确保等待异步操作完成：

var storageEvents = require('./storageEvents');

// 如果是Lambda处理函数，必须改为async函数
exports.handler = async function(event, context) {
    try {
        const currentEventsList = await storageEvents.loadEvents(session);
        console.log("getEventsFromDynamoDb currentEventsList: " + currentEventsList);
        eventList = currentEventsList;
        // 其他业务逻辑...
        return { statusCode: 200, body: '操作成功' };
    } catch (err) {
        console.error('加载事件失败:', err);
        return { statusCode: 500, body: '内部错误' };
    }
};

2. 验证权限与参数正确性 #

虽然你提到其他DynamoDB函数正常，但还是要确认：

• IAM角色是否包含dynamodb:BatchGetItem权限（针对EventsData表）
• batchGetItem的参数是否正确：比如EventsData表的主键确实是country（字符串类型），如果主键是其他属性（比如event_name），会导致查询不到数据，但即使如此，Promise的catch块也会执行并打印错误
• S3的IAM权限是否包含s3:GetObject，且桶名、对象键没有拼写错误，目标对象确实存在

3. 非Lambda环境的程序生命周期检查 #

如果这段代码运行在普通Node.js环境，要确保主线程不会提前退出。比如在index.js的主逻辑末尾添加等待逻辑，或者用async/await包裹所有异步操作后再退出：

var storageEvents = require('./storageEvents');

async function main() {
    try {
        const currentEventsList = await storageEvents.loadEvents(session);
        console.log("getEventsFromDynamoDb currentEventsList: " + currentEventsList);
        eventList = currentEventsList;
        // 其他逻辑...
        process.exit(0); // 完成后正常退出
    } catch (err) {
        console.error('错误:', err);
        process.exit(1); // 异常退出
    }
}

main();

这样修改后，你应该能看到batchGetItem completed的日志，即使出现错误也会打印详细信息，方便进一步排查问题。

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