Functions
	init (engine_settings)
	request (query, params)
	_match_query (query)
	_simple_query_string_query (query)
	_term_query (query)
	_terms_query (query)
	_custom_query (query)
EngineResults	response (SXNG_Response resp)

Variables
list	categories = ['general']
bool	paging = True
dict	about
str	base_url = 'http://localhost:9200'
str	username = ''
str	password = ''
str	index = ''
str	query_type = 'match'
dict	custom_query_json = {}
bool	show_metadata = False
int	page_size = 10
dict	_available_query_types

Detailed Description

.. sidebar:: info

   - :origin:`elasticsearch.py <searx/engines/elasticsearch.py>`
   - `Elasticsearch <https://www.elastic.co/elasticsearch/>`_
   - `Elasticsearch Guide
     <https://www.elastic.co/guide/en/elasticsearch/reference/current/index.html>`_
   - `Install Elasticsearch
     <https://www.elastic.co/guide/en/elasticsearch/reference/current/install-elasticsearch.html>`_

Elasticsearch_ supports numerous ways to query the data it is storing.  At the
moment the engine supports the most popular search methods (``query_type``):

- ``match``,
- ``simple_query_string``,
- ``term`` and
- ``terms``.

If none of the methods fit your use case, you can select ``custom`` query type
and provide the JSON payload to submit to Elasticsearch in
``custom_query_json``.

Example
=======

The following is an example configuration for an Elasticsearch_ instance with
authentication configured to read from ``my-index`` index.

.. code:: yaml

  - name: elasticsearch
    shortcut: els
    engine: elasticsearch
    base_url: http://localhost:9200
    username: elastic
    password: changeme
    index: my-index
    query_type: match
    # custom_query_json: '{ ... }'
    enable_http: true

Function Documentation

◆ _custom_query()

searx.engines.elasticsearch._custom_query ( query )

protected

Definition at line 156 of file elasticsearch.py.

def _custom_query(query):
    key, value = query.split(':')
    custom_query = custom_query_json
    for query_key, query_value in custom_query.items():
        if query_key == '{{KEY}}':
            custom_query[key] = custom_query.pop(query_key)
        if query_value == '{{VALUE}}':
            custom_query[query_key] = value
    return custom_query
 
 

◆ _match_query()

searx.engines.elasticsearch._match_query ( query )

protected

The standard for full text queries.
SearXNG format: "key:value" e.g. city:berlin
REF: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-match-query.html

Definition at line 101 of file elasticsearch.py.

def _match_query(query):
    """
    The standard for full text queries.
    SearXNG format: "key:value" e.g. city:berlin
    REF: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-match-query.html
    """
 
    try:
        key, value = query.split(':')
    except Exception as e:
        raise ValueError('query format must be "key:value"') from e
 
    return {"query": {"match": {key: {'query': value}}}}
 
 

◆ _simple_query_string_query()

searx.engines.elasticsearch._simple_query_string_query ( query )

protected

Accepts query strings, but it is less strict than query_string
The field used can be specified in index.query.default_field in Elasticsearch.
REF: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-simple-query-string-query.html

Definition at line 116 of file elasticsearch.py.

def _simple_query_string_query(query):
    """
    Accepts query strings, but it is less strict than query_string
    The field used can be specified in index.query.default_field in Elasticsearch.
    REF: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-simple-query-string-query.html
    """
 
    return {'query': {'simple_query_string': {'query': query}}}
 
 

◆ _term_query()

searx.engines.elasticsearch._term_query ( query )

protected

Accepts one term and the name of the field.
searx format: "key:value" e.g. city:berlin
REF: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-term-query.html

Definition at line 126 of file elasticsearch.py.

def _term_query(query):
    """
    Accepts one term and the name of the field.
    searx format: "key:value" e.g. city:berlin
    REF: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-term-query.html
    """
 
    try:
        key, value = query.split(':')
    except Exception as e:
        raise ValueError('query format must be key:value') from e
 
    return {'query': {'term': {key: value}}}
 
 

◆ _terms_query()

searx.engines.elasticsearch._terms_query ( query )

protected

Accepts multiple terms and the name of the field.
searx format: "key:value1,value2" e.g. city:berlin,paris
REF: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-terms-query.html

Definition at line 141 of file elasticsearch.py.

def _terms_query(query):
    """
    Accepts multiple terms and the name of the field.
    searx format: "key:value1,value2" e.g. city:berlin,paris
    REF: https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-terms-query.html
    """
 
    try:
        key, values = query.split(':')
    except Exception as e:
        raise ValueError('query format must be key:value1,value2') from e
 
    return {'query': {'terms': {key: values.split(',')}}}
 
 

◆ init()

searx.engines.elasticsearch.init ( engine_settings )

Definition at line 71 of file elasticsearch.py.

def init(engine_settings):
    if 'query_type' in engine_settings and engine_settings['query_type'] not in _available_query_types:
        raise ValueError('unsupported query type', engine_settings['query_type'])
 
    if index == '':
        raise ValueError('index cannot be empty')
 
 

◆ request()

searx.engines.elasticsearch.request	(		query,
			params )

Definition at line 79 of file elasticsearch.py.

def request(query, params):
    if query_type not in _available_query_types:
        return params
 
    if username and password:
        params['auth'] = (username, password)
 
    args = {
        'from': (params['pageno'] - 1) * page_size,
        'size': page_size,
    }
    data = _available_query_types[query_type](query)
    data.update(args)
 
    params['url'] = f"{base_url}/{index}/_search"
    params['method'] = 'GET'
    params['data'] = dumps(data)
    params['headers']['Content-Type'] = 'application/json'
 
    return params
 
 

◆ response()

EngineResults searx.engines.elasticsearch.response ( SXNG_Response resp )

Definition at line 167 of file elasticsearch.py.

def response(resp: SXNG_Response) -> EngineResults:
    res = EngineResults()
 
    resp_json = loads(resp.text)
    if 'error' in resp_json:
        raise SearxEngineAPIException(resp_json["error"])
 
    for result in resp_json["hits"]["hits"]:
        kvmap = {key: str(value) if not key.startswith("_") else value for key, value in result["_source"].items()}
        if show_metadata:
            kvmap["metadata"] = {"index": result["_index"], "id": result["_id"], "score": result["_score"]}
        res.add(res.types.KeyValue(kvmap=kvmap))
 
    return res
 
 

Variable Documentation

◆ _available_query_types

dict searx.engines.elasticsearch._available_query_types

protected

Initial value:

=  {
    # Full text queries
    # https://www.elastic.co/guide/en/elasticsearch/reference/current/full-text-queries.html
    'match': _match_query,
    'simple_query_string': _simple_query_string_query,
    # Term-level queries
    # https://www.elastic.co/guide/en/elasticsearch/reference/current/term-level-queries.html
    'term': _term_query,
    'terms': _terms_query,
    # Query JSON defined by the instance administrator.
    'custom': _custom_query,
}

Definition at line 183 of file elasticsearch.py.

◆ about

dict searx.engines.elasticsearch.about

Initial value:

=  {
    'website': 'https://www.elastic.co',
    'wikidata_id': 'Q3050461',
    'official_api_documentation': 'https://www.elastic.co/guide/en/elasticsearch/reference/current/search-search.html',
    'use_official_api': True,
    'require_api_key': False,
    'format': 'JSON',
}

Definition at line 52 of file elasticsearch.py.

◆ base_url

str searx.engines.elasticsearch.base_url = 'http://localhost:9200'

Definition at line 61 of file elasticsearch.py.

◆ categories

list searx.engines.elasticsearch.categories = ['general']

Definition at line 49 of file elasticsearch.py.

◆ custom_query_json

dict searx.engines.elasticsearch.custom_query_json = {}

Definition at line 66 of file elasticsearch.py.

◆ index

str searx.engines.elasticsearch.index = ''

Definition at line 64 of file elasticsearch.py.

◆ page_size

int searx.engines.elasticsearch.page_size = 10

Definition at line 68 of file elasticsearch.py.

◆ paging

bool searx.engines.elasticsearch.paging = True

Definition at line 50 of file elasticsearch.py.

◆ password

str searx.engines.elasticsearch.password = ''

Definition at line 63 of file elasticsearch.py.

◆ query_type

str searx.engines.elasticsearch.query_type = 'match'

Definition at line 65 of file elasticsearch.py.

◆ show_metadata

bool searx.engines.elasticsearch.show_metadata = False

Definition at line 67 of file elasticsearch.py.

◆ username

str searx.engines.elasticsearch.username = ''

Definition at line 62 of file elasticsearch.py.

Functions

Variables

Detailed Description

Function Documentation

◆ _custom_query()

◆ _match_query()

◆ _simple_query_string_query()

◆ _term_query()

◆ _terms_query()

◆ init()

◆ request()

◆ response()

Variable Documentation

◆ _available_query_types

◆ about

◆ base_url

◆ categories

◆ custom_query_json

◆ index

◆ page_size

◆ paging

◆ password

◆ query_type

◆ show_metadata

◆ username