| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [View Raw Code] [Original HTTPS Page] |
实例
from elasticsearch import Elasticsearch
es = Elasticsearch(hosts="10.10.123.131", timeout=360)
body = {
# 精确查询
"query": {
"term": {
"c_name": "宾利"
}
}
}
result = es.search(index="carlist", doc_type="car", body=body)
print(result)
print(result["hits"]["hits"]) # 获取更好格式的数据实例
import tornado.web
from elasticsearch import Elasticsearch
class MyHeadler(tornado.wewb.RequestHandler):
def get(self):
result = locals()
result.pop("self")
self.render("index.html", **result)
class CarHeadler(tornado.web.RequestHandler):
def initialize(self):
self.es = Elasticsearch("10.10.123.131")
self.body = {
"query": {
"match": {
"c_name": ""
}
}
}
def get(self):
# 获取请求数据
c_name = self.get_arguments("search_key")[0]
# 进行请求的 es 个数构建
self.body["query"]["match"]["c_name"] = c_name
self.body["from"] = 0
self.body["size"] = 12
# 进行 es 请求
result = self.es.search(
body = self.body,
index = "carlist",
doc_type = "car",
)
# 数据过滤
cars = result["hits"]["hits"]
car_list = [i["_source"] for i in cars]
self.render("car_list.html", car_list=car_list)| Back | FazBrowse Home | New Git URL |