aioelasticsearch
pypi i aioelasticsearch

aioelasticsearch

aioelasticsearch-py wrapper for asyncio

by aio-libs

0.7.0 (see all)Categories:asyncio ElasticSearch
pypi i aioelasticsearch
Readme

aioelasticsearch

:info: elasticsearch-py wrapper for asyncio

.. image:: https://img.shields.io/travis/aio-libs/aioelasticsearch.svg :target: https://travis-ci.org/aio-libs/aioelasticsearch

.. image:: https://img.shields.io/pypi/v/aioelasticsearch.svg :target: https://pypi.python.org/pypi/aioelasticsearch

.. image:: https://codecov.io/gh/aio-libs/aioelasticsearch/branch/master/graph/badge.svg :target: https://codecov.io/gh/aio-libs/aioelasticsearch

Installation

.. code-block:: shell

pip install aioelasticsearch

Usage

.. code-block:: python

import asyncio

from aioelasticsearch import Elasticsearch

async def go():
    es = Elasticsearch()

    print(await es.search())

    await es.close()

loop = asyncio.get_event_loop()
loop.run_until_complete(go())
loop.close()

Features

Asynchronous scroll <https://www.elastic.co/guide/en/elasticsearch/reference/current/search-request-scroll.html>_

.. code-block:: python

import asyncio

from aioelasticsearch import Elasticsearch
from aioelasticsearch.helpers import Scan

async def go():
    async with Elasticsearch() as es:
        async with Scan(
            es,
            index='index',
            doc_type='doc_type',
            query={},
        ) as scan:
            print(scan.total)

            async for doc in scan:
                print(doc['_source'])

loop = asyncio.get_event_loop()
loop.run_until_complete(go())
loop.close()

Thanks

The library was donated by Ocean S.A. <https://ocean.io/>_

Thanks to the company for contribution.

GitHub Stars

131

LAST COMMIT

1yr ago

MAINTAINERS

1

CONTRIBUTORS

18

OPEN ISSUES

18

OPEN PRs

12
VersionTagPublished
0.7.0
2yrs ago
0.6.0
3yrs ago
0.5.2
4yrs ago
0.5.1
4yrs ago
No tutorials found
Add a tutorial