in src/main/java/com/amazonaws/kvstranscribestreaming/handler/KVSTranscribeStreamingHandler.java [98:123]
public String handleRequest(String eventBody) {
try {
Map<String, Object> eventBodyMap = objectMapper.readValue(eventBody, Map.class);
Map<String, String> eventDetail = (Map) eventBodyMap.get("detail");
String streamingStatus = eventDetail.get("streamingStatus");
String transactionId = eventDetail.get("transactionId");
this.transactionId = transactionId;
logger.info("Received STARTED event");
if (StreamingStatus.STARTED.name().equals(streamingStatus)) {
final StreamingStatusStartedDetail streamingStatusStartedDetail = objectMapper.convertValue(eventDetail,
StreamingStatusStartedDetail.class);
logger.info("[{}] Streaming status {} , EventDetail: {}", transactionId, streamingStatus, streamingStatusStartedDetail);
startKVSToTranscribeStreaming(streamingStatusStartedDetail);
}
logger.info("[{}] Finished processing request", this.transactionId);
} catch (Exception e) {
logger.error("[{}] KVS to Transcribe Streaming failed with: ", this.transactionId, e);
return "{ \"result\": \"Failed\" }";
}
return "{ \"result\": \"Success\" }";
}