Я пытаюсь настроить поток из одного потока динамо, чтобы он мог помещать данные в другую таблицу динамо, но данные, похоже, не помещаются в целевую таблицу динамо
Код выполняется нормально, и cloudwatch не показывает никаких ошибок. У него достаточно прав для доступа к таблице динамо, в которую он пытается записать.
var AWS = require("aws-sdk");
const dynamoDb = new AWS.DynamoDB.DocumentClient();
exports.handler = async (event, context) => {
event.Records.forEach((record) => {
if (record.eventName != 'INSERT') {
console.log('Ignored ' + record.eventName + ' stream event.');
return;
}
var input = record.dynamodb.NewImage;
var id = input.pageId.S;
console.log(input);
console.log(id);
const params = {
TableName: "target-table",
Key: {
"targetId": id,
},
Item: {"targetId": id},
};
dynamoDb.put(params).promise();
console.log("put put the put put")
});
}
Я ожидаю, что данные, которые я ввожу в одну таблицу, будут реплицированы в цель, но, похоже, ничего не происходит.