async function updateDynamoDB()

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;
  }
}