self/botalka
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: self:bea73c9322eee228524748dd0a48738dd476468f
Branches Tags
self:master
self:prod
self:metric
self:dev
..
compare: self:0112b5c0e4406dd7c08a0994dccaf2816300bc86
Branches Tags
self:master
self:prod
self:metric
self:dev

No commits in common. "bea73c9322eee228524748dd0a48738dd476468f" and "0112b5c0e4406dd7c08a0994dccaf2816300bc86" have entirely different histories.
bea73c9322 ... 0112b5c0e4

4 changed files with 5 additions and 3 deletions
Show Stats Expand all files Collapse all files

2
.deploy/deploy-dev.yaml
View File

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

2
daemons/metrics.py
View File

@ -13,7 +13,7 @@ class Daemon(base.Daemon):
for file in os.listdir('/usr/src/metrics'): for file in os.listdir('/usr/src/metrics'):
data = open(f'/usr/src/metrics/{file}', 'r').read() data = open(f'/usr/src/metrics/{file}', 'r').read()
payload = json.loads(data) 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: if resp.status_code == 202:
print("Metric ok") print("Metric ok")
else: else:

2
run.sh
View File

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

2
utils/queues.py
View File

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