python连接elasticsearch查询数据

python连接elasticsearch获取数据

原文：https://blog.csdn.net/ziqiaowang/article/details/54972279

# -*- encoding: utf-8 -*-
import sys
import json
from elasticsearch import Elasticsearch
reload(sys)
sys.setdefaultencoding("utf8")
######################################################
# 用于连接ES环境，查询检索小区信息，返回排名靠前10的小区信息。
# http_auth=('es_username', 'es_passwd')
# es_search(city,name):es_search(深圳,登科花园)
######################################################
es = Elasticsearch(
['xxx.xxx.xxx.xxx'],
http_auth=('elastic', 'passwd'),
port=9200
)
def es_search(city, name):
query_json = {
"bool": {
"must": {
"term": {
"city": city
}
},
"must_not":{
"term": {
"base_inf.kind":'商铺'
}
},
"should": [
{
"match": {
"message": name
}
}
]
}
}
source_arr = ["name",
"Long_lat.lon",
"Long_lat.lat",
"detail_inf",
"avg_price",
"base_inf.kind",
"base_inf.build_time"]
res = es.search(index="st_soufang", body={"query": query_json, "_source": source_arr}) # 获取所有数据
# 获取第一条数据，得分最高。
top_10_recodes = res['hits']['hits']
# print json.dumps(top_10_recodes)
return [top_10_recodes]
#
# for item in best_recode:
# if item != '_source':
# print item,best_recode[item]
if __name__ == "__main__":
# 测试单例
city = '深圳'
name = '东方星大厦'
es_search(city, name)

python连接elasticsearch查询数据相关推荐

使用Connector / Python连接MySQL/查询数据
使用Connector / Python连接MySQL connect()构造函数创建到MySQL服务器的连接并返回一个 MySQLConnection对象在python中有以下几种方法可以连接到M ...
python连接mysql查询一个数据_使用Connector / Python连接MySQL/查询数据
使用Connector / Python连接MySQL connect()构造函数创建到MySQL服务器的连接并返回一个 MySQLConnection对象在python中有以下几种方法可以连接到M ...
python 连接mongodb查询数据
1.安装pymongo并引入 pip install pymongo 连接MongoDB时,需要使用PyMongo库里面的MongoClient. 2.连接mongoDB 一般来说,传入MongoD ...
python连接mysql查询数据返回字典格式
import MySQLdb import MySQLdb.cursors conn = MySQLdb.connec('localhost','root','test456','db_test', ...
python连接mysql数据库数据
使用python连接mysql数据库数据,有以下两种读取数据的方式推荐. 一种是通过游标,及fetch系列方法进行操作,另一种是通过pandas的read_sql()进行读取并操作.各种方法各有优劣, ...
python将ElasticSearch索引数据读入pandas dataframe实战
python将ElasticSearch索引数据读入pandas dataframe实战 # 导入基础包和库 import pandas as pdpd.set_option('display.max ...
VB.NET通过OleDbConnection连接oracle查询数据示例
一.前言 1.目的本文实现了VB.Net通过OleDbConnection连接oracle查询数据,并展示数据到TextBox1. 2.数据库版本 select * from v$version; ...
Python连接mysql,插入数据时不报错，但是没有插入进去
Python连接mysql,插入数据时不报错,但是没有插入进去在connect方法中,设置 autocommit =True conn=pymysql.connect(host=host_db,use ...
【PyQt5】连接 mysql 查询数据并显示在 tableWidget 表格
PyQt5 数据库建表 + SQL 语句 Qt designer 制作界面连接 MySQL 相关知识查询并获取数据库的数据运行效果数据库建表 + SQL 语句建立一个数据库:test 建立一 ...

python连接elasticsearch查询数据

python连接elasticsearch查询数据相关推荐

最新文章

热门文章