与Asyncio集成的ElasticSearch。

aioes-ext的Python项目详细描述


aioes是一个与asyncio兼容的库,用于处理ElasticSearch

文档

阅读aioes有关阅读文档的文档:http://aioes.readthedocs.org/

示例

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())

要求

测试

确保在端口9200上运行弹性搜索实例 在执行测试之前。

为了使所有测试都能工作,您需要在 config/elasticsearch.yml配置文件:

启用Groovy脚本:

script.groovy.sandbox.enabled: true

设置存储库路径:

path.repo: ["/tmp"]

测试套件使用nose,执行:

nosetests tests

许可证

aioes是根据bsd许可证提供的。

更改

0.6.1(2016-09-08)

  • 接受字节作为有效载荷42
  • Elasticsearch.close()转换为协同程序。

0.6.0(2016-09-08)

  • 添加对verify_ssl_43的支持

0.5.0(2016-07-16)

  • 允许在连接中使用方案、用户名和密码40

0.4.0(2016-02-10)

  • 修复传输地址regex 38中的es2+兼容性

0.3.0(2016-01-27)

  • 在内部使用aiohttp.clientsession 36

0.2.0(2015-10-08)

  • 与ElasticSearch 1.7兼容
  • 支持Python3.5
  • 放弃Python3.3支持
  • 根据apache 2重新授权

0.1.0(2014-10-04)

  • 初始版本

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java使用ContentExchange设置请求属性   java Spark/Hdfs/Hdfsclient兼容性   java springcloudstreamkafka配置:instanceCount和instanceIndex   Java中web服务序列化日期   java用动态数据替换占位符   java git gc似乎覆盖了一个packfile,留下了一个打开的文件描述符,其中包含对“oldxxx.pack”的引用   为什么Apache项目对Java版本敏感?   java Anylogic帮助如何在导入的3dobject通过输送机上的多个“站”时更改其颜色?   JavaEclipseNeonM2E可以导入一个大型项目,但似乎不能自动解决依赖关系   java@FindBy搜索具有满足条件的子元素的元素   java如何将ActionEvent e与键绑定一起使用?   java转换以集中方式从外部库抛出的异常   java中用户文件/数据文件与系统/程序文件的区别   java使用变量字符串或字符作为对象名   字体使用Java图形操纵字符串中每个字符的形状   JavaFX图表移动数据   java RandomAccessFile:将所有项设置为相同的字节数?   java Google Play inapp Billing onPurchasesUpdated()错误响应代码1   java在不知道属性名和属性数的情况下处理json对象   java是否可以一次从HazelcastInstance(映射和列表)中删除所有数据?