Django 连通Elasticsearch之前后台串联

来自CloudWiki
Cloud17讨论 | 贡献2019年9月2日 (一) 02:06的版本
跳转至: 导航搜索

前言

我们在Django 连通ElasticsearchDjango 连通Elasticsearch之创建表单中分别用Django框架 连通了后台的ES 和前台的表单,现在让我们把django的前后台连接起来,使得表单搜索的关键字 能直接进入后台ES查询,并显示结果

修改视图层

我们在表单的视图层文件 search.py 中,添加拥有查询ES的代码:

# -*- coding: utf-8 -*-

from django.http import HttpResponse
from django.shortcuts import render_to_response

import traceback
from elasticsearch import Elasticsearch
from .ElasticObj import ElasticObj

# 表单
def search_form(request):
    return render_to_response('search_form.html')

# 提交后的接收请求数据
def search(request):
    obj = ElasticObj("ott1", "ott_type1")
    h = obj.Get_Data_By_Body("电视")#搜索电视
    return HttpResponse(h)

添加表单参数

现在我们尝试将前台表单传过来的参数,传到ES中进行查询:

# -*- coding: utf-8 -*-

from django.http import HttpResponse
from django.shortcuts import render_to_response

import traceback
from elasticsearch import Elasticsearch
from .ElasticObj import ElasticObj

# 表单
def search_form(request):
    return render_to_response('search_form.html')

# 提交后的接收请求数据
def search(request):
    request.encoding='utf-8'
    if 'q' in request.GET:
        obj = ElasticObj("ott1", "ott_type1")
        h = obj.Get_Data_By_Body(request.GET['q'])#搜索电视
        #message = '你搜索的内容为: ' + request.GET['q']

    else:
        h =""
    return HttpResponse(h)