org.elasticsearch.client.transport.TransportClient.admin()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(19.0k)|赞(0)|评价(0)|浏览(145)

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

TransportClient.admin介绍

暂无

代码示例

代码示例来源：origin: brianfrankcooper/YCSB

private void refreshIfNeeded() {
 if (isRefreshNeeded) {
  final boolean refresh;
  synchronized (this) {
   if (isRefreshNeeded) {
    refresh = true;
    isRefreshNeeded = false;
   } else {
    refresh = false;
   }
  }
  if (refresh) {
   client.admin().indices().refresh(new RefreshRequest()).actionGet();
  }
 }
}

代码示例来源：origin: prestodb/presto

private String[] getIndices(TransportClient client, GetIndexRequest request)
{
  try {
    return retry()
        .maxAttempts(maxAttempts)
        .exponentialBackoff(maxRetryTime)
        .run("getIndices", () -> client.admin()
            .indices()
            .getIndex(request)
            .actionGet(requestTimeout.toMillis())
            .getIndices());
  }
  catch (Exception e) {
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: prestodb/presto

private ImmutableOpenMap<String, ImmutableOpenMap<String, MappingMetaData>> getMappings(TransportClient client, GetMappingsRequest request)
{
  try {
    return retry()
        .maxAttempts(maxAttempts)
        .exponentialBackoff(maxRetryTime)
        .run("getMappings", () -> client.admin()
            .indices()
            .getMappings(request)
            .actionGet(requestTimeout.toMillis())
            .getMappings());
  }
  catch (Exception e) {
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: alibaba/canal

ImmutableOpenMap<String, MappingMetaData> mappings;
try {
  mappings = transportClient.admin()
    .cluster()
    .prepareState()

代码示例来源：origin: apache/incubator-gobblin

@Override
public void recreateIndex(String indexName)
  throws IOException {
 DeleteIndexRequestBuilder dirBuilder = transportClient.admin().indices().prepareDelete(indexName);
 try {
  DeleteIndexResponse diResponse = dirBuilder.execute().actionGet();
 } catch (IndexNotFoundException ie) {
  System.out.println("Index not found... that's ok");
 }
 CreateIndexRequestBuilder cirBuilder = transportClient.admin().indices().prepareCreate(indexName);
 CreateIndexResponse ciResponse = cirBuilder.execute().actionGet();
 Assert.assertTrue(ciResponse.isAcknowledged(), "Create index succeeeded");
}

代码示例来源：origin: prestodb/presto

private ClusterSearchShardsResponse getSearchShardsResponse(TransportClient client, ClusterSearchShardsRequest request)
{
  try {
    return retry()
        .maxAttempts(maxAttempts)
        .exponentialBackoff(maxRetryTime)
        .run("getSearchShardsResponse", () -> client.admin()
            .cluster()
            .searchShards(request)
            .actionGet(requestTimeout.toMillis()));
  }
  catch (Exception e) {
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: SonarSource/sonarqube

@Override
public ClusterHealthStatus getClusterHealthStatus() {
 return getTransportClient().admin().cluster()
  .health(new ClusterHealthRequest().waitForStatus(ClusterHealthStatus.YELLOW).timeout(timeValueSeconds(30)))
  .actionGet().getStatus();
}

代码示例来源：origin: floragunncom/search-guard

@Test
public void testTransportClientImpersonationWildcard() throws Exception {
  final Settings settings = Settings.builder()
      .putList("searchguard.authcz.impersonation_dn.CN=spock,OU=client,O=client,L=Test,C=DE", "*")
      .build();
  setup(settings);
  Settings tcSettings = Settings.builder()
      .put("searchguard.ssl.transport.keystore_filepath", FileHelper.getAbsoluteFilePathFromClassPath("spock-keystore.jks"))
      .put(SSLConfigConstants.SEARCHGUARD_SSL_TRANSPORT_KEYSTORE_ALIAS,"spock")
      .put("path.home", ".")
      .put("request.headers.sg_impersonate_as", "worf")
      .build();
  try (TransportClient tc = getInternalTransportClient(clusterInfo, tcSettings)) {
    NodesInfoRequest nir = new NodesInfoRequest();
    Assert.assertEquals(clusterInfo.numNodes, tc.admin().cluster().nodesInfo(nir).actionGet().getNodes().size());
  }        
}

代码示例来源：origin: floragunncom/search-guard

@Test
public void testAdvancedMapping() throws Exception {
  setup(Settings.EMPTY, new DynamicSgConfig(), Settings.EMPTY, true, ClusterConfiguration.DEFAULT);
  try (TransportClient tc = getInternalTransportClient(this.clusterInfo, Settings.EMPTY)) {
    tc.admin().indices().create(new CreateIndexRequest("myindex1")
    .mapping("mytype1", FileHelper.loadFile("mapping1.json"), XContentType.JSON)).actionGet();
    tc.admin().indices().create(new CreateIndexRequest("myindex2")
    .mapping("mytype2", FileHelper.loadFile("mapping2.json"), XContentType.JSON)).actionGet();
    tc.admin().indices().create(new CreateIndexRequest("myindex3")
    .mapping("mytype3", FileHelper.loadFile("mapping3.json"), XContentType.JSON)).actionGet();
    tc.admin().indices().create(new CreateIndexRequest("myindex4")
    .mapping("mytype4", FileHelper.loadFile("mapping4.json"), XContentType.JSON)).actionGet();
  }
  RestHelper rh = nonSslRestHelper();
  System.out.println("############ write into mapping 1");
  String data1 = FileHelper.loadFile("data1.json");
  System.out.println(rh.executePutRequest("myindex1/mytype1/1?refresh", data1, encodeBasicHeader("nagilum", "nagilum")));
  System.out.println(rh.executePutRequest("myindex1/mytype1/1?refresh", data1, encodeBasicHeader("nagilum", "nagilum")));
  System.out.println("############ write into mapping 2");
  System.out.println(rh.executePutRequest("myindex2/mytype2/2?refresh", data1, encodeBasicHeader("nagilum", "nagilum")));
  System.out.println(rh.executePutRequest("myindex2/mytype2/2?refresh", data1, encodeBasicHeader("nagilum", "nagilum")));
  System.out.println("############ write into mapping 3");
  String parent = FileHelper.loadFile("data2.json");
  String child = FileHelper.loadFile("data3.json");
  System.out.println(rh.executePutRequest("myindex3/mytype3/1?refresh", parent, encodeBasicHeader("nagilum", "nagilum")));
  System.out.println(rh.executePutRequest("myindex3/mytype3/2?routing=1&refresh", child, encodeBasicHeader("nagilum", "nagilum")));
  System.out.println("############ write into mapping 4");
  System.out.println(rh.executePutRequest("myindex4/mytype4/1?refresh", parent, encodeBasicHeader("nagilum", "nagilum")));
  System.out.println(rh.executePutRequest("myindex4/mytype4/2?routing=1&refresh", child, encodeBasicHeader("nagilum", "nagilum")));
}

代码示例来源：origin: testcontainers/testcontainers-java

@Test
public void transportClientClusterHealth() {
  try (ElasticsearchContainer container = new ElasticsearchContainer()) {
    container.start();
    TransportAddress transportAddress = new TransportAddress(container.getTcpHost());
    String expectedClusterName = "docker-cluster";
    Settings settings = Settings.builder().put("cluster.name", expectedClusterName).build();
    try (TransportClient transportClient = new PreBuiltTransportClient(settings)
      .addTransportAddress(transportAddress)) {
      ClusterHealthResponse healths = transportClient.admin().cluster().prepareHealth().get();
      String clusterName = healths.getClusterName();
      assertThat(clusterName, is(expectedClusterName));
    }
  }
}

代码示例来源：origin: floragunncom/search-guard

@Test
public void testTransportClientImpersonationWildcardUsernameAttribute() throws Exception {
  final Settings settings = Settings.builder()
      .putList("searchguard.authcz.impersonation_dn.CN=spock,OU=client,O=client,L=Test,C=DE", "*")
      .build();
  setup(Settings.EMPTY, new DynamicSgConfig().setSgConfig("sg_config_transport_username.yml")
      .setSgRolesMapping("sg_roles_mapping_transport_username.yml")
      .setSgInternalUsers("sg_internal_users_transport_username.yml")
      , settings);
  
  Settings tcSettings = Settings.builder()
      .put("searchguard.ssl.transport.keystore_filepath", FileHelper.getAbsoluteFilePathFromClassPath("spock-keystore.jks"))
      .put(SSLConfigConstants.SEARCHGUARD_SSL_TRANSPORT_KEYSTORE_ALIAS,"spock")
      .put("path.home", ".")
      .put("request.headers.sg_impersonate_as", "worf")
      .build();
  try (TransportClient tc = getInternalTransportClient(clusterInfo, tcSettings)) {
    NodesInfoRequest nir = new NodesInfoRequest();
    Assert.assertEquals(clusterInfo.numNodes, tc.admin().cluster().nodesInfo(nir).actionGet().getNodes().size());
  }        
}

代码示例来源：origin: floragunncom/search-guard

Assert.assertEquals(clusterInfo.numNodes, tc.admin().cluster().nodesInfo(new NodesInfoRequest()).actionGet().getNodes().size());
tc.index(new IndexRequest("searchguard").type("sg").setRefreshPolicy(RefreshPolicy.IMMEDIATE).id("internalusers").source("internalusers", FileHelper.readYamlContent("sg_internal_users_spock_add_roles.yml"))).actionGet();
ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();
Assert.assertEquals(clusterInfo.numNodes, tc.admin().cluster().nodesInfo(new NodesInfoRequest()).actionGet().getNodes().size());
tc.index(new IndexRequest("searchguard").type("sg").setRefreshPolicy(RefreshPolicy.IMMEDIATE).id("config").source("config", FileHelper.readYamlContent("sg_config_anon.yml"))).actionGet();
ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config"})).actionGet();

代码示例来源：origin: floragunncom/search-guard

@Test
public void testTransportClientImpersonation() throws Exception {
  final Settings settings = Settings.builder()
      .putList("searchguard.authcz.impersonation_dn.CN=spock,OU=client,O=client,L=Test,C=DE", "worf", "nagilum")
      .build();
  setup(settings);
  try (TransportClient tc = getInternalTransportClient()) {
    tc.index(new IndexRequest("starfleet").type("ships").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("{\"content\":1}", XContentType.JSON)).actionGet();
    ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();
    Assert.assertEquals(clusterInfo.numNodes, cur.getNodes().size());
  }
  Settings tcSettings = Settings.builder()
      .put("searchguard.ssl.transport.keystore_filepath", FileHelper.getAbsoluteFilePathFromClassPath("spock-keystore.jks"))
      .put(SSLConfigConstants.SEARCHGUARD_SSL_TRANSPORT_KEYSTORE_ALIAS,"spock")
      .put("path.home", ".")
      .put("request.headers.sg_impersonate_as", "worf")
      .build();
  try (TransportClient tc = getInternalTransportClient(clusterInfo, tcSettings)) {            
    NodesInfoRequest nir = new NodesInfoRequest();
    Assert.assertEquals(clusterInfo.numNodes, tc.admin().cluster().nodesInfo(nir).actionGet().getNodes().size());
  }
}

代码示例来源：origin: floragunncom/search-guard

@Test
public void testTransportClientImpersonationUsernameAttribute() throws Exception {
  final Settings settings = Settings.builder()
      .putList("searchguard.authcz.impersonation_dn.CN=spock,OU=client,O=client,L=Test,C=DE", "worf", "nagilum")
      .build();
  setup(Settings.EMPTY, new DynamicSgConfig().setSgConfig("sg_config_transport_username.yml")
      .setSgRolesMapping("sg_roles_mapping_transport_username.yml")
      .setSgInternalUsers("sg_internal_users_transport_username.yml")
      , settings);
  try (TransportClient tc = getInternalTransportClient()) {
    tc.index(new IndexRequest("starfleet").type("ships").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("{\"content\":1}", XContentType.JSON)).actionGet();
    ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();
    Assert.assertEquals(clusterInfo.numNodes, cur.getNodes().size());
  }
  Settings tcSettings = Settings.builder()
      .put("searchguard.ssl.transport.keystore_filepath", FileHelper.getAbsoluteFilePathFromClassPath("spock-keystore.jks"))
      .put(SSLConfigConstants.SEARCHGUARD_SSL_TRANSPORT_KEYSTORE_ALIAS,"spock")
      .put("path.home", ".")
      .put("request.headers.sg_impersonate_as", "worf")
      .build();
  try (TransportClient tc = getInternalTransportClient(clusterInfo, tcSettings)) {            
    NodesInfoRequest nir = new NodesInfoRequest();
    Assert.assertEquals(clusterInfo.numNodes, tc.admin().cluster().nodesInfo(nir).actionGet().getNodes().size());
  }
}

代码示例来源：origin: floragunncom/search-guard

tc.index(new IndexRequest("esb-prod-5").type("doc").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("{\"content\":5}", XContentType.JSON)).actionGet();
tc.admin().indices().aliases(new IndicesAliasesRequest().addAliasAction(AliasActions.add().indices("esb-prod-1","esb-prod-2","esb-prod-3","esb-prod-4","esb-prod-5").alias("esb-prod-all"))).actionGet();
tc.admin().indices().aliases(new IndicesAliasesRequest().addAliasAction(AliasActions.add().indices("esb-prod-1").alias("esb-alias-1"))).actionGet();
tc.admin().indices().aliases(new IndicesAliasesRequest().addAliasAction(AliasActions.add().indices("esb-prod-2").alias("esb-alias-2"))).actionGet();
tc.admin().indices().aliases(new IndicesAliasesRequest().addAliasAction(AliasActions.add().indices("esb-prod-3").alias("esb-alias-3"))).actionGet();
tc.admin().indices().aliases(new IndicesAliasesRequest().addAliasAction(AliasActions.add().indices("esb-prod-4").alias("esb-alias-4"))).actionGet();
tc.admin().indices().aliases(new IndicesAliasesRequest().addAliasAction(AliasActions.add().indices("esb-prod-5").alias("esb-alias-5"))).actionGet();

代码示例来源：origin: floragunncom/search-guard

@Test
public void test557() throws Exception {
  final Settings settings = Settings.builder()
      .put(ConfigConstants.SEARCHGUARD_ROLES_MAPPING_RESOLUTION, "BOTH")
      .build();
  setup(Settings.EMPTY, new DynamicSgConfig(), settings);
  
  try (TransportClient tc = getInternalTransportClient(this.clusterInfo, Settings.EMPTY)) {
    
    tc.admin().indices().create(new CreateIndexRequest("copysf")).actionGet();
    
    tc.index(new IndexRequest("vulcangov").type("kolinahr").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("{\"content\":1}", XContentType.JSON)).actionGet();
         tc.index(new IndexRequest("starfleet").type("ships").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("{\"content\":1}", XContentType.JSON)).actionGet();
         tc.index(new IndexRequest("starfleet_academy").type("students").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("{\"content\":1}", XContentType.JSON)).actionGet();
    
  }
  
  final RestHelper rh = nonSslRestHelper();
  HttpResponse res = rh.executePostRequest("/*/_search", "{\"size\":0,\"aggs\":{\"indices\":{\"terms\":{\"field\":\"_index\",\"size\":10}}}}", encodeBasicHeader("nagilum", "nagilum"));
  System.out.println(res.getBody());
  Assert.assertEquals(HttpStatus.SC_OK, res.getStatusCode());  
  Assert.assertTrue(res.getBody().contains("starfleet_academy"));
  res = rh.executePostRequest("/*/_search", "{\"size\":0,\"aggs\":{\"indices\":{\"terms\":{\"field\":\"_index\",\"size\":10}}}}", encodeBasicHeader("557", "nagilum"));
  System.out.println(res.getBody());
  Assert.assertEquals(HttpStatus.SC_OK, res.getStatusCode());  
  Assert.assertTrue(res.getBody().contains("starfleet_academy"));  
}

代码示例来源：origin: floragunncom/search-guard

tc.admin().indices().aliases(new IndicesAliasesRequest().addAliasAction(AliasActions.add().alias("alias1").filter(QueryBuilders.termQuery("_type", "type1")).index("theindex"))).actionGet();
tc.admin().indices().aliases(new IndicesAliasesRequest().addAliasAction(AliasActions.add().alias("alias2").filter(QueryBuilders.termQuery("_type", "type2")).index("theindex"))).actionGet();
tc.admin().indices().aliases(new IndicesAliasesRequest().addAliasAction(AliasActions.add().alias("alias3").filter(QueryBuilders.termQuery("_type", "type2")).index("otherindex"))).actionGet();

代码示例来源：origin: floragunncom/search-guard

tc.admin().cluster().nodesInfo(new NodesInfoRequest()).actionGet().getNodes().size());
  tc.admin().indices().create(new CreateIndexRequest("searchguard")).actionGet();
} catch (Exception e) {

代码示例来源：origin: floragunncom/search-guard

tc.index(new IndexRequest("testsnap6").type("kolinahr").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("{\"content\":1}", XContentType.JSON)).actionGet();
tc.admin().cluster().putRepository(new PutRepositoryRequest("bckrepo").type("fs").settings(Settings.builder().put("location", repositoryPath.getRoot().getAbsolutePath() + "/bckrepo"))).actionGet();

代码示例来源：origin: floragunncom/search-guard

@Test
public void testAliasResolution() throws Exception {
  final Settings settings = Settings.builder()
      .build();
  setup(settings);
  final RestHelper rh = nonSslRestHelper();
  try (TransportClient tc = getInternalTransportClient()) {                    
    tc.index(new IndexRequest("concreteindex-1").type("doc").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("{\"content\":1}", XContentType.JSON)).actionGet();                
    tc.admin().indices().aliases(new IndicesAliasesRequest().addAliasAction(AliasActions.add().indices("concreteindex-1").alias("calias-1"))).actionGet();
    tc.index(new IndexRequest(".kibana-6").type("doc").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("{\"content\":1}", XContentType.JSON)).actionGet();                
    tc.admin().indices().aliases(new IndicesAliasesRequest().addAliasAction(AliasActions.add().indices(".kibana-6").alias(".kibana"))).actionGet();
  }
  Assert.assertEquals(HttpStatus.SC_OK, rh.executeGetRequest("calias-1/_search?pretty", encodeBasicHeader("aliastest", "nagilum")).getStatusCode());
  Assert.assertEquals(HttpStatus.SC_OK, rh.executeGetRequest("calias-*/_search?pretty", encodeBasicHeader("aliastest", "nagilum")).getStatusCode());
  Assert.assertEquals(HttpStatus.SC_OK, rh.executeGetRequest("*kibana/_search?pretty", encodeBasicHeader("aliastest", "nagilum")).getStatusCode());
  Assert.assertEquals(HttpStatus.SC_OK, rh.executeGetRequest(".ki*ana/_search?pretty", encodeBasicHeader("aliastest", "nagilum")).getStatusCode());
  Assert.assertEquals(HttpStatus.SC_OK, rh.executeGetRequest(".kibana/_search?pretty", encodeBasicHeader("aliastest", "nagilum")).getStatusCode());
}

内容来源于网络，如有侵权，请联系作者删除！

TransportClient

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    TransportClient类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com