fix
This commit is contained in:
22
daemons/metrics.py
Normal file
22
daemons/metrics.py
Normal file
@@ -0,0 +1,22 @@
|
||||
import os
|
||||
|
||||
from requests import post
|
||||
import json
|
||||
|
||||
from daemons import base
|
||||
|
||||
|
||||
class Daemon(base.Daemon):
|
||||
|
||||
def execute(self):
|
||||
while True:
|
||||
for file in os.listdir('/usr/src/metrics'):
|
||||
data = open(f'/usr/src/metrics/{file}', 'r').read()
|
||||
payload = json.loads(data)
|
||||
resp = post('http://monitoring:1237/api/v1/metrics/task', json=payload)
|
||||
if resp.status_code == 202:
|
||||
print("Metric ok")
|
||||
else:
|
||||
print(f'metric not ok: {resp.status_code}')
|
||||
os.remove(f'/usr/src/metrics/{file}')
|
||||
break
|
||||
Reference in New Issue
Block a user