in functions/source/amazon-chime-recordandtranscribe/src/main/java/com/amazonaws/kvstranscribestreaming/handler/KVSTranscribeStreamingHandler.java [106:131]
public String handleRequest(String eventBody) {
try {
logger.info("inside Handler ---- ", eventBody);
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");
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");
} catch (Exception e) {
logger.error("KVS to Transcribe Streaming failed with: ", e);
return "{ \"result\": \"Failed\" }";
}
return "{ \"result\": \"Success\" }";
}