.deploy/deploy-dev.yaml

@@ -38,3 +38,5 @@ networks:
     external: true
   queues-development:
     external: true
+  monitoring:
+    external: true

daemons/metrics.py

@@ -13,7 +13,7 @@ class Daemon(base.Daemon):
             for file in os.listdir('/usr/src/metrics'):
                 data = open(f'/usr/src/metrics/{file}', 'r').read()
                 payload = json.loads(data)
-                resp = post('http://queues:1239/api/v1/metric', json=payload)
+                resp = post('http://monitoring:1237/api/v1/metrics/task', json=payload)
                 if resp.status_code == 202:
                     print("Metric ok")
                 else:

run.sh

@@ -4,7 +4,7 @@
 python3 main.py $1 &
 
 # Start the second process
-python3 main.py metrics &
+# python3 main.py metrics &
 
 # Wait for any process to exit
 wait -n

utils/queues.py

@@ -60,7 +60,7 @@ class TasksHandlerMixin:
                     print(f'finish task with id {task["id"]}')
                 except:
                     print(f'Failed to finish task id={task["id"]}')
-            self._send_metric(start, end, success)
+            # self._send_metric(start, end, success)
 
     @property
     def queue_name(self):