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

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

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

TransportClient.execute介绍

暂无

代码示例

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

final WhoAmIResponse whoAmIRes = tc.execute(WhoAmIAction.INSTANCE, new WhoAmIRequest()).actionGet();
System.out.println("Connected as "+whoAmIRes.getDn());
  tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();                
  final AcknowledgedResponse response = tc.admin().indices().updateSettings((new UpdateSettingsRequest(index).settings(indexSettings))).actionGet();
  System.out.println("Reload config on all nodes");
  tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();                
  System.out.println("Reload config on all nodes");
  System.exit(0);
  LicenseInfoResponse res = tc.execute(LicenseInfoAction.INSTANCE, new LicenseInfoRequest()).actionGet();                
  System.out.println(res.toString());
  System.exit(0);
      .put("index.auto_expand_replicas", replicaAutoExpand?"0-all":"false")
      .build();                
  tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();                
  final AcknowledgedResponse response = tc.admin().indices().updateSettings((new UpdateSettingsRequest(index).settings(indexSettings))).actionGet();
  System.out.println("Reload config on all nodes");
  ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{type})).actionGet();
ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();

代码示例来源：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, cur.getNodes().size());   
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();
Assert.assertEquals(clusterInfo.numNodes, cur.getNodes().size());

代码示例来源：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

@Test
public void testSingle() throws Exception {

  setup();

  try (TransportClient tc = getInternalTransportClient()) {          
    tc.index(new IndexRequest("shakespeare").type("type").id("1").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());
  }

  RestHelper rh = nonSslRestHelper();
  //sg_shakespeare -> picard

  HttpResponse resc = rh.executeGetRequest("shakespeare/_search", encodeBasicHeader("picard", "picard"));
  System.out.println(resc.getBody());
  Assert.assertEquals(HttpStatus.SC_OK, resc.getStatusCode());
  Assert.assertTrue(resc.getBody().contains("\"content\":1"));
  
  resc = rh.executeHeadRequest("shakespeare", encodeBasicHeader("picard", "picard"));
  Assert.assertEquals(HttpStatus.SC_OK, resc.getStatusCode());
  
}

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

@Test
public void testMultiRoleSpan() throws Exception {
  
  setup();
  final RestHelper rh = nonSslRestHelper();
  try (TransportClient tc = getInternalTransportClient()) {    
    tc.index(new IndexRequest("mindex_1").type("logs").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("{\"content\":1}", XContentType.JSON)).actionGet();
    tc.index(new IndexRequest("mindex_2").type("logs").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("{\"content\":2}", XContentType.JSON)).actionGet();
  }
  
  HttpResponse res = rh.executeGetRequest("/mindex_1,mindex_2/_search", encodeBasicHeader("mindex12", "nagilum"));
  System.out.println(res.getBody());
  Assert.assertEquals(HttpStatus.SC_FORBIDDEN, res.getStatusCode());
  Assert.assertFalse(res.getBody().contains("\"content\":1"));
  Assert.assertFalse(res.getBody().contains("\"content\":2"));
  
  try (TransportClient tc = getInternalTransportClient()) {                                       
    tc.index(new IndexRequest("searchguard").type("sg").id("config").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("config", FileHelper.readYamlContent("sg_config_multirolespan.yml"))).actionGet();
    ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config"})).actionGet();
    Assert.assertEquals(clusterInfo.numNodes, cur.getNodes().size());
  }
  
  res = rh.executeGetRequest("/mindex_1,mindex_2/_search", encodeBasicHeader("mindex12", "nagilum"));
  System.out.println(res.getBody());
  Assert.assertEquals(HttpStatus.SC_OK, res.getStatusCode());
  Assert.assertTrue(res.getBody().contains("\"content\":1"));
  Assert.assertTrue(res.getBody().contains("\"content\":2"));
  
}

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

ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();
Assert.assertEquals(clusterInfo.numNodes, cur.getNodes().size());

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

@Test
public void testWhoAmI() throws Exception {
  setup(Settings.EMPTY, new DynamicSgConfig().setSgInternalUsers("sg_internal_empty.yml")
      .setSgRoles("sg_roles_deny.yml"), Settings.EMPTY, true);
  
  try (TransportClient tc = getUserTransportClient(clusterInfo, "spock-keystore.jks", Settings.EMPTY)) {  
    WhoAmIResponse wres = tc.execute(WhoAmIAction.INSTANCE, new WhoAmIRequest()).actionGet();  
    System.out.println(wres);
    Assert.assertEquals(wres.toString(), "CN=spock,OU=client,O=client,L=Test,C=DE", wres.getDn());
    Assert.assertFalse(wres.toString(), wres.isAdmin());
    Assert.assertFalse(wres.toString(), wres.isAuthenticated());
    Assert.assertFalse(wres.toString(), wres.isNodeCertificateRequest());
  }
  
  try (TransportClient tc = getUserTransportClient(clusterInfo, "node-0-keystore.jks", Settings.EMPTY)) {  
    WhoAmIResponse wres = tc.execute(WhoAmIAction.INSTANCE, new WhoAmIRequest()).actionGet();    
    System.out.println(wres);
    Assert.assertEquals(wres.toString(), "CN=node-0.example.com,OU=SSL,O=Test,L=Test,C=DE", wres.getDn());
    Assert.assertFalse(wres.toString(), wres.isAdmin());
    Assert.assertFalse(wres.toString(), wres.isAuthenticated());
    Assert.assertTrue(wres.toString(), wres.isNodeCertificateRequest());
  }
}

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

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

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

.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(ConfigConstants.CONFIG_NAMES.toArray(new String[0])))
    .actionGet();
Assert.assertEquals(info.numNodes, cur.getNodes().size());

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

tc.index(new IndexRequest("lorem").type("type1").setRefreshPolicy(RefreshPolicy.IMMEDIATE).source("{\"field2\":\"init\"}", XContentType.JSON)).actionGet();      
WhoAmIResponse wres = tc.execute(WhoAmIAction.INSTANCE, new WhoAmIRequest()).actionGet();   
System.out.println(wres);
Assert.assertEquals("CN=kirk,OU=client,O=client,L=Test,C=DE", wres.getDn());
WhoAmIResponse wres = tc.execute(WhoAmIAction.INSTANCE, new WhoAmIRequest()).actionGet();                
Assert.assertEquals("CN=spock,OU=client,O=client,L=Test,C=DE", wres.getDn());
Assert.assertFalse(wres.isAdmin());

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

ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"roles"})).actionGet();
Assert.assertEquals(clusterInfo.numNodes, cur.getNodes().size());
ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"roles"})).actionGet();
Assert.assertEquals(clusterInfo.numNodes, cur.getNodes().size());

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

tc.admin().cluster().createSnapshot(new CreateSnapshotRequest("all", "all_1").indices("*").includeGlobalState(false).waitForCompletion(true)).actionGet();
ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();
Assert.assertEquals(currentClusterConfig.getNodes(), cur.getNodes().size());
System.out.println(cur.getNodesMap());

代码示例来源：origin: com.floragunn/search-guard-6

final WhoAmIResponse whoAmIRes = tc.execute(WhoAmIAction.INSTANCE, new WhoAmIRequest()).actionGet();
System.out.println("Connected as "+whoAmIRes.getDn());
  tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();                
  final AcknowledgedResponse response = tc.admin().indices().updateSettings((new UpdateSettingsRequest(index).settings(indexSettings))).actionGet();
  System.out.println("Reload config on all nodes");
  tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();                
  System.out.println("Reload config on all nodes");
  System.exit(0);
  LicenseInfoResponse res = tc.execute(LicenseInfoAction.INSTANCE, new LicenseInfoRequest()).actionGet();                
  System.out.println(res.toString());
  System.exit(0);
      .put("index.auto_expand_replicas", replicaAutoExpand?"0-all":"false")
      .build();                
  tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();                
  final AcknowledgedResponse response = tc.admin().indices().updateSettings((new UpdateSettingsRequest(index).settings(indexSettings))).actionGet();
  System.out.println("Reload config on all nodes");
  ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{type})).actionGet();
ConfigUpdateResponse cur = tc.execute(ConfigUpdateAction.INSTANCE, new ConfigUpdateRequest(new String[]{"config","roles","rolesmapping","internalusers","actiongroups"})).actionGet();

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

TransportClient

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    TransportClient类方法

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