in source/transcribedocker/transcribe-to-dynamo-withSDK.js [195:250]
function sendResultsToDynamo(results, requestStartTime){
var milliseconds = timestamp_millis();
var timestamp = parseInt(Math.floor(milliseconds / 1000));
var timestamp_ttl = timestamp + 600;
var alternative = results.Alternatives[0];
var dynamoClient = new AWS.DynamoDB.DocumentClient();
console.log("Writing dynamo id_name: " + results.ResultId);
var resultsStartTime = String(results.StartTime.toFixed(2));
var resultsEndTime = String(results.EndTime.toFixed(2));
var sortStartTime = (timestamp_millis() * 1000);
// Write to Dynamo
var params = {
TableName : TABLE_NAME,
Item: {
// Ware
id_name: results.ResultId,
id_status: "ready",
sort_starttime: sortStartTime,
id_session: String(requestStartTime),
id_pipe: ID_PIPE,
id_lang: "en",
timestamp_created: timestamp,
timestamp_ttl: timestamp_ttl,
// ITEM
item_list: results.Alternatives[0].Items,
// TRANSCRIPT
transcript_transcript: alternative.Transcript,
transcript_starttime: resultsStartTime,
transcript_endtime: resultsEndTime,
transcript_resultid: String(results.ResultId),
transcript_ispartial: results.IsPartial
}
};
dynamoClient.put(params, function(err, data) {
if (err){
console.log(err);
}
// else { console.log(data); }
});
// Send SNS NON PARTIAL for translation to topic.
if(results.IsPartial == false){
// Remove Item_List from object getting sent to SNS
delete params["Item"]["item_list"];
publishSNSTopic(params["Item"]);
}
}