aioelasticsearch 0.1.8

Installation

pip install aioelasticsearch

Usage

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

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 scroll in scan:
                for doc in scroll:
                    print(doc['_source'])

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

Coroutine version of scroll

import asyncio

from aioelasticsearch import Elasticsearch
from aioelasticsearch.helpers import Scan

@asyncio.coroutine
def go():
    es = Elasticsearch()
    try:
        with Scan(
            es,
            index='index',
            doc_type='doc_type',
            query={},
        ) as scan:
            try:
                yield from scan.scroll()
                print(scan.total)

                for scroll in scan:
                    scroll = yield from scroll

                    for doc in scroll:
                        print(doc['_source'])
            finally:
                yield from scan.clear_scroll()
    finally:
        yield from es.close()

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