in ambari-infra-solr-client/src/main/java/org/apache/ambari/infra/solr/S3Uploader.java [33:63]
public static void main(String[] args) {
try {
String keyFilePath = args[0];
String bucketName = args[1];
String keyPrefix = args[2];
String filePath = args[3];
String keyFileContent = FileUtils.readFileToString(new File(keyFilePath)).trim();
String[] keys = keyFileContent.split(",");
String accessKey = keys[0];
String secretKey = keys[1];
BasicAWSCredentials credentials = new BasicAWSCredentials(accessKey, secretKey);
AmazonS3Client client = new AmazonS3Client(credentials);
File file = new File(filePath);
String key = keyPrefix + file.getName();
if (client.doesObjectExist(bucketName, key)) {
System.out.println("Object '" + key + "' already exists");
System.exit(0);
}
client.putObject(bucketName, key, file);
} catch (Exception e) {
e.printStackTrace(System.err);
System.exit(1);
}
System.exit(0);
}