in src/qldb_streaming_to_es_sample/clients/elasticsearch.py [0:0]
def __init__(self, host, awsauth):
self.es_client = Elasticsearch(
hosts=[{'host': host, 'port': 443}],
http_auth=awsauth,
use_ssl=True,
verify_certs=True,
connection_class=RequestsHttpConnection,
retry_on_timeout=True,
max_retries=3
)