Clm hostname fix

imageroot/actions/set-clm-forwarder/10set

@@ -6,6 +6,7 @@
 #
 
 import subprocess
+import hashlib
 import agent
 import json
 import uuid
@@ -23,6 +24,7 @@ if not bool(subscription):
 
 if (request['active']):
     agent.set_env('CLOUD_LOG_MANAGER_UUID', uuid.uuid5(uuid.NAMESPACE_DNS, cluster_uuid))
+    agent.set_env('CLOUD_LOG_MANAGER_HOSTNAME', 'cluster-' + hashlib.sha256(cluster_uuid.encode("utf-8")).hexdigest()[:8])
     agent.set_env('CLOUD_LOG_MANAGER_ADDRESS', f"{request['address']}")
     agent.set_env('CLOUD_LOG_MANAGER_TENANT', f"{request['tenant']}")
 

imageroot/bin/cloud-log-manager-forwarder

@@ -21,12 +21,11 @@ import sys
 
 try:
     UUID = os.environ.get('CLOUD_LOG_MANAGER_UUID')
+    HOSTNAME = os.environ.get('CLOUD_LOG_MANAGER_HOSTNAME')
     START_TIME = os.environ.get('CLOUD_LOG_MANAGER_START_TIME', '')
     ADDRESS = os.environ.get('CLOUD_LOG_MANAGER_ADDRESS', 'https://nar.nethesis.it')
     TENANT = os.environ.get('CLOUD_LOG_MANAGER_TENANT')
 
-    HOSTNAME = os.popen('hostname').read().rstrip('\n')
-
     os.environ['LOKI_ADDR'] = f"http://127.0.0.1:{os.environ['LOKI_HTTP_PORT']}"
     os.environ['LOKI_USERNAME'] = os.environ['LOKI_API_AUTH_USERNAME']
     os.environ['LOKI_PASSWORD'] = os.environ['LOKI_API_AUTH_PASSWORD']
@@ -120,8 +119,8 @@ while True:
                         # Save log timestamp only when socket send succeed
                         last_timestamp = json_object["timestamp"]
 
-                        # If list size is bigger than 1 MB, send
-                        if sys.getsizeof(logs_list) >= 1048576:
+                        # If list size is bigger than 128 kB, send
+                        if sys.getsizeof(logs_list) >= 131072:
                             send_logs_list(logs_list, last_timestamp)
                             logs_list.clear()
                 except Exception as exc:

imageroot/events/default-instance-changed/10set

@@ -10,6 +10,7 @@ import os
 import sys
 import datetime
 import subprocess
+import hashlib
 
 import agent
 
@@ -40,6 +41,8 @@ if os.getenv("AGENT_EVENT_SOURCE") == 'cluster':
                             stderr=sys.stderr,
                             text=True,
                             check=True)
+
+            agent.unset_env('CLOUD_LOG_MANAGER_HOSTNAME')
 
         # New instance
         if 'current' in data and data['current'] == os.getenv('MODULE_ID'):
@@ -49,7 +52,10 @@ if os.getenv("AGENT_EVENT_SOURCE") == 'cluster':
 
             # If cloud log manager service was active in old instance, start on new instacnce
             if all(key in previous_environment for key in ('CLOUD_LOG_MANAGER_ADDRESS', 'CLOUD_LOG_MANAGER_TENANT', 'CLOUD_LOG_MANAGER_UUID')) and bool(subscription):
+                cluster_uuid = rdb.get('cluster/uuid')
+
                 agent.set_env('CLOUD_LOG_MANAGER_UUID', previous_environment['CLOUD_LOG_MANAGER_UUID'])
+                agent.set_env('CLOUD_LOG_MANAGER_HOSTNAME', 'cluster-' + hashlib.sha256(cluster_uuid.encode("utf-8")).hexdigest()[:8])
                 agent.set_env('CLOUD_LOG_MANAGER_ADDRESS', previous_environment['CLOUD_LOG_MANAGER_ADDRESS'])
                 agent.set_env('CLOUD_LOG_MANAGER_TENANT', previous_environment['CLOUD_LOG_MANAGER_TENANT'])