本文整理汇总了Java中com.amazonaws.services.s3.AmazonS3ClientBuilder.withCredentials方法的典型用法代码示例。如果您正苦于以下问题:Java AmazonS3ClientBuilder.withCredentials方法的具体用法?Java AmazonS3ClientBuilder.withCredentials怎么用?Java AmazonS3ClientBuilder.withCredentials使用的例子?那么恭喜您, 这里精选的方法代码示例或许可以为您提供帮助。您也可以进一步了解该方法所在类com.amazonaws.services.s3.AmazonS3ClientBuilder
的用法示例。
在下文中一共展示了AmazonS3ClientBuilder.withCredentials方法的8个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: buildAmazonS3ForRegion
import com.amazonaws.services.s3.AmazonS3ClientBuilder; //导入方法依赖的package包/类
private AmazonS3ClientBuilder buildAmazonS3ForRegion(AmazonS3 prototype, String region) {
AmazonS3ClientBuilder clientBuilder = AmazonS3ClientBuilder.standard();
AmazonS3Client target = getAmazonS3ClientFromProxy(prototype);
if (target != null) {
AWSCredentialsProvider awsCredentialsProvider = (AWSCredentialsProvider) ReflectionUtils.getField(this.credentialsProviderField, target);
clientBuilder.withCredentials(awsCredentialsProvider);
}
return clientBuilder.withRegion(region);
}
开发者ID:spring-cloud,项目名称:spring-cloud-aws,代码行数:12,代码来源:AmazonS3ClientFactory.java示例2: S3Reader
import com.amazonaws.services.s3.AmazonS3ClientBuilder; //导入方法依赖的package包/类
public S3Reader(Region region, String accessKey, String secretKey) {
AmazonS3ClientBuilder clientBuilder = AmazonS3ClientBuilder.standard();
clientBuilder.setRegion(region.getName());
if (!accessKey.isEmpty() && !secretKey.isEmpty()) {
clientBuilder.withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials(accessKey, secretKey)));
}
this.s3Client = clientBuilder.build();
}
开发者ID:sherzberg,项目名称:graylog-plugin-s3,代码行数:11,代码来源:S3Reader.java示例3: create
import com.amazonaws.services.s3.AmazonS3ClientBuilder; //导入方法依赖的package包/类
public AmazonS3 create(final BlobStoreConfiguration blobStoreConfiguration) {
AmazonS3ClientBuilder builder = AmazonS3ClientBuilder.standard();
String accessKeyId = blobStoreConfiguration.attributes(CONFIG_KEY).get(ACCESS_KEY_ID_KEY, String.class);
String secretAccessKey = blobStoreConfiguration.attributes(CONFIG_KEY).get(SECRET_ACCESS_KEY_KEY, String.class);
String region = blobStoreConfiguration.attributes(CONFIG_KEY).get(REGION_KEY, String.class);
if (!isNullOrEmpty(accessKeyId) && !isNullOrEmpty(secretAccessKey)) {
String sessionToken = blobStoreConfiguration.attributes(CONFIG_KEY).get(SESSION_TOKEN_KEY, String.class);
AWSCredentials credentials = buildCredentials(accessKeyId, secretAccessKey, sessionToken);
String assumeRole = blobStoreConfiguration.attributes(CONFIG_KEY).get(ASSUME_ROLE_KEY, String.class);
AWSCredentialsProvider credentialsProvider = buildCredentialsProvider(credentials, region, assumeRole);
builder = builder.withCredentials(credentialsProvider);
}
if (!isNullOrEmpty(region)) {
String endpoint = blobStoreConfiguration.attributes(CONFIG_KEY).get(ENDPOINT_KEY, String.class);
if (!isNullOrEmpty(endpoint)) {
builder = builder.withEndpointConfiguration(new AmazonS3ClientBuilder.EndpointConfiguration(endpoint, region));
} else {
builder = builder.withRegion(region);
}
}
return builder.build();
}
开发者ID:sonatype,项目名称:nexus-public,代码行数:29,代码来源:AmazonS3Factory.java示例4: configureTokenAuthentication
import com.amazonaws.services.s3.AmazonS3ClientBuilder; //导入方法依赖的package包/类
private static AmazonS3ClientBuilder configureTokenAuthentication(Environment environment, AmazonS3ClientBuilder builder) {
LOGGER.info("Using Token authentication");
final String key = environment.getProperty("content-service.store.s3.accessKey");
final String secret = environment.getProperty("content-service.store.s3.secretKey");
AWSCredentials awsCredentials = new BasicAWSCredentials(key, secret);
return builder.withCredentials(new StaticCredentialsProvider(awsCredentials));
}
开发者ID:Talend,项目名称:daikon,代码行数:8,代码来源:S3ContentServiceConfiguration.java示例5: getS3client
import com.amazonaws.services.s3.AmazonS3ClientBuilder; //导入方法依赖的package包/类
public static AmazonS3 getS3client(GoEnvironment env) {
AmazonS3ClientBuilder amazonS3ClientBuilder = AmazonS3ClientBuilder.standard();
if (env.has(AWS_REGION)) {
amazonS3ClientBuilder.withRegion(env.get(AWS_REGION));
}
if (env.hasAWSUseIamRole()) {
amazonS3ClientBuilder.withCredentials(new InstanceProfileCredentialsProvider(false));
} else if (env.has(AWS_ACCESS_KEY_ID) && env.has(AWS_SECRET_ACCESS_KEY)) {
BasicAWSCredentials basicCreds = new BasicAWSCredentials(env.get(AWS_ACCESS_KEY_ID), env.get(AWS_SECRET_ACCESS_KEY));
amazonS3ClientBuilder.withCredentials(new AWSStaticCredentialsProvider(basicCreds));
}
return amazonS3ClientBuilder.build();
}
开发者ID:indix,项目名称:gocd-s3-artifacts,代码行数:16,代码来源:S3ArtifactStore.java示例6: initClient
import com.amazonaws.services.s3.AmazonS3ClientBuilder; //导入方法依赖的package包/类
public static AmazonS3 initClient(String s3AccessKey, String s3SecretKey, String s3BucketRegion)
{
// equivalent to "defaultClient" (unless credentials &/or region are overridden)
AmazonS3ClientBuilder s3ClientBuilder = AmazonS3ClientBuilder.standard();
if ((s3AccessKey != null) || (s3SecretKey != null))
{
// override default credentials
s3ClientBuilder.withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials(s3AccessKey, s3SecretKey)));
}
if (s3BucketRegion != null)
{
// override default region
s3ClientBuilder.withRegion(s3BucketRegion);
}
AmazonS3 s3 = null;
try
{
s3 = s3ClientBuilder.build();
}
catch (AmazonClientException e)
{
if (e.getMessage().contains("Unable to find a region via the region provider chain"))
{
s3ClientBuilder.withRegion(DEFAULT_BUCKET_REGION);
s3 = s3ClientBuilder.build();
}
}
return s3;
}
开发者ID:Alfresco,项目名称:gytheio,代码行数:35,代码来源:S3ContentReferenceHandlerImpl.java示例7: configureEC2Authentication
import com.amazonaws.services.s3.AmazonS3ClientBuilder; //导入方法依赖的package包/类
private static AmazonS3ClientBuilder configureEC2Authentication(AmazonS3ClientBuilder builder) {
LOGGER.info("Using EC2 authentication");
return builder.withCredentials(new EC2ContainerCredentialsProviderWrapper());
}
开发者ID:Talend,项目名称:daikon,代码行数:5,代码来源:S3ContentServiceConfiguration.java示例8: S3Filer
import com.amazonaws.services.s3.AmazonS3ClientBuilder; //导入方法依赖的package包/类
public S3Filer(@Nonnull Config config, @Nonnull Access access) {
checkNotNull(config);
checkNotNull(access);
String url = config.getString("url");
int index = url.indexOf("://");
if (index > -1) {
index = url.indexOf("/", index + 3);
if (index > -1) {
url = url.substring(0, index);
}
}
uri = URI.create(url);
bucket = uri.getHost();
partSize = config.getInt("s3.partSize", 5 * 1024 * 1024);
tempDir = new File(config.getString("s3.tempDir", System.getProperty("java.io.tmpdir")));
service = Executors.newFixedThreadPool(config.getInt("s3.threads", 1));
AmazonS3ClientBuilder builder = AmazonS3ClientBuilder.standard();
String region = config.getString("aws.region", null);
if (region != null) {
builder.withRegion(region);
}
String key = config.getString("aws.key", null);
if (key != null) {
AmazonS3Exception exception = null;
int retries = config.getInt("aws.retries", 3);
for (int i = 0; i < retries + 1; i++) {
Response response = access.prompt(key + ".secret", key + ".secret: ", Type.MASKED);
try {
String secret = response.value();
builder.withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials(key, secret)));
AmazonS3 testS3 = builder.build();
testS3.listObjects(new ListObjectsRequest().withBucketName(bucket));
response.accept();
break;
} catch (AmazonS3Exception e) {
exception = e;
response.reject();
}
}
if (exception != null) {
throw exception;
}
}
s3 = builder.build();
}
开发者ID:lithiumtech,项目名称:flow,代码行数:55,代码来源:S3Filer.java本文标签属性:
示例:示例的拼音
代码:代码编程
java:java面试题
AmazonS3ClientBuilder:AmazonS3ClientBuilder
withCredentials:withCredentials