in src/main/java/com/amazonaws/kvstranscribestreaming/publisher/DynamoDBTranscriptionPublisher.java [46:65]
public void publish(TranscriptEvent transcriptEvent) {
List<Result> results = transcriptEvent.transcript().results();
if (results.size() > 0) {
Result result = results.get(0);
// we're only saving final transcripts here (note: this will make the Ux appear slower)
if (!result.isPartial()) {
try {
Item ddbItem = toDynamoDbItem(result);
if (ddbItem != null) {
getDdbClient().getTable(TABLE_TRANSCRIPT).putItem(ddbItem);
}
} catch (Exception e) {
logger.error("Exception while writing to DDB: ", e);
}
}
}
}