swh.search.elasticsearch module

swh.search.elasticsearch.token_encode(index_to_tokenize: Dict[bytes, Any]) → str[source]: Tokenize as string an index page result from a search

swh.search.elasticsearch.token_decode(page_token: str) → Dict[bytes, Any][source]: Read the page_token

class swh.search.elasticsearch.ElasticSearch(hosts: List[str], indexes: Dict[str, Dict[str, str]] = {})[source]

deinitialize() → None[source]: Removes all indices from the Elasticsearch backend

initialize() → None[source]: Declare Elasticsearch indices, aliases and mappings

origin_update(documents: Iterable[swh.search.interface.OriginDict]) → None[source]

origin_search(*, query: str = '', url_pattern: Optional[str] = None, metadata_pattern: Optional[str] = None, with_visit: bool = False, visit_types: Optional[List[str]] = None, min_nb_visits: int = 0, min_last_visit_date: str = '', min_last_eventful_visit_date: str = '', min_last_revision_date: str = '', min_last_release_date: str = '', min_date_created: str = '', min_date_modified: str = '', min_date_published: str = '', programming_languages: Optional[List[str]] = None, licenses: Optional[List[str]] = None, keywords: Optional[List[str]] = None, sort_by: Optional[List[str]] = None, page_token: Optional[str] = None, limit: int = 50) → swh.core.api.classes.PagedResult[swh.search.interface.MinimalOriginDict, str][source]