aioes 0.7.2

文档

在 Read The Docs 上阅读aioes文档：http: //aioes.readthedocs.io/

例子

import asyncio
from aioes import Elasticsearch

@asyncio.coroutine
def go():
    es = Elasticsearch(['localhost:9200'])
    ret = yield from es.create(index="my-index",
                               doc_type="test-type",
                               id=42,
                               body={"str": "data",
                                     "int": 1})
    assert (ret == {'_id': '42',
                    '_index': 'my-index',
                    '_type': 'test-type',
                    '_version': 1,
                    'ok': True})

    answer = yield from es.get(index="my-index",
                               doc_type="test-type",
                               id=42)
    assert answer['_source'] == {'str': 'data', 'int': 1}

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

要求

• Python 3.3+

• 异步或 Python 3.4+

• aiohttp 1.3+

测试

在执行测试之前，请确保您有一个在端口 9200 上运行的 Elasticsearch 实例。

为了使所有测试正常工作，您需要在 config/elasticsearch.yml配置文件中添加以下行：

启用 groovy 脚本：

script.groovy.sandbox.enabled: true

设置存储库路径：

path.repo: ["/tmp"]

测试套件使用py.test，只需运行：

$ py.test

执照

aioes 在 BSD 许可下提供。

变化