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+

• asyncio 或 Python 3.4+

• aiohttp 1.3+

测试

在执行测试之前，请确保Elasticsearch实例正在端口9200上运行。

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

启用Groovy脚本

script.groovy.sandbox.enabled: true

设置存储库路径

path.repo: ["/tmp"]

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

$ py.test

许可证

aioes 在BSD许可证下提供。

变更