以下是一个示例 Lambda 函数,用于处理连续记录:
const AWS = require('aws-sdk');
exports.handler = async (event) => {
const dynamodb = new AWS.DynamoDB();
const streamRecord = event.Records[0].dynamodb;
if (streamRecord.NewImage) {
const timestamp = streamRecord.NewImage.timestamp.N;
const prevTimestamp = streamRecord.OldImage ? streamRecord.OldImage.PrevTimestamp.N : null;
if (prevTimestamp == timestamp) {
// 连续记录,执行更新操作或删除操作
} else {
// 非连续记录,执行其他操作
}
}
};
上一篇:AWSLambda|如何通过执行超时回滚数据库更改?
下一篇:AWSLambda、RDSServices、AuroraMySqlserverless中,RDS编写的预处理SQL语句无法正常运行或返回结果。