Delete documents by query
delete documents by query via a POST request
docs_delete_by_query( conn, index, body, type = NULL, conflicts = NULL, routing = NULL, scroll_size = NULL, refresh = NULL, wait_for_completion = NULL, wait_for_active_shards = NULL, timeout = NULL, scroll = NULL, requests_per_second = NULL, ... )
conn |
an Elasticsearch connection object, see |
index |
(character) The name of the index. Required |
body |
(character/json) query to be passed on to POST request body |
type |
(character) The type of the document. optional |
conflicts |
(character) If you’d like to count version conflicts
rather than cause them to abort then set |
routing |
(character) Specific routing value |
scroll_size |
(integer) By default uses scroll batches of 1000. Change batch size with this parameter. |
refresh |
(logical) Refresh the index after performing the operation |
wait_for_completion |
(logical) If |
wait_for_active_shards |
(logical) controls how many copies of a shard must be active before proceeding with the request. |
timeout |
(character) Explicit operation timeout, e.g,. 5m (for 5 minutes) |
scroll |
(integer) control how long the "search context" is kept
alive, eg |
requests_per_second |
(integer) any positive decimal number
(1.4, 6, 1000, etc); throttles rate at which |
... |
Curl args passed on to crul::verb-POST |
## Not run: (x <- connect()) x$ping() plosdat <- system.file("examples", "plos_data.json", package = "elastic") plosdat <- type_remover(plosdat) if (!index_exists(x, "plos")) invisible(docs_bulk(x, plosdat)) # delete with fuzzy matching body <- '{ "query": { "match": { "title": { "query": "cells", "fuzziness": 1 } } } }' docs_delete_by_query(x, index='plos', body = body) # delete with no fuzziness if (index_exists(x, "plos")) index_delete(x, 'plos') invisible(docs_bulk(x, plosdat)) count(x, "plos") body <- '{ "query": { "match": { "title": { "query": "cells", "fuzziness": 0 } } } }' docs_delete_by_query(x, index='plos', body = body) # delete all docs with match_all query if (index_exists(x, "plos")) index_delete(x, 'plos') invisible(docs_bulk(x, plosdat)) body <- '{ "query": { "match_all": {} } }' docs_delete_by_query(x, index='plos', body = body) # put plos back in if (index_exists(x, "plos")) index_delete(x, 'plos') invisible(docs_bulk(x, plosdat)) # delete docs from more than one index foo <- system.file("examples/foo.json", package = "elastic") if (!index_exists(x, "foo")) invisible(docs_bulk(x, foo)) bar <- system.file("examples/bar.json", package = "elastic") if (!index_exists(x, "bar")) invisible(docs_bulk(x, bar)) body <- '{ "query": { "match_all": {} } }' docs_delete_by_query(x, index=c('foo','bar'), body = body, verbose = TRUE) ## End(Not run)
Please choose more modern alternatives, such as Google Chrome or Mozilla Firefox.