def __init__()

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
        )