python elasticsearch

原文链接

文档：http://elasticsearch-py.readthedocs.io/en/master/
Elasticsearch官方API文档：
https://www.elastic.co/guide/en/elasticsearch/reference/current/search.html
两种方式现实Elasticsearch API操作
方式一：安装elasticsearch模块，通过它操作Elasticsearch，代码示例如下

from elasticsearch import Elasticsearchclass ElasticSearchClass(object):def __init__(self, host, port, user, passwrod):self.host = hostself.port = portself.user = userself.password = passwrodself.connect()def connect(self):self.es = Elasticsearch(hosts=[{'host': self.host, 'port': self.port}],http_auth=(self.user, self.password ))def count(self, indexname):""":param indexname::return: 统计index总数"""return self.es.count(index=indexname)def delete(self, indexname, doc_type, id):""":param indexname::param doc_type::param id::return: 删除index中具体的一条"""self.es.delete(index=indexname, doc_type=doc_type, id=id)def get(self, indexname, id):return self.es.get(index=indexname, id=id)def search(self, indexname, size=10):try:return self.es.search(index=indexname, size=size, sort="@timestamp:desc")except Exception as err:print(err)

方式二：安装requests模块，通过GET、POST方式操作Elasticsearch

class RequestsElasticSearchClass(object):def __init__(self, host, port, user, passwrod):self.url = 'http://' + host + ':' + str(port)basicpwd = base64.b64encode((user + ':' + passwrod).encode('UTF-8'))self.headers = {"User-Agent": "shhnwangjian","Content-Type": "application/json","Authorization": "Basic {}".format(basicpwd.decode('utf-8'))}def search(self, indexname, size=10):gettdata = {"sort": "@timestamp:desc","size": size}url = self.url + '/' + indexname + '/_search'ret = requests.get(url, headers=self.headers, timeout=10, params=gettdata)print(ret.text)

python elasticsearch相关推荐

python elasticsearch 入门教程(二) ---全文搜索
python elasticsearch 入门教程(二) ---全文搜索截止目前的搜索相对都很简单:单个姓名,通过年龄过滤.现在尝试下稍微高级点儿的全文搜索--一项传统数据库确实很难搞定的任务. ...
Python + ElasticSearch：有了这个超级武器，你也可以报名参加诗词大会了！ | 博文精选...
来源 | CSDN 博客作者 | 天元浪子责编 | Carol 出品 | CSDN云计算(ID:CSDNcloud) 意犹未尽的诗词大会正月十六,中国诗词大会第五季落下帷幕.从2016年2月12 ...
python elasticsearch.exceptions.ConnectionError: ConnectionError(check_hostname requires server_host
代码 from elasticsearch import Elasticsearch from elasticsearch import RequestsHttpConnection from ssl ...
python Elasticsearch 排序
sort 与query是同级的 Elasticsearch python sort {"sort": [{"_score": {"order" ...
python elasticsearch模块_Python 操作 ElasticSearch
Python操作ElasticSearch Python批量向ElasticSearch插入数据 Python 2的多进程不能序列化类方法, 所以改为函数的形式. 直接上代码: #!/usr/bin/ ...
python elasticsearch查询_python 查询Elasticsearch的小例子
#!/usr/bin/env python # -*- coding: utf-8 -*- from sfo_common.agent import Agent from sfo_common.imp ...
python elasticsearch update_使用python的elasticsearch部分更新
我有以下格式的elasticsearch文档.我需要部分更新"x"字段并在其中添加python dict.{ "_index": "gdata34&q ...
python elasticsearch模块_Python3 操作 elasticsearch
elasticsearch 模块 Elasticsearch低级客户端.提供从Python到ES REST端点的直接映射. 连接集群节点指定连接 es = Elasticsearch( ['172. ...
python elasticsearch bulk_关于ElasticSearch Bulk的用法
Background 刚接触ElasticSearch不久,公司让我帮忙去导一下数据,刚开始数量并不是很大,我都是用Elasticsearch python的api接口,一条一条数据去往新的index ...
python elasticsearch 提示 ‘update‘ API and will be removed
环境: Elasticsearch 版本:7.10.1 elasticsearch-analysis-ik 版本:7.10.1 Elasticsearch 操作的 Python 库版本:7.16.1 ...

python elasticsearch

python elasticsearch相关推荐

最新文章

热门文章