medium/serverless/S3EventHandler.java

S3EventHandler.java

@Override
public Void handleRequest(S3Event event, Context context) {
    List<S3EventNotificationRecord> records = event.getRecords();
  ...
    String bucket = record.getS3().getBucket().getName();
    String key = decodeKey(record.getS3().getObject().getKey());
  ...
    // fetch recording off S3 bucket
    S3Object object = getS3Object(bucket, key);

    MosResult mos = computeMos(object);

    // store custom metrics
    mCloudWatchMosMetricProducer.put(mos, CLOUDWATCH_METRICS_NAMESPACE);
    // send kinesis event
    mKinesisMosRecordProducer.put(mos, KINESIS_STREAM_NAME);
    return null;
}