com.amazonaws.services.s3.AmazonS3ClientBuilder.withPathStyleAccessEnabled()方法的使用及代码示例

x33g5p2x  于2022-01-15 转载在 其他  
字(7.6k)|赞(0)|评价(0)|浏览(583)

本文整理了Java中com.amazonaws.services.s3.AmazonS3ClientBuilder.withPathStyleAccessEnabled()方法的一些代码示例,展示了AmazonS3ClientBuilder.withPathStyleAccessEnabled()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AmazonS3ClientBuilder.withPathStyleAccessEnabled()方法的具体详情如下:
包路径:com.amazonaws.services.s3.AmazonS3ClientBuilder
类名称:AmazonS3ClientBuilder
方法名:withPathStyleAccessEnabled

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 {

相关文章