python批量操作ElasticSearch

2020-12-19 00:49:13 编辑 0 阅读量:854

Elasticsearch有python的客户端，名字就是 Elasticsearch，提供了一系列操作es的方法，主要有3个层次：` Elasticsearch`, `helpers`, `Connection Layer`。批量操作的行为是bulk，通过helpers完成。代码如下：
 
 ```python
 from elasticsearch import ElasticSearch, helpers
 
 es = ElasticSearch() # 连接到127.0.0.1
 body = [{
    '_op_type': 'update',
    '_index': 'data',   # 索引的名字
    '_type': 'test',    # 索引的doc_type
    '_id': 6,
    '_source': {'question': 'The life, universe and everything.'}
},
{
    '_op_type': 'index',
    '_index': 'data',
    '_type': 'test',
    '_id': 7,
    '_source': {'question': 'The life, universe and everything.'}
},
{
    '_op_type': 'delete',
    '_index': 'another index',
    '_type': 'doc_type',
    '_id': 42,
}
]

helpers.bulk(es, body, raise_on_error=False, raise_on_exception=False) # 忽略error的Exception
```

`helpers`中还有一些其他的方法，可以自己看下说明

---
参考：
- [1][官方es文档](https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html)
- [2][官方python elasticsearch文档](http://elasticsearch-py.readthedocs.io/en/master/helpers.html)

python批量操作ElasticSearch

附件: