本文整理了Java中com.amazonaws.services.s3.AmazonS3ClientBuilder.withPathStyleAccessEnabled()
方法的一些代码示例,展示了AmazonS3ClientBuilder.withPathStyleAccessEnabled()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AmazonS3ClientBuilder.withPathStyleAccessEnabled()
方法的具体详情如下:
包路径:com.amazonaws.services.s3.AmazonS3ClientBuilder
类名称:AmazonS3ClientBuilder
方法名:withPathStyleAccessEnabled
暂无
代码示例来源:origin: apache/incubator-druid
@Provides
@LazySingleton
public ServerSideEncryptingAmazonS3 getAmazonS3Client(
AWSCredentialsProvider provider,
AWSProxyConfig proxyConfig,
AWSEndpointConfig endpointConfig,
AWSClientConfig clientConfig,
S3StorageConfig storageConfig
)
{
final ClientConfiguration configuration = new ClientConfigurationFactory().getConfig();
final Protocol protocol = determineProtocol(clientConfig, endpointConfig);
final AmazonS3ClientBuilder builder = AmazonS3Client
.builder()
.withCredentials(provider)
.withClientConfiguration(setProxyConfig(configuration, proxyConfig).withProtocol(protocol))
.withChunkedEncodingDisabled(clientConfig.isDisableChunkedEncoding())
.withPathStyleAccessEnabled(clientConfig.isEnablePathStyleAccess())
.withForceGlobalBucketAccessEnabled(clientConfig.isForceGlobalBucketAccessEnabled());
if (StringUtils.isNotEmpty(endpointConfig.getUrl())) {
builder.setEndpointConfiguration(
new EndpointConfiguration(endpointConfig.getUrl(), endpointConfig.getSigningRegion())
);
}
return new ServerSideEncryptingAmazonS3(builder.build(), storageConfig.getServerSideEncryption());
}
代码示例来源:origin: neo4j-contrib/neo4j-apoc-procedures
public S3Aws(S3Params s3Params, String region){
s3Client = AmazonS3ClientBuilder.standard()
.withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials(s3Params.getAccessKey(), s3Params.getSecretKey())))
.withClientConfiguration(S3URLConnection.buildClientConfig())
.withPathStyleAccessEnabled(true)
.withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(s3Params.getEndpoint(), region))
.build();
}
代码示例来源:origin: jenkinsci/pipeline-aws-plugin
protected AmazonS3ClientBuilder createAmazonS3ClientBuilder() {
return AmazonS3ClientBuilder.standard()
.withPathStyleAccessEnabled(this.isPathStyleAccessEnabled())
.withPayloadSigningEnabled(this.isPayloadSigningEnabled());
}
}
代码示例来源:origin: anylogic/alogic
private void initS3()
{
credentials = new BasicAWSCredentials(accessKey, secretKey);
ClientConfiguration clientConfiguration = new ClientConfiguration();
clientConfiguration.setProtocol(Protocol.HTTP);
s3 = AmazonS3ClientBuilder.standard()
.withPathStyleAccessEnabled(true)
.withCredentials(this)
.withClientConfiguration(clientConfiguration)
.withEndpointConfiguration(new EndpointConfiguration(endpoint, region))
.build();
}
代码示例来源:origin: automatictester/lightning
public static MockedS3Client createInstance(String region) {
AwsClientBuilder.EndpointConfiguration endpointConfiguration = new AwsClientBuilder.EndpointConfiguration(S3_MOCK_URL, region);
AmazonS3 client = AmazonS3ClientBuilder
.standard()
.withPathStyleAccessEnabled(true)
.withEndpointConfiguration(endpointConfiguration)
.build();
return new MockedS3Client(client);
}
代码示例来源:origin: IQSS/dataverse
public S3AccessIO(T dvObject, DataAccessRequest req) {
super(dvObject, req);
this.setIsLocalFile(false);
try {
// get a standard client, using the standard way of configuration the credentials, etc.
AmazonS3ClientBuilder s3CB = AmazonS3ClientBuilder.standard();
// if the admin has set a system property (see below) we use this endpoint URL instead of the standard ones.
if (!s3CEUrl.isEmpty()) {
s3CB.setEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(s3CEUrl, s3CERegion));
}
// some custom S3 implementations require "PathStyleAccess" as they us a path, not a subdomain. default = false
s3CB.withPathStyleAccessEnabled(s3pathStyleAccess);
// let's build the client :-)
this.s3 = s3CB.build();
} catch (Exception e) {
throw new AmazonClientException(
"Cannot instantiate a S3 client using; check your AWS credentials and region",
e);
}
}
代码示例来源:origin: opendedup/sdfs
builder.withPathStyleAccessEnabled(Boolean.parseBoolean(config.getAttribute("disableDNSBucket")));
System.out.println("disableDNSBucket=" + Boolean.parseBoolean(config.getAttribute("disableDNSBucket")));
代码示例来源:origin: georocket/georocket
builder = builder.withPathStyleAccessEnabled(pathStyleAccess);
代码示例来源:origin: uber/marmaray
@Override
protected AmazonS3 getS3Connection() {
this.endpoint = new EndpointConfiguration(S3_TEST_URL, S3_TEST_REGION);
AmazonS3 s3ClientTest = AmazonS3ClientBuilder
.standard()
.withPathStyleAccessEnabled(true)
.withEndpointConfiguration(endpoint)
.withCredentials(new AWSStaticCredentialsProvider(new AnonymousAWSCredentials()))
.build();
s3ClientTest.createBucket(S3_TEST_BUCKET_NAME);
return spy(s3ClientTest);
}
}
代码示例来源:origin: org.apache.druid.extensions/druid-s3-extensions
@Provides
@LazySingleton
public ServerSideEncryptingAmazonS3 getAmazonS3Client(
AWSCredentialsProvider provider,
AWSProxyConfig proxyConfig,
AWSEndpointConfig endpointConfig,
AWSClientConfig clientConfig,
S3StorageConfig storageConfig
)
{
final ClientConfiguration configuration = new ClientConfigurationFactory().getConfig();
final AmazonS3ClientBuilder builder = AmazonS3Client
.builder()
.withCredentials(provider)
.withClientConfiguration(setProxyConfig(configuration, proxyConfig))
.withChunkedEncodingDisabled(clientConfig.isDisableChunkedEncoding())
.withPathStyleAccessEnabled(clientConfig.isEnablePathStyleAccess())
.withForceGlobalBucketAccessEnabled(clientConfig.isForceGlobalBucketAccessEnabled());
if (StringUtils.isNotEmpty(endpointConfig.getUrl())) {
builder.setEndpointConfiguration(
new EndpointConfiguration(endpointConfig.getUrl(), endpointConfig.getSigningRegion())
);
}
return new ServerSideEncryptingAmazonS3(
builder.build(),
storageConfig.getServerSideEncryption()
);
}
代码示例来源:origin: uber/marmaray
private AmazonS3 getMockS3Connection() {
final EndpointConfiguration endpoint = new EndpointConfiguration(S3_TEST_URL, S3_TEST_REGION);
AmazonS3 s3ClientTest = AmazonS3ClientBuilder
.standard()
.withPathStyleAccessEnabled(true)
.withEndpointConfiguration(endpoint)
.withCredentials(new AWSStaticCredentialsProvider(new AnonymousAWSCredentials()))
.build();
return s3ClientTest;
}
}
代码示例来源:origin: org.seaborne.rdf-delta/rdf-delta-server-extra
public static AmazonS3 buildS3(LocalServerConfig configuration) {
String region = configuration.getProperty(pRegion);
String endpoint = configuration.getProperty(pEndpoint);
String credentialsFile = configuration.getProperty(pCredentialFile);
String credentialsProfile = configuration.getProperty(pCredentialProfile);
AmazonS3ClientBuilder builder = AmazonS3ClientBuilder.standard();
if ( endpoint == null )
builder.withRegion(region);
else {
// Needed for S3mock
builder.withPathStyleAccessEnabled(true);
builder.withEndpointConfiguration(new EndpointConfiguration(endpoint, region));
builder.withCredentials(new AWSStaticCredentialsProvider(new AnonymousAWSCredentials()));
}
if ( credentialsFile != null )
builder.withCredentials(new ProfileCredentialsProvider(credentialsFile, credentialsProfile));
return builder.build();
}
代码示例来源:origin: io.konig/konig-camel-aws-s3
clientBuilder = clientBuilder.withRegion(Regions.valueOf(configuration.getRegion()));
clientBuilder = clientBuilder.withPathStyleAccessEnabled(configuration.isPathStyleAccess());
client = clientBuilder.build();
} else {
代码示例来源:origin: io.konig/konig-camel-aws-s3
clientBuilder = clientBuilder.withRegion(Regions.valueOf(configuration.getRegion()));
clientBuilder = clientBuilder.withPathStyleAccessEnabled(configuration.isPathStyleAccess());
client = clientBuilder.build();
} else {
clientBuilder = clientBuilder.withRegion(Regions.valueOf(configuration.getRegion()));
clientBuilder = clientBuilder.withPathStyleAccessEnabled(configuration.isPathStyleAccess());
client = clientBuilder.build();
} else {
内容来源于网络,如有侵权,请联系作者删除!