ElasticSearch Handler
Project description
exec_es
exec_es 对ElasticSearch进行了二次开发,针对多开发环境数据写入,以及bulk进行了优化。
Installation
1.使用python包管理工具 pip 进行安装。
pip install exec-es
Usage
from execelasticsearch.handler import ExecES
choose_config = 0
dt_config = [dict(hosts=[{'host': "172.28.0.1"}]), dict(hosts=[{'host': "172.28.0.1"}], doc_type='tags')][choose_config]
dp_config = [dict(hosts=[{'host': "172.28.0.2"}]), dict(hosts=[{'host': "172.28.0.2"}], doc_type='tags')][choose_config]
es_clients = ExecES(dt=dt_config, dp=dp_config)
index = 'exec_es_test'
hosts = ["dt", "dp"]
def es_create(data_, dex=0):
data_ = data_[dex]
print(es_clients.create(index, data_['id'], data_, hosts))
def es_update(data_, dex=0):
data_ = data_[dex]
data_['account_score'] = 10
print(es_clients.update(index, data_['id'], data_, hosts))
def es_delete(id_):
print(es_clients.delete(index, id_, hosts))
def es_update_or_ignore(data_, dex=0):
data_ = data_[dex]
print(es_clients.update_or_ignore(index, data_['id'], data_, hosts))
def es_upsert(data_, dex=0):
data_ = data_[dex]
print(es_clients.upsert(index, data_['id'], data_, hosts))
def es_bulk_upsert(data_):
data_[0]['account_score'] = 10
print(es_clients.bulk_upsert(index, data_, hosts))
def es_bulk_delete(data_):
ids = [i['id'] for i in data_]
print(es_clients.bulk_delete(index, ids, hosts))
def es_mget(data_, _source_includes=None):
ids = [i['id'] for i in data_]
print(es_clients.mget(index, ids, hosts, _source_includes=_source_includes))
def es_exists(ids: list):
print(es_clients.exists_ids(index, ids, hosts))
def es_original_func():
print(es_clients['dt'].ping())
if __name__ == '__main__':
es_original_func()
Contributing
使用前请做适当的测试,以确定跟您的项目完全兼容。
License
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
exec-es-0.0.3.tar.gz
(7.3 kB
view hashes)