swh.search.elasticsearch module

swh.search.elasticsearch.token_encode(index_to_tokenize: Dict[bytes, Any]) → str

Tokenize as string an index page result from a search

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

Read the page_token

class swh.search.elasticsearch.ElasticSearch(hosts: List[str])

Bases: object

check()

deinitialize() → None

Removes all indices from the Elasticsearch backend

initialize() → None

Declare Elasticsearch indices and mappings

flush() → None

origin_update(documents: Iterable[Dict]) → None

origin_dump() → Iterator[swh.model.model.Origin]

origin_search(*, url_pattern: Optional[str] = None, metadata_pattern: Optional[str] = None, with_visit: bool = False, page_token: Optional[str] = None, limit: int = 50) → swh.core.api.classes.PagedResult[Dict[str, Any], str]