本文整理汇总了Java中com.amazonaws.services.cloudsearchv2.AmazonCloudSearchClient类的典型用法代码示例。如果您正苦于以下问题：Java AmazonCloudSearchClient类的具体用法？Java AmazonCloudSearchClient怎么用？Java AmazonCloudSearchClient使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
AmazonCloudSearchClient类属于com.amazonaws.services.cloudsearchv2包，在下文中一共展示了AmazonCloudSearchClient类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: cloudSearchDomainAsyncClients
import com.amazonaws.services.cloudsearchv2.AmazonCloudSearchClient; //导入依赖的package包/类
@Bean
public Map<String, AmazonCloudSearchDomainAsyncClient> cloudSearchDomainAsyncClients(
AmazonCloudSearchClient cloudSearchClient, AWSCredentialsProvider awsCredentialsProvider) {
DescribeDomainsResult describeDomainsResult = cloudSearchClient.describeDomains();
List<DomainStatus> domainStatusList = describeDomainsResult.getDomainStatusList();
Map<String, AmazonCloudSearchDomainAsyncClient> domainClients = new HashMap<>(domainStatusList.size());
for (DomainStatus domainStatus : domainStatusList) {
log.debug("domainStatus: {}", domainStatus);
String domainName = domainStatus.getDomainName();
if (domainStatus.isCreated() && !domainStatus.isDeleted()) {
log.info("creating AmazonCloudSearchDomainClient for {} domain", domainName);
ServiceEndpoint serviceEndpoint = domainStatus.getDocService();
AmazonCloudSearchDomainAsyncClient domainClient = new AmazonCloudSearchDomainAsyncClient(
awsCredentialsProvider, client)
.withEndpoint(serviceEndpoint.getEndpoint());
domainClients.put(domainName, domainClient);
} else {
log.info("skipping domain {}: created = {}, deleted = {}", domainName, domainStatus.isCreated(),
domainStatus.isDeleted());
}
}
return domainClients;
}
开发者ID:efenderbosch，项目名称:spring-boot-aws-cloudsearch，代码行数:24，代码来源:CloudSearchConfig.java
示例2: CloudSearchIndexer
import com.amazonaws.services.cloudsearchv2.AmazonCloudSearchClient; //导入依赖的package包/类
public CloudSearchIndexer(AWSCredentialsProvider creds, String index) {
// Find the Cloud Search Domain endpoint
AmazonCloudSearchClient cloudsearch = new AmazonCloudSearchClient(creds);
for (DomainStatus domain : cloudsearch.describeDomains().getDomainStatusList()) {
Logger.Info(domain.getDomainName());
if (domain.getDomainName().equals(index))
searchClient = new AmazonCloudSearchDomainClient(creds)
.withEndpoint(domain.getDocService().getEndpoint());
}
if (searchClient == null) {
Logger.Info("Could not find Cloud Search index %s, aborting.", index);
throw new IllegalArgumentException("Unrecognized index.");
}
}
开发者ID:jhy，项目名称:RekognitionS3Batch，代码行数:15，代码来源:CloudSearchIndexer.java
示例3: scanCloudSearch
import com.amazonaws.services.cloudsearchv2.AmazonCloudSearchClient; //导入依赖的package包/类
/**
* Collect data for CloudSearch.
*
* @param stats
* current statistics object.
* @param account
* currently used credentials object.
* @param region
* currently used aws region.
*/
public static void scanCloudSearch(AwsStats stats, AwsAccount account, Regions region) {
LOG.debug("Scan for CloudSearch in region " + region.getName() + " in account " + account.getAccountId());
try {
AmazonCloudSearchClient cs = new AmazonCloudSearchClient(account.getCredentials());
cs.setRegion(Region.getRegion(region));
int totalDomains = 0;
for (DomainStatus ds : cs.describeDomains().getDomainStatusList()) {
AwsResource res = new AwsResource(ds.getDomainName(), account.getAccountId(), AwsResourceType.CloudSearch, region);
res.addInfo("Endpoint", ds.getSearchService().getEndpoint());
res.addInfo("SearchInstanceType", ds.getSearchInstanceType());
res.addInfo("SearchInstanceCount", ds.getSearchInstanceCount());
res.addInfo("ARN", ds.getARN());
stats.add(res);
totalDomains++;
}
LOG.info(totalDomains + " CloudSearch domains in region " + region.getName() + " in account " + account.getAccountId());
} catch (AmazonServiceException ase) {
if (ase.getErrorCode().contains("AccessDenied")) {
LOG.info("Access denied for CloudSearch in region " + region.getName() + " in account " + account.getAccountId());
} else {
LOG.error("Exception of CloudSearch: " + ase.getMessage());
}
} catch (Exception ex) {
LOG.error("Exception of CloudSearch: " + ex.getMessage());
}
}
开发者ID:janloeffler，项目名称:aws-utilization-monitor，代码行数:40，代码来源:AwsScan.java
示例4: open
import com.amazonaws.services.cloudsearchv2.AmazonCloudSearchClient; //导入依赖的package包/类
@Override
public void open(JobConf job, String name) throws IOException {
LOG.debug("CloudSearchIndexWriter.open() name={} ", name);
maxDocsInBatch = job.getInt(CloudSearchConstants.MAX_DOCS_BATCH, -1);
buffer = new StringBuffer(MAX_SIZE_BATCH_BYTES).append('[');
dumpBatchFilesToTemp = job.getBoolean(CloudSearchConstants.BATCH_DUMP,
false);
if (dumpBatchFilesToTemp) {
// only dumping to local file
// no more config required
return;
}
String endpoint = job.get(CloudSearchConstants.ENDPOINT);
if (StringUtils.isBlank(endpoint)) {
throw new RuntimeException("endpoint not set for CloudSearch");
}
AmazonCloudSearchClient cl = new AmazonCloudSearchClient();
if (StringUtils.isNotBlank(regionName)) {
cl.setRegion(RegionUtils.getRegion(regionName));
}
String domainName = null;
// retrieve the domain name
DescribeDomainsResult domains = cl
.describeDomains(new DescribeDomainsRequest());
Iterator<DomainStatus> dsiter = domains.getDomainStatusList().iterator();
while (dsiter.hasNext()) {
DomainStatus ds = dsiter.next();
if (ds.getDocService().getEndpoint().equals(endpoint)) {
domainName = ds.getDomainName();
break;
}
}
// check domain name
if (StringUtils.isBlank(domainName)) {
throw new RuntimeException(
"No domain name found for CloudSearch endpoint");
}
DescribeIndexFieldsResult indexDescription = cl.describeIndexFields(
new DescribeIndexFieldsRequest().withDomainName(domainName));
for (IndexFieldStatus ifs : indexDescription.getIndexFields()) {
String indexname = ifs.getOptions().getIndexFieldName();
String indextype = ifs.getOptions().getIndexFieldType();
LOG.info("CloudSearch index name {} of type {}", indexname, indextype);
csfields.put(indexname, indextype);
}
client = new AmazonCloudSearchDomainClient();
client.setEndpoint(endpoint);
}
开发者ID:jorcox，项目名称:GeoCrawler，代码行数:63，代码来源:CloudSearchIndexWriter.java
示例5: AmazonCloudSearchFactory
import com.amazonaws.services.cloudsearchv2.AmazonCloudSearchClient; //导入依赖的package包/类
public AmazonCloudSearchFactory() {
client = new AmazonCloudSearchClient();
}
开发者ID:coding4people，项目名称:mosquito-report-api，代码行数:4，代码来源:AmazonCloudSearchFactory.java
示例6: prepare
import com.amazonaws.services.cloudsearchv2.AmazonCloudSearchClient; //导入依赖的package包/类
@SuppressWarnings({ "rawtypes", "unchecked" })
@Override
public void prepare(Map conf, TopologyContext context,
OutputCollector collector) {
super.prepare(conf, context, collector);
_collector = collector;
this.eventCounter = context.registerMetric("CloudSearchIndexer",
new MultiCountMetric(), 10);
maxTimeBuffered = ConfUtils.getInt(conf,
CloudSearchConstants.MAX_TIME_BUFFERED, 10);
maxDocsInBatch = ConfUtils.getInt(conf,
CloudSearchConstants.MAX_DOCS_BATCH, -1);
buffer = new StringBuffer(MAX_SIZE_BATCH_BYTES).append('[');
dumpBatchFilesToTemp = ConfUtils.getBoolean(conf,
"cloudsearch.batch.dump", false);
if (dumpBatchFilesToTemp) {
// only dumping to local file
// no more config required
return;
}
String endpoint = ConfUtils.getString(conf, "cloudsearch.endpoint");
if (StringUtils.isBlank(endpoint)) {
String message = "Missing CloudSearch endpoint";
LOG.error(message);
throw new RuntimeException(message);
}
String regionName = ConfUtils.getString(conf,
CloudSearchConstants.REGION);
AmazonCloudSearchClient cl = new AmazonCloudSearchClient();
if (StringUtils.isNotBlank(regionName)) {
cl.setRegion(RegionUtils.getRegion(regionName));
}
String domainName = null;
// retrieve the domain name
DescribeDomainsResult domains = cl
.describeDomains(new DescribeDomainsRequest());
Iterator<DomainStatus> dsiter = domains.getDomainStatusList()
.iterator();
while (dsiter.hasNext()) {
DomainStatus ds = dsiter.next();
if (ds.getDocService().getEndpoint().equals(endpoint)) {
domainName = ds.getDomainName();
break;
}
}
// check domain name
if (StringUtils.isBlank(domainName)) {
throw new RuntimeException(
"No domain name found for CloudSearch endpoint");
}
DescribeIndexFieldsResult indexDescription = cl
.describeIndexFields(new DescribeIndexFieldsRequest()
.withDomainName(domainName));
for (IndexFieldStatus ifs : indexDescription.getIndexFields()) {
String indexname = ifs.getOptions().getIndexFieldName();
String indextype = ifs.getOptions().getIndexFieldType();
LOG.info("CloudSearch index name {} of type {}", indexname,
indextype);
csfields.put(indexname, indextype);
}
client = new AmazonCloudSearchDomainClient();
client.setEndpoint(endpoint);
}
开发者ID:DigitalPebble，项目名称:storm-crawler，代码行数:79，代码来源:CloudSearchIndexerBolt.java
注：本文中的com.amazonaws.services.cloudsearchv2.AmazonCloudSearchClient类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论