elasticsearch.py

ElasticSearch object

def __init__(self, url, endpoint = None)

Example:

ElasticSearch('https://some-es.server', )

list

GET from the given ElasticSearch object, endpoint not required.

async def list(self, endpoint = None):```

Example:

async list(endpoint = 'products/')

store

POST to the given ElasticSearch object at the specified endpoint.

async def store(self, endpoint, data):

Example:

await store('products/', ['stuff', 'stuff again', 2, False])