Merge pull request #66 from darkindex/elasticsearch-fields
Make Elasticsearch searched fields configurable
This commit is contained in:
commit
a721de26b6
|
@ -248,6 +248,12 @@ In your Realms Config, have the following options set:
|
||||||
"SEARCH_TYPE": "elasticsearch"
|
"SEARCH_TYPE": "elasticsearch"
|
||||||
"ELASTICSEARCH_URL": "http://127.0.0.1:9200"
|
"ELASTICSEARCH_URL": "http://127.0.0.1:9200"
|
||||||
|
|
||||||
|
Optionally, also set the following option to configure which fields are searchable:
|
||||||
|
|
||||||
|
"ELASTICSEARCH_FIELDS": ["name"]
|
||||||
|
|
||||||
|
Allowable values are `"name"`, `"content"`, `"username"`, `"message"`. The default is `["name"]`.
|
||||||
|
|
||||||
### Whoosh Setup
|
### Whoosh Setup
|
||||||
|
|
||||||
Simply install Whoosh to your Python environment, e.g.
|
Simply install Whoosh to your Python environment, e.g.
|
||||||
|
|
|
@ -99,6 +99,7 @@ SEARCH_TYPE = 'simple' # simple is not good for large wikis
|
||||||
|
|
||||||
# SEARCH_TYPE = 'elasticsearch'
|
# SEARCH_TYPE = 'elasticsearch'
|
||||||
ELASTICSEARCH_URL = 'http://127.0.0.1:9200'
|
ELASTICSEARCH_URL = 'http://127.0.0.1:9200'
|
||||||
|
ELASTICSEARCH_FIELDS = ["name"]
|
||||||
|
|
||||||
# SEARCH_TYPE = 'whoosh'
|
# SEARCH_TYPE = 'whoosh'
|
||||||
WHOOSH_INDEX = '/tmp/whoosh'
|
WHOOSH_INDEX = '/tmp/whoosh'
|
||||||
|
|
|
@ -14,7 +14,8 @@ def whoosh(app):
|
||||||
|
|
||||||
def elasticsearch(app):
|
def elasticsearch(app):
|
||||||
from flask.ext.elastic import Elastic
|
from flask.ext.elastic import Elastic
|
||||||
return ElasticSearch(Elastic(app))
|
fields = app.config.get('ELASTICSEARCH_FIELDS')
|
||||||
|
return ElasticSearch(Elastic(app), fields)
|
||||||
|
|
||||||
|
|
||||||
class Search(object):
|
class Search(object):
|
||||||
|
@ -125,8 +126,9 @@ class WhooshSearch(BaseSearch):
|
||||||
|
|
||||||
|
|
||||||
class ElasticSearch(BaseSearch):
|
class ElasticSearch(BaseSearch):
|
||||||
def __init__(self, elastic):
|
def __init__(self, elastic, fields):
|
||||||
self.elastic = elastic
|
self.elastic = elastic
|
||||||
|
self.fields = fields
|
||||||
|
|
||||||
def index(self, index, doc_type, id_=None, body=None):
|
def index(self, index, doc_type, id_=None, body=None):
|
||||||
return self.elastic.index(index=index, doc_type=doc_type, id=id_, body=body)
|
return self.elastic.index(index=index, doc_type=doc_type, id=id_, body=body)
|
||||||
|
@ -144,7 +146,7 @@ class ElasticSearch(BaseSearch):
|
||||||
res = self.elastic.search(index='wiki', body={"query": {
|
res = self.elastic.search(index='wiki', body={"query": {
|
||||||
"multi_match": {
|
"multi_match": {
|
||||||
"query": query,
|
"query": query,
|
||||||
"fields": ["name"]
|
"fields": self.fields
|
||||||
}}})
|
}}})
|
||||||
|
|
||||||
return [hit["_source"] for hit in res['hits']['hits']]
|
return [hit["_source"] for hit in res['hits']['hits']]
|
||||||
|
|
Loading…
Reference in a new issue