From b7a91008c1c19ced85ae1557f39ccbe3702c2ed0 Mon Sep 17 00:00:00 2001
From: Honza Kral <honza.kral@gmail.com>
Date: Mon, 22 Jul 2013 00:40:41 +0200
Subject: [PATCH] delete_by_query

---
 elasticsearch/client/__init__.py | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

diff --git a/elasticsearch/client/__init__.py b/elasticsearch/client/__init__.py
index 2c9843af..0b105707 100644
--- a/elasticsearch/client/__init__.py
+++ b/elasticsearch/client/__init__.py
@@ -389,3 +389,22 @@ class Elasticsearch(object):
         status, data = self.transport.perform_request('GET', _make_path(index, doc_type, '_msearch'), params=params, body=self._bulk_body(body))
         return data
 
+    @query_params('consistency', 'ignore_indices', 'replication', 'routing', 'source', 'timeout')
+    def delete_by_query(self, index, doc_type=None, body=None, params=None):
+        """
+        The delete by query API allows to delete documents from one or more indices and one or more types based on a query.
+        http://www.elasticsearch.org/guide/reference/api/delete-by-query/
+
+        :arg index: A comma-separated list of indices to restrict the operation
+        :arg doc_type: A comma-separated list of types to restrict the operation
+        :arg body: A query to restrict the operation
+        :arg consistency: Specific write consistency setting for the operation
+        :arg ignore_indices: When performed on multiple indices, allows to ignore `missing` ones, default u'none'
+        :arg replication: Specific replication type, default u'sync'
+        :arg routing: Specific routing value
+        :arg source: The URL-encoded query definition (instead of using the request body)
+        :arg timeout: Explicit operation timeout
+        """
+        status, data = self.transport.perform_request('DELETE', _make_path(index, doc_type, '_query'), params=params, body=body)
+        return data
+