معرفی شرکت ها

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

توضیحات

Collections of ElasticSearch pyscripts for human

ویژگی	مقدار
سیستم عامل	-
نام فایل	elasticSearch-collections-1.1
نام	elasticSearch-collections
نسخه کتابخانه	1.1
نگهدارنده	['Alex Ng']
ایمیل نگهدارنده	['alex_q_wu@qq.com']
نویسنده	Alex Ng
ایمیل نویسنده	alex_q_wu@qq.com
آدرس صفحه اصلی	https://github.com/AlexNg9527/ElasticSearchCollections
آدرس اینترنتی	https://pypi.org/project/elasticSearch-collections/
مجوز	MIT

# ElasticSearchCollections Collections of ElasticSearch pyscripts for human ## Example ```python from elasticSearch_collections.elasticSearch_collections import ElasticSearchCollections from typing import Dict, List # Connect to es hosts es = ElasticSearchCollections(["https://127.0.0.1"], http_auth=("username", "password"), ca_certs=False, verify_certs=False, timeout=600) def fn_data_update(_data: List[Dict]): actions = [] for i in _data: # do something action = { "_op_type": "update", "_index": i["_index"], "_type": "_doc", "_id": i["_id"], "doc": { # update logic } } actions.append(action) if actions: es.bulk(actions) es_search_info = { "index": '_index', "scroll": '1m', "size": 1000, "body": """{ "query": { "match_all": {} } }""", "timeout": "10m" } _res_list = es.scroll_source_generator(es_search_info) # run multiple threads with threado from threado.simple_thread_runner import SimpleThreadsRunner # Define the num_workers and batch_size # refer to https://github.com/AlexNg9527/threado sr = SimpleThreadsRunner(fn=fn_data_update) sr.run_threads(num_workers=10, iter_data=_res_list, batch_size=10) # clear scroll_id es.delete_scroll_id() ``` ## Installing and Supported Versions elasticSearch_collections is available on PyPI: ```console $ python -m pip install elasticSearch_collections ```

نیازمندی

مقدار	نام
-	loguru
==7.11.0	elasticsearch

نحوه نصب

نصب پکیج whl elasticSearch-collections-1.1:

pip install elasticSearch-collections-1.1.whl

نصب پکیج tar.gz elasticSearch-collections-1.1:

pip install elasticSearch-collections-1.1.tar.gz