soil.connectors.elastic_search

Package for Elastic Search Connector

ElasticSearchDBObject Objects#

class ElasticSearchDBObject()

Represents an Elastic Search Data Base Object.

bulk#

| bulk(actions: Iterable[Any]) -> Any

Performs actions in bulk as defined in the ES bulk API.

query#

| query(query: Any, random_sorting: bool = False) -> Any

Launches a query to ES. Returns the query.

insert#

| insert(document: Any, id: Optional[str] = None) -> Any

Inserts a document to ES.

update_query#

| update_query(new_partial_query: Any) -> Any

Updates a query without executing it.

create_db_object#

create_db_object(index: str, force_rewrite: bool = False) -> ElasticSearchDBObject

Obtains an Elastic Search DB object. Only works on cloud.