in src/main/java/com/amazonaws/kvstranscribestreaming/TranscribedSegmentWriter.java [58:78]
public void writeToDynamoDB(TranscriptEvent transcriptEvent, String tableName) {
logger.info("table name: " + tableName);
logger.info("Transcription event: " + transcriptEvent.transcript().toString());
List<Result> results = transcriptEvent.transcript().results();
if (results.size() > 0) {
Result result = results.get(0);
if (SAVE_PARTIAL_TRANSCRIPTS || !result.isPartial()) {
try {
Item ddbItem = toDynamoDbItem(result);
if (ddbItem != null) {
getDdbClient().getTable(tableName).putItem(ddbItem);
}
} catch (Exception e) {
logger.error("Exception while writing to DDB: ", e);
}
}
}
}