スクリプト開発 / コネクターオブジェクト 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 公式ドキュメントを参照してください。