Removed unecessary comments and fix a typo

Author: ajacquemot

aws/logs_monitoring/lambda_function.py

@@ -64,7 +64,7 @@
 
 # http specific
 DD_USE_HTTP = True
-DD_BATCH_SIZE = "10"
+DD_BATCH_SIZE = 10
 
 # Pass custom tags as environment variable, ensure comma separated, no trailing comma in envvar!
 DD_TAGS = os.environ.get("DD_TAGS", "")
@@ -143,13 +143,13 @@ class DatadogHTTPClient(object):
     _POST = "POST"
     _HEADERS = {"Content-type": "application/json"}
 
-    def __init__(self, host, apiKey, timeout=1, max_retries=1, backoff=0.5):
+    def __init__(self, host, apiKey, timeout=10, max_retries=1, backoff=0.5):
         self._url = "https://{}/v1/input/{}".format(host, apiKey)
         self._session = requests.Session()
         self._session.headers.update(self._HEADERS)
-        self._timeout = timeout if timeout > 0 else 1
-        self._max_retries = max_retries if max_retries >= 0 else 1
-        self._backoff = backoff if backoff > 0 else 0.5
+        self._timeout = timeout
+        self._max_retries = max_retries
+        self._backoff = backoff
 
     def send(self, batch, metadata=None):
         """
@@ -159,23 +159,16 @@ def send(self, batch, metadata=None):
         body = json.dumps(batch)
         for retry in range(1 + self._max_retries):
             if retry > 0:
-                print("Retrying, retry: {}, max: {}".format(retry, self._max_retries))
                 time.sleep(self._backoff)
             try:
                 resp = self._session.post(
                     self._url, data=body, params=metadata, timeout=self._timeout
                 )
             except Exception as e:
                 # most likely a network error
-                print("Unexpected exception: {}".format(str(e)))
                 continue
             if resp.status_code >= 500:
                 # server error
-                print(
-                    "Server error, status {}, reason: {}".format(
-                        resp.status_code, resp.reason
-                    )
-                )
                 continue
             elif resp.status_code >= 400:
                 # client error
@@ -207,10 +200,7 @@ def batch(self, logs):
         each batch contains at most max_size logs.
         """
         batches = []
-        if len(logs) % self._max_size != 0:
-            nb_batchs = int(len(logs) / self._max_size) + 1
-        else:
-            nb_batchs = int(len(logs) / self._max_size)
+        nb_batchs = int(len(logs) / self._max_size) + 1
         for i in range(0, nb_batchs):
             l = i * self._max_size
             r = (i + 1) * self._max_size