in source/lambda/updateburnedvideopath/updateburnedvideopath.js [40:92]
async function updateDynamoDB(params) {
console.log("[INFO] dynamoVideoTable: %s", params.dynamoVideoTable);
console.log("[INFO] videoId: %s", params.videoId);
try {
var s3BurnedVideoPath =
"s3://" + params.inputBucket + "/" + params.inputKey;
console.log("[INFO] update s3BurnedVideoPath: %s", s3BurnedVideoPath);
var updateParams = {};
if (params.translated) {
var updateParams = {
TableName: params.dynamoVideoTable,
Key: {
videoId: { S: params.videoId },
},
UpdateExpression:
"SET #s3BurnedTranslatedVideoPath = :s3BurnedTranslatedVideoPath",
ExpressionAttributeNames: {
"#s3BurnedTranslatedVideoPath": "s3BurnedTranslatedVideoPath",
},
ExpressionAttributeValues: {
":s3BurnedTranslatedVideoPath": {
S: s3BurnedVideoPath,
},
},
ReturnValues: "NONE",
};
} else {
var updateParams = {
TableName: params.dynamoVideoTable,
Key: {
videoId: { S: params.videoId },
},
UpdateExpression: "SET #s3BurnedVideoPath = :s3BurnedVideoPath",
ExpressionAttributeNames: {
"#s3BurnedVideoPath": "s3BurnedVideoPath",
},
ExpressionAttributeValues: {
":s3BurnedVideoPath": {
S: s3BurnedVideoPath,
},
},
ReturnValues: "NONE",
};
}
await dynamoDB.updateItem(updateParams).promise();
console.log("[INFO] successfully updated DynamoDB status");
} catch (error) {
console.log("[ERROR] to update DynamoDB status", error);
throw error;
}
}