scroll — lt.jocas/lazy-elasticsearch-scroll 1.0.6

client clj

continue clj

(continue es-host scroll-id opts)

default-exponential-backoff-params clj

default-query clj

default-size clj

dissoc-aggs clj

(dissoc-aggs scroll-request)

execute-request clj

(execute-request {:keys [url body opts]})

exponential-backoff clj

(exponential-backoff f)

(exponential-backoff f {:keys [time rate max p?] :as opts})

extract-hits clj

(extract-hits batch keywordize?)

extract-scroll-id clj

(extract-scroll-id batch keywordize?)

fetch clj

(fetch {:keys [es-host index-name query scroll-id opts] :as req})

hits clj

(hits {:keys [es-host] :as scroll-request})

Returns a lazy sequence of hits from Elasticsearch using Scroll API. See: https://www.elastic.co/guide/en/elasticsearch/reference/7.5/search-request-body.html#request-body-search-scroll

Params:

• es-host: Elasticsearch host, e.g. http://localhost:9200
• index-name: indices through which to scroll, default *, i.e. all indices
• query: Elasticsearch query to filter the documents, default: {:sort ["_doc"]}
• opts: supported options:
• • keep-context: specifies how log to maintain scroll state, default 30s
• • keywordize?: should the JSON keys be converted to Clojure keys, default true
• • size: how many records should be fetched from Elasticsearch in one network trip, default 1000

set-batch-size clj

(set-batch-size query opts)

sni-configure clj

(sni-configure ssl-engine uri)

start clj

(start es-host index-name query opts)