跳转至

脚本开发 / elasticsearch

elasticsearch 连接器操作对象主要提供一些操作 elasticsearch 的方法。

本连接器基于 HTTP 协议连接

DFF.CONN(...)参数如下:

参数 类型 必须/默认值 说明
connector_id str 必须 连接器 ID

.query(...)

query(...)方法用于向 elasticsearch 发送 HTTP 请求,参数如下:

参数 类型 必须/默认值 说明
method str 必须 请求方法:GETPOST
path str None 请求路径
query dict None 请求 URL 参数
body dict None 请求体

示例如下:

Python
1
2
3
result = db.query('GET', '/some_index/_search?q=some_field:something')
result = db.query('GET', '/some_index/_search', query={...})
result = db.query('GET', '/some_index/_search', body={...})

具体查询语法、格式等,请参考 elasticsearch 官方文档