- added back the use of sessions to improve the performance and reuse of open ports

Author: gregorleban

eventregistry/EventRegistry.py

@@ -49,6 +49,7 @@ def __init__(self,
 
         # lock for making sure we make one request at a time - requests module otherwise sometimes returns incomplete json objects
         self._lock = threading.Lock()
+        self._reqSession = requests.Session()
         self._apiKey = apiKey
         self._extraParams = None
 
@@ -86,7 +87,7 @@ def checkVersion(self):
         check what is the latest version of the python sdk and report in case there is a newer version
         """
         try:
-            respInfo = requests.get(self._host + "/static/pythonSDKVersion.txt")
+            respInfo = self._reqSession.get(self._host + "/static/pythonSDKVersion.txt")
             if respInfo.status_code != 200 or len(respInfo.text) > 20:
                 return
             latestVersion = respInfo.text.strip()
@@ -258,7 +259,7 @@ def jsonRequest(self, methodUrl, paramDict, customLogFName = None, allowUseOfArc
                 url = self._host + methodUrl
 
                 # make the request
-                respInfo = requests.post(url, json = paramDict)
+                respInfo = self._reqSession.post(url, json = paramDict)
                 # remember the returned headers
                 self._headers = respInfo.headers
                 # if we got some error codes print the error and repeat the request after a short time period
@@ -311,7 +312,7 @@ def jsonRequestAnalytics(self, methodUrl, paramDict):
             tryCount += 1
             try:
                 # make the request
-                respInfo = requests.post(self._hostAnalytics + methodUrl, json = paramDict)
+                respInfo = self._reqSession.post(self._hostAnalytics + methodUrl, json = paramDict)
                 # remember the returned headers
                 self._headers = respInfo.headers
                 # if we got some error codes print the error and repeat the request after a short time period