@query_params('consistency', 'fields', 'pipeline', 'refresh', 'routing',
        'timeout')
    def bulk(self, body, index=None, doc_type=None, params=None):
        if body in SKIP_IN_PATH:
            raise ValueError("Empty value passed for a required argument 'body'.")
        return self.transport.perform_request('POST', _make_path(index,
            doc_type, '_bulk'), params=params, body=self._bulk_body(body))
Perform many index/delete operations in a single API call.
dataset/ETHPy150Open elastic/elasticsearch-py/elasticsearch/client/__init__.py/Elasticsearch.bulk