腳本開發 / 連接器對象 DFF.CONN / Elasticsearch

Elasticsearch 連接器操作對象主要提供一些操作 Elasticsearch 的方法。

本連接器基於 HTTP 協議連接

DFF.CONN(...) 參數如下：

參數	類型	必須 / 默認值	説明
connector_id	str	必須	連接器 ID
timeout	int/float	10	當前操作對象的默認 HTTP 請求超時時間，秒

.query(...)

向 Elasticsearch 發送 HTTP 請求，參數如下：

參數	類型	必須 / 默認值	説明
method	str	必須	請求方法，如 GET、POST；也可寫為 "GET /path"
path	str	None	請求路徑；省略時從 method 中拆分
query	dict	None	URL 查詢參數
body	dict	None	JSON 請求體
timeout	int/float	None	本次請求超時時間，省略時使用操作對象的默認值

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={...})

連接器會自動補充 format=json 查詢參數。響應為 JSON 或 XML 時返回解析後的對象，否則返回原始字節；HTTP 狀態碼大於等於 400 時拋出異常。

具體查詢語法和格式請參考 Elasticsearch 官方文檔。