views.py 文件源码

def search(request): # /search
  if request.method != 'POST':  
    return _error_response(request, err_exp.E_BAD_REQUEST, "must make POST request")

  if not es.indices.exists(index='listing_index'):
    return _error_response(request, 'listings not found')

  resp = []
  res = es.search(index='listing_index', body={'query': {'query_string': {'query': request.POST['query']}}, 'size': 10})
  hits = res['hits']['hits']
  if not hits:
    return _error_response(request, res)
  for hit in hits:
    resp.append(hit['_source']) # parse es source

  return _success_response(request, resp)