asyncio的elasticsearch-py包装器
项目描述
- info:
asyncio的elasticsearch-py包装器
安装
pip install aioelasticsearch使用
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()功能
异步 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 doc in scan:
print(doc['_source'])
loop = asyncio.get_event_loop()
loop.run_until_complete(go())
loop.close()感谢
该库由 Ocean S.A. 捐赠
感谢公司做出贡献。
项目详情
下载文件
下载适用于您的平台的文件。如果您不确定选择哪个，请了解更多关于安装包的信息。
源代码分发
aioelasticsearch-0.7.0.tar.gz (10.0 kB 查看哈希值)
构建分发
aioelasticsearch-0.7.0-py3-none-any.whl (11.0 kB 查看哈希值)