How to delete documents matching a condition in Elasticsearch?

Question

Python

I used to use elasticutils in my Python script.
Now I am rewriting it to use the elasticsearch-dsl module.
Here is the old code:

from elasticutils import get_es

es = get_es(urls=config.ELASTIC_SEARCH_HOSTS, timeout=timeout)
es.delete_by_query(
            'posts',
            'post',
            {'query': {'term': {'user_id': user.id}}})

There is nothing in elasticsearch-dsl for such an operation.
How to delete documents by condition using elasticsearch module?
Used by Elasticsearch 2.4.
The delete_by_query module is cut out of the second elastic, it is not desirable to cut it back.
As far as I understand, you need to delete via bulk. But I don't understand how to build a query.

Answer 1

Try it through a regular client (didn't check the code, pulled it from the source, but it should work)

from elasticsearch import Elasticsearch, helpers

es = Elasticsearch()

def mybulk_delete(q, index, doc_type):
   res = helpers.scan(es,
                       query={"query": q},
                       index=index, doc_type= doc_type)
    for r in res:
       yield {"delete" : { "_index" : r["_index"], "_type" : r["_type"], "_id" : r["_id"] } }

q = {"query":{"term":{"user":"kimchy"}}}
k = (i for i in mybulk_delete(q,"myindex", "mytype"))
helpers.bulk(es, k, refresh = True)

Answer 2

For example, like this:

POST finrep/securities/_delete_by_query
{
  "query": { 
    "match": {
      "company_name": "ТрансКонтейнер"
    }
  }
}