下面列出了怎么用com.amazonaws.services.s3.model.SSECustomerKey的API类实例代码及写法，或者点击链接到github查看源代码。
@Override
public SSECustomerKey deserialize(JsonParser parser, DeserializationContext context)
throws IOException {
Map<String, String> asMap = parser.readValueAs(new TypeReference<Map<String, String>>() {});
final String key = asMap.getOrDefault("key", null);
final String algorithm = asMap.getOrDefault("algorithm", null);
final String md5 = asMap.getOrDefault("md5", null);
SSECustomerKey sseCustomerKey = new SSECustomerKey(key);
if (algorithm != null) {
sseCustomerKey.setAlgorithm(algorithm);
}
if (md5 != null) {
sseCustomerKey.setMd5(md5);
}
return sseCustomerKey;
}
static S3Object getObject(
AmazonS3 s3Client,
String bucket,
String objectKey,
boolean useSSE,
CredentialValue customerKey,
CredentialValue customerKeyMd5
) throws StageException {
GetObjectRequest getObjectRequest = new GetObjectRequest(bucket, objectKey);
if (useSSE) {
SSECustomerKey sseCustomerKey = new SSECustomerKey(customerKey.get());
sseCustomerKey.setMd5(customerKeyMd5.get());
getObjectRequest.setSSECustomerKey(sseCustomerKey);
}
return s3Client.getObject(getObjectRequest);
}
static S3Object getObjectRange(
AmazonS3 s3Client,
String bucket,
String objectKey,
long range,
boolean useSSE,
CredentialValue customerKey,
CredentialValue customerKeyMd5
) throws StageException {
GetObjectRequest getObjectRequest = new GetObjectRequest(bucket, objectKey).withRange(0, range);
if (useSSE) {
SSECustomerKey sseCustomerKey = new SSECustomerKey(customerKey.get());
sseCustomerKey.setMd5(customerKeyMd5.get());
getObjectRequest.setSSECustomerKey(sseCustomerKey);
}
return s3Client.getObject(getObjectRequest);
}
public AwsModule() {
super("AwsModule");
setMixInAnnotation(AWSCredentialsProvider.class, AWSCredentialsProviderMixin.class);
setMixInAnnotation(SSECustomerKey.class, SSECustomerKeyMixin.class);
setMixInAnnotation(SSEAwsKeyManagementParams.class, SSEAwsKeyManagementParamsMixin.class);
setMixInAnnotation(ClientConfiguration.class, AwsHttpClientConfigurationMixin.class);
}
@Test
public void testSSECustomerKeySerializationDeserialization() throws Exception {
final String key = "86glyTlCNZgccSxW8JxMa6ZdjdK3N141glAysPUZ3AA=";
final String md5 = null;
final String algorithm = "AES256";
SSECustomerKey value = new SSECustomerKey(key);
String valueAsJson = objectMapper.writeValueAsString(value);
SSECustomerKey valueDes = objectMapper.readValue(valueAsJson, SSECustomerKey.class);
assertEquals(key, valueDes.getKey());
assertEquals(algorithm, valueDes.getAlgorithm());
assertEquals(md5, valueDes.getMd5());
}
@Nullable
static String getSSECustomerKeyMd5(S3Options options) {
SSECustomerKey sseCostumerKey = options.getSSECustomerKey();
if (sseCostumerKey != null) {
return Base64.encodeAsString(DigestUtils.md5(Base64.decode(sseCostumerKey.getKey())));
}
return null;
}
private cfData readToMemory(AmazonS3 s3Client, String bucket, String key, String aes256key, int retry, int retryseconds) throws Exception {
// Let us run around the number of attempts
int attempts = 0;
while ( attempts < retry ){
try{
GetObjectRequest gor = new GetObjectRequest(bucket, key);
if ( aes256key != null && !aes256key.isEmpty() )
gor.setSSECustomerKey( new SSECustomerKey(aes256key) );
S3Object s3object = s3Client.getObject(gor);
String contentType = s3object.getObjectMetadata().getContentType();
ByteArrayOutputStream baos = new ByteArrayOutputStream( 32000 );
StreamUtil.copyTo(s3object.getObjectContent(), baos, false );
if ( contentType.indexOf("text") != -1 || contentType.indexOf("javascript") != -1 ){
return new cfStringData( baos.toString() );
}else{
return new cfBinaryData( baos.toByteArray() );
}
}catch(Exception e){
cfEngine.log("Failed: AmazonS3Read(bucket=" + bucket + "; key=" + key + "; attempt=" + (attempts+1) + "; exception=" + e.getMessage() + ")");
attempts++;
if ( attempts == retry )
throw e;
else
Thread.sleep( retryseconds*1000 );
}
}
return null; // should never
}
public cfData execute( cfSession _session, cfArgStructData argStruct ) throws cfmRunTimeException{
AmazonKey amazonKey = getAmazonKey(_session, argStruct);
AmazonS3 s3Client = getAmazonS3(amazonKey);
String bucket = getNamedStringParam(argStruct, "bucket", null );
String srckey = getNamedStringParam(argStruct, "srckey", null );
String deskey = getNamedStringParam(argStruct, "destkey", null );
String aes256key = getNamedStringParam(argStruct, "aes256key", null );
if ( srckey != null && srckey.charAt( 0 ) == '/' )
srckey = srckey.substring(1);
if ( deskey != null && deskey.charAt( 0 ) == '/' )
deskey = deskey.substring(1);
CopyObjectRequest cor = new CopyObjectRequest(bucket, srckey, bucket, deskey);
if ( aes256key != null && !aes256key.isEmpty() ){
cor.setSourceSSECustomerKey( new SSECustomerKey(aes256key) );
cor.setDestinationSSECustomerKey( new SSECustomerKey(aes256key) );
}
try {
s3Client.copyObject(cor);
s3Client.deleteObject(new DeleteObjectRequest(bucket, srckey));
return cfBooleanData.TRUE;
} catch (Exception e) {
throwException(_session, "AmazonS3: " + e.getMessage() );
return cfBooleanData.FALSE;
}
}
@Description(
"SSE key for SSE-C encryption, e.g. a base64 encoded key and the algorithm."
+ "To specify on the command-line, represent the value as a JSON object. For example:"
+ " --SSECustomerKey={\"key\": \"86glyTlCN...\", \"algorithm\": \"AES256\"}")
@Nullable
SSECustomerKey getSSECustomerKey();
static S3Options s3OptionsWithSSECustomerKey() {
S3Options options = s3Options();
options.setSSECustomerKey(new SSECustomerKey("86glyTlCNZgccSxW8JxMa6ZdjdK3N141glAysPUZ3AA="));
return options;
}
static S3Options s3OptionsWithMultipleSSEOptions() {
S3Options options = s3OptionsWithSSEAwsKeyManagementParams();
options.setSSECustomerKey(new SSECustomerKey("86glyTlCNZgccSxW8JxMa6ZdjdK3N141glAysPUZ3AA="));
return options;
}
public cfData execute( cfSession _session, cfArgStructData argStruct ) throws cfmRunTimeException{
AmazonKey amazonKey = getAmazonKey(_session, argStruct);
AmazonS3 s3Client = getAmazonS3(amazonKey);
String srcbucket = getNamedStringParam(argStruct, "srcbucket", null );
String srckey = getNamedStringParam(argStruct, "srckey", null );
String srcaes256key = getNamedStringParam(argStruct, "srcaes256key", null );
String destbucket = getNamedStringParam(argStruct, "destbucket", null );
String deskey = getNamedStringParam(argStruct, "destkey", null );
String destaes256key = getNamedStringParam(argStruct, "destaes256key", null );
String deststorageclass = getNamedStringParam(argStruct, "deststorageclass", null );
String destacl = getNamedStringParam(argStruct, "destacl", null );
if ( srckey != null && srckey.charAt( 0 ) == '/' )
srckey = srckey.substring(1);
if ( deskey != null && deskey.charAt( 0 ) == '/' )
deskey = deskey.substring(1);
CopyObjectRequest cor = new CopyObjectRequest(srcbucket, srckey, destbucket, deskey);
if ( srcaes256key != null && !srcaes256key.isEmpty() )
cor.setSourceSSECustomerKey( new SSECustomerKey(srcaes256key) );
if ( destaes256key != null && !destaes256key.isEmpty() )
cor.setDestinationSSECustomerKey( new SSECustomerKey(destaes256key) );
if ( deststorageclass != null && !deststorageclass.isEmpty() )
cor.setStorageClass( amazonKey.getAmazonStorageClass(deststorageclass) );
if ( destacl != null && !destacl.isEmpty() )
cor.setCannedAccessControlList( amazonKey.getAmazonCannedAcl(destacl) );
try {
s3Client.copyObject(cor);
return cfBooleanData.TRUE;
} catch (Exception e) {
throwException(_session, "AmazonS3: " + e.getMessage() );
return cfBooleanData.FALSE;
}
}
private void writeData( AmazonKey amazonKey, String bucket, String key, Map<String, String> metadata, StorageClass storage, String mimetype, cfData data, int retry, int retryseconds, String acl, String aes256key, Map<String, String> customheaders ) throws Exception {
if ( mimetype == null ) {
if ( data.getDataType() == cfData.CFBINARYDATA )
mimetype = "application/unknown";
else if ( cfData.isSimpleValue( data ) )
mimetype = "text/plain";
else
mimetype = "application/json";
// Check to see if the mime type is in the metadata
if ( metadata != null && metadata.containsKey( "Content-Type" ) )
mimetype = metadata.get( "Content-Type" );
}
InputStream ios = null;
long size = 0;
if ( data.getDataType() == cfData.CFSTRINGDATA ) {
ios = new java.io.ByteArrayInputStream( data.getString().getBytes() );
size = data.getString().length();
} else if ( data.getDataType() == cfData.CFBINARYDATA ) {
ios = new java.io.ByteArrayInputStream( ( (cfBinaryData) data ).getByteArray() );
size = ( (cfBinaryData) data ).getLength();
} else {
serializejson json = new serializejson();
StringBuilder out = new StringBuilder();
json.encodeJSON( out, data, false, CaseType.MAINTAIN, DateType.LONG );
size = out.length();
mimetype = "application/json";
ios = new java.io.ByteArrayInputStream( out.toString().getBytes() );
}
// Setup the object data
ObjectMetadata omd = new ObjectMetadata();
if ( metadata != null )
omd.setUserMetadata( metadata );
omd.setContentType( mimetype );
omd.setContentLength( size );
AmazonS3 s3Client = getAmazonS3( amazonKey );
// Let us run around the number of attempts
int attempts = 0;
while ( attempts < retry ) {
try {
PutObjectRequest por = new PutObjectRequest( bucket, key, ios, omd );
por.setStorageClass( storage );
if ( aes256key != null && !aes256key.isEmpty() )
por.setSSECustomerKey( new SSECustomerKey( aes256key ) );
if ( acl != null && !acl.isEmpty() )
por.setCannedAcl( amazonKey.getAmazonCannedAcl( acl ) );
if ( customheaders != null && !customheaders.isEmpty() ) {
Iterator<String> it = customheaders.keySet().iterator();
while ( it.hasNext() ) {
String k = it.next();
por.putCustomRequestHeader( k, customheaders.get( k ) );
}
}
s3Client.putObject( por );
break;
} catch ( Exception e ) {
cfEngine.log( "Failed: AmazonS3Write(bucket=" + bucket + "; key=" + key + "; attempt=" + ( attempts + 1 ) + "; exception=" + e.getMessage() + ")" );
attempts++;
if ( attempts == retry )
throw e;
else
Thread.sleep( retryseconds * 1000 );
}
}
}
private void writeFile( AmazonKey amazonKey, String bucket, String key, Map<String, String> metadata, StorageClass storage, String localpath, int retry, int retryseconds, boolean deletefile, boolean background, String callback, String callbackdata, String appname, String acl, String aes256key, Map<String, String> customheaders ) throws Exception {
File localFile = new File( localpath );
if ( !localFile.isFile() )
throw new Exception( "The file specified does not exist: " + localpath );
// Push this to the background loader to handle and return immediately
if ( background ) {
BackgroundUploader.acceptFile( amazonKey, bucket, key, metadata, storage, localpath, retry, retryseconds, deletefile, callback, callbackdata, appname, acl, aes256key, customheaders );
return;
}
// Setup the object data
ObjectMetadata omd = new ObjectMetadata();
if ( metadata != null )
omd.setUserMetadata( metadata );
AmazonS3 s3Client = getAmazonS3( amazonKey );
// Let us run around the number of attempts
int attempts = 0;
while ( attempts < retry ) {
try {
PutObjectRequest por = new PutObjectRequest( bucket, key, localFile );
por.setMetadata( omd );
por.setStorageClass( storage );
if ( acl != null && !acl.isEmpty() )
por.setCannedAcl( amazonKey.getAmazonCannedAcl( acl ) );
if ( aes256key != null && !aes256key.isEmpty() )
por.setSSECustomerKey( new SSECustomerKey( aes256key ) );
if ( customheaders != null && !customheaders.isEmpty() ) {
Iterator<String> it = customheaders.keySet().iterator();
while ( it.hasNext() ) {
String k = it.next();
por.putCustomRequestHeader( k, customheaders.get( k ) );
}
}
s3Client.putObject( por );
break;
} catch ( Exception e ) {
cfEngine.log( "Failed: AmazonS3Write(bucket=" + bucket + "key=" + key + "; file=" + localFile + "; attempt=" + ( attempts + 1 ) + "; exception=" + e.getMessage() + ")" );
attempts++;
if ( attempts == retry )
throw e;
else
Thread.sleep( retryseconds * 1000 );
}
}
// delete the file now that it is a success
if ( deletefile )
localFile.delete();
}
/**
* Fetchs a remote object from S3; datasource, bucket, key, aes256key supported
*
* @param props
* @param _Session
* @throws cfmRunTimeException
*/
private void remoteFetchS3( cfStructData props, cfSession _Session ) throws cfmRunTimeException {
if ( !props.containsKey( "datasource" ) ||
!props.containsKey( "bucket" ) ||
!props.containsKey( "key" ) )
throw newRunTimeException( "'remote'.type=s3; minimum keys are datasource, bucket and key" );
String datasource = props.getData( "datasource" ).getString();
String bucket = props.getData( "bucket" ).getString();
String key = props.getData( "key" ).getString();
// Get the Amazon datasource
AmazonKey amazonKey = AmazonKeyFactory.getDS( datasource );
if ( amazonKey == null )
throw newRunTimeException( "Amazon Datasource [" + datasource + "] has not been registered; use AmazonRegisterDataSource()" );
amazonKey.setDataSource( datasource );
AmazonS3 s3Client = new AmazonBase().getAmazonS3( amazonKey );
GetObjectRequest gor = new GetObjectRequest( bucket, key );
if ( props.containsKey( "aes256key" ) ) {
String aes256key = props.getData( "aes256key" ).getString();
if ( !aes256key.isEmpty() )
gor.setSSECustomerKey( new SSECustomerKey( aes256key ) );
}
// Get the object
try {
S3Object s3object = s3Client.getObject( gor );
_Session.setContentType( s3object.getObjectMetadata().getContentType() );
InputStream in = s3object.getObjectContent();
byte[] buffer = new byte[65536];
int readCount = 0;
while ( ( readCount = in.read( buffer ) ) != -1 ) {
_Session.write( buffer, 0, readCount );
_Session.pageFlush();
}
} catch ( Exception e ) {
if ( e.getMessage().indexOf("404") != -1 ){
_Session.setStatus( 404 );
return;
}else{
cfEngine.log( e.getMessage() );
throw newRunTimeException( e.getMessage() + "; key=" + key + "; bucket=" + bucket );
}
}
}
private void enableCustomerEncryption(PutObjectRequest uploadRequest) {
SSECustomerKey sseKey = new SSECustomerKey(mConfig.getAwsSseCustomerKey());
uploadRequest.withSSECustomerKey(sseKey);
}
@Override
public void configurePutObjectRequest(PutObjectRequest request, ObjectMetadata objectMetadata, String keyValue) {
SSECustomerKey customerKey = new SSECustomerKey(keyValue);
request.setSSECustomerKey(customerKey);
}
@Override
public void configureInitiateMultipartUploadRequest(InitiateMultipartUploadRequest request, ObjectMetadata objectMetadata, String keyValue) {
SSECustomerKey customerKey = new SSECustomerKey(keyValue);
request.setSSECustomerKey(customerKey);
}
@Override
public void configureGetObjectRequest(GetObjectRequest request, ObjectMetadata objectMetadata, String keyValue) {
SSECustomerKey customerKey = new SSECustomerKey(keyValue);
request.setSSECustomerKey(customerKey);
}
@Override
public void configureUploadPartRequest(UploadPartRequest request, ObjectMetadata objectMetadata, String keyValue) {
SSECustomerKey customerKey = new SSECustomerKey(keyValue);
request.setSSECustomerKey(customerKey);
}
void setSSECustomerKey(SSECustomerKey value);