Add endpoint information to logs

singnet · Aug 19, 2024 · 39c6162 · 39c6162
1 parent 9188215
commit 39c6162
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/service_status/service_status.py b/service_status/service_status.py
@@ -78,7 +78,7 @@ def _update_service_failed_status_count(self, failed_status_count, row_id):
         response = self.repo.execute(update_query, [failed_status_count, row_id])
         return response
 
-    def _send_logs_to_opensearch(self, service_id, debug_error_string):
+    def _send_logs_to_opensearch(self, service_id, debug_error_string, endpoint):
         client = OpenSearch(
             http_compress = True,
             hosts = [{'host': HOST, 'port': 443}],
@@ -102,7 +102,8 @@ def _send_logs_to_opensearch(self, service_id, debug_error_string):
         document = {
             '@timestamp': timestamp,
             'Log': debug_error_string,
-            'Service': service_id
+            'Service': service_id,
+            'Endpoint': endpoint
         }
         response = client.index(
             index = index_name,
@@ -150,7 +151,7 @@ def update_service_status(self):
                 org_id = record["org_id"]
                 service_id = record["service_id"]
                 recipients = self._get_service_provider_email(org_id=org_id, service_id=service_id)
-                self._send_logs_to_opensearch(service_id=service_id, debug_error_string=debug_error_string)
+                self._send_logs_to_opensearch(service_id=service_id, debug_error_string=debug_error_string, endpoint=record["endpoint"])
                 if failed_status_count <= 10:
                     self._send_notification(org_id=org_id, service_id=service_id, recipients=recipients,
                                             endpoint=record["endpoint"], error_details=error_details,