function sendResultsToDynamo()

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"]);
	}
	

}