需要执行一系列异步作业,每个作业都需要查询Elasticsearch,然后开始对查询结果进行处理。val port = 9300 val client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(NodeName), port))
client[_cli
我想在elasticsearch中签入索引是否存在。如果它不存在,它应该创建索引并执行其他功能。我试图找出一个解决办法,但没有找到任何完美的解决办法。有人能找到解决这个问题的办法吗。我正在使用Elasticsearch库。
**$client = new Elasticsearch\Client();**