in src/main/java/com/amazonaws/kvstranscribestreaming/utils/AudioUtils.java [51:92]
public static void uploadRawAudio(Regions region, String bucketName, String keyPrefix, String audioFilePath, String transactionId, String startTime, boolean publicReadAcl, AWSCredentialsProvider awsCredentials) {
File wavFile = null;
try {
AmazonS3 s3Client = AmazonS3ClientBuilder.standard()
.withRegion(region)
.withCredentials(awsCredentials)
.build();
wavFile = convertToWav(audioFilePath);
// upload the raw audio file to the designated S3 location
String objectKey = keyPrefix + wavFile.getName();
logger.info(String.format("Uploading Audio: to %s/%s from %s", bucketName, objectKey, wavFile));
PutObjectRequest request = new PutObjectRequest(bucketName, objectKey, wavFile);
ObjectMetadata metadata = new ObjectMetadata();
metadata.setContentType("audio/wav");
metadata.addUserMetadata("transactionId", transactionId);
metadata.addUserMetadata("startTime", startTime);
request.setMetadata(metadata);
if (publicReadAcl) {
request.setCannedAcl(CannedAccessControlList.PublicRead);
}
s3Client.putObject(request);
logger.info("putObject completed successfully for S3 key " + objectKey);
} catch (SdkClientException e) {
logger.error("Audio upload to S3 failed: ", e);
throw e;
} catch (UnsupportedAudioFileException|IOException e) {
logger.error("Failed to convert to wav: ", e);
}
finally {
if (wavFile != null) {
wavFile.delete();
}
}
}