23 lines
642 B
Python
23 lines
642 B
Python
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://queues:1239/api/v1/metric', 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
|