From 25b418da5aa175db131775657317b0cdd27b7034 Mon Sep 17 00:00:00 2001
From: Tommy Burke <Tommy.Burke@kyndryl.com>
Date: Wed, 27 Apr 2022 16:30:19 +0100
Subject: [PATCH] Updated Handlers.py for elasticsearch 8.0

changed from RequestsHttpConnection to RequestsHttpNode as 'RequestsHttpConnection' was removed from 'elasticsearch' and is replaced with RequestsHttpNode from elastic_transport https://github.com/elastic/elasticsearch-py/issues/1778#issuecomment-1055882291
---
 elasticecslogging/handlers.py | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/elasticecslogging/handlers.py b/elasticecslogging/handlers.py
index 0e2f653..9bab95c 100644
--- a/elasticecslogging/handlers.py
+++ b/elasticecslogging/handlers.py
@@ -11,7 +11,8 @@
 import uuid
 from threading import Timer, Lock
 
-from elasticsearch import Elasticsearch, RequestsHttpConnection
+from elasticsearch import Elasticsearch
+from elastic_transport import RequestsHttpNode
 from elasticsearch import helpers as eshelpers
 from enum import Enum
 
@@ -261,7 +262,7 @@ def __get_es_client(self):
                 self._client = Elasticsearch(hosts=self.hosts,
                                              use_ssl=self.use_ssl,
                                              verify_certs=self.verify_certs,
-                                             connection_class=RequestsHttpConnection,
+                                             connection_class=RequestsHttpNode,
                                              serializer=self.serializer)
             return self._client
 
@@ -271,7 +272,7 @@ def __get_es_client(self):
                                      http_auth=self.auth_details,
                                      use_ssl=self.use_ssl,
                                      verify_certs=self.verify_certs,
-                                     connection_class=RequestsHttpConnection,
+                                     connection_class=RequestsHttpNode,
                                      serializer=self.serializer)
             return self._client
 
@@ -282,7 +283,7 @@ def __get_es_client(self):
             return Elasticsearch(hosts=self.hosts,
                                  use_ssl=self.use_ssl,
                                  verify_certs=self.verify_certs,
-                                 connection_class=RequestsHttpConnection,
+                                 connection_class=RequestsHttpNode,
                                  http_auth=HTTPKerberosAuth(mutual_authentication=DISABLED),
                                  serializer=self.serializer)
 
@@ -296,7 +297,7 @@ def __get_es_client(self):
                     http_auth=awsauth,
                     use_ssl=self.use_ssl,
                     verify_certs=True,
-                    connection_class=RequestsHttpConnection,
+                    connection_class=RequestsHttpNode,
                     serializer=self.serializer
                 )
             return self._client