Update __init__.py

Added "hosts" parameter
jertel · Oct 22, 2021 · 246aa14 · 246aa14
1 parent 8aa3b59
commit 246aa14
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/elastalert/__init__.py b/elastalert/__init__.py
@@ -16,7 +16,8 @@ def __init__(self, conf):
         """
         :arg conf: es_conn_config dictionary. Ref. :func:`~util.build_es_conn_config`
         """
-        super(ElasticSearchClient, self).__init__(host=conf['es_host'],
+        super(ElasticSearchClient, self).__init__(host=conf.get('es_host', None),
+                                                  hosts=conf.get('es_hosts', []),
                                                   port=conf['es_port'],
                                                   url_prefix=conf['es_url_prefix'],
                                                   use_ssl=conf['use_ssl'],