"Elasticsearch 是一个分布式搜索服务器，它提供了Restful API更新数据、搜索数据。提交的数据、搜索结果都是JSON格式，计算引擎语言SPL有json()函数解析JSON字符 .."

xjl 北京
乾学院 9 号会员
1 回帖 • 639 浏览 • 1 年前

...

SPL：访问 Elasticsearch

计算＆AI

Elasticsearch 是一个分布式搜索服务器，它提供了Restful API更新数据、搜索数据。提交的数据、搜索结果都是JSON格式，计算引擎语言SPL有json()函数解析JSON字符串，转换成容易做数据计算的SPL序表，因此，也特意提供了es_rest()函数调用Elasticsearch API读写数据。

es_rest(url, method, content; httpHeader1, httpHeader2, …)，第一个参数是链接地址，不同操作的url有不同的尾部格式，支持http和https；第二个参数是HTTP method，值可能是GET/PUT/POST/DELETE；第三个参数是HTTP请求提交的内容，但也有些操作不提交任何内容，这个参数就可以省略。分号后面是多个HTTP header，是验证身份的API Key、指明内容格式等一些信息。每种Rest的HTTP请求，使用哪种method，提交什么内容，设置哪些HTTP header，这些细节参考其官网文档。

示例：

	A
1	>apikey="Authorization:ApiKey a2x6aEF……KZ29rT2hoQQ=="
2	'{ "counter" : 1, "tags" : ["red"] ,"beginTime":"2022-01-03" ,"endTime":"2022-02-15" }
3	=es_rest("https://localhost:9200/index1/_doc/1", "PUT",A2;"Content-Type: application/x-ndjson",apikey)
4	=json(A3.Content)
5	'{ "counter" : 2, "tags" : ["gray"] ,"beginTime":"2022-08-03" ,"endTime":"2022-12-15" }
6	=es_rest("https://localhost:9200/index2/_doc/1", "PUT",A2;"Content-Type: application/x-ndjson",apikey)
7	'{ "script" : { "source": "ctx._source.counter += params.count", "lang": "painless", "params" : { "count" : 4 } } }
8	=es_rest("https://localhost:9200/index1/_update/1", "POST",A7;"Content-Type: application/x-ndjson",apikey)
9	'{ "docs": [ { "_index": "index1" ,"_id":1 } ,{ "_index": "index2" ,"_id":1 } ] }
10	=es_rest("https://localhost:9200/_mget", "GET",A9;apikey,"Content-Type: application/json")
11	=json(A10.Content)
12	'{ "query": { "bool": { "filter": { "range": { "beginTime": {"gte": "2022-01-01", "lte": "2022-07-01"} } } ,"boost" : 1.0 } } }
13	=es_rest("https://localhost:9200/_search","GET",A12;apikey,"Content-Type: application/json")
14	=json(A13.Content)
15	=es_rest("https://localhost:9200/index1/_doc/1", "DELETE";apikey)
16	=json(A15.Content)