GoldenPogacsa/consumer-scheduler
GoldenPogacsa/consumer-scheduler
Archived
7
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Update 'app.py'
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Kocsis Richárd 2020-04-17 16:25:00 +02:00
parent a60ee01ae1
commit a1ca3285ab
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
app.py
View File

@ -7,6 +7,7 @@ import os
import redis import redis
import json import json
import logging import logging
import socket
""" """
Scheduler Scheduler
@ -36,6 +37,9 @@ def main():
logging.debug('Get consumer list from redis at first: Done') logging.debug('Get consumer list from redis at first: Done')
temp_dict = { } temp_dict = { }
hostname = socket.gethostname()
current_ip = socket.gethostbyname(host_name)
for ip in ip_list: for ip in ip_list:
try: try:
# request synchronization # request synchronization
@ -58,13 +62,12 @@ def main():
ip = info['ip'] ip = info['ip']
try: try:
# request synchronization # request synchronization
response = requests.post(f"http://{ip}/sync", json = { 'uuid': os.environ['LOCAL_UUID'] }) response = requests.post(f"http://{ip}/sync", json={'uuid': os.environ['LOCAL_UUID']})
except requests.exceptions.ConnectionError: except requests.exceptions.ConnectionError:
continue continue
if response.status_code == 200: if response.status_code == 200:
temp_dict[response.json()['uuid']] = { 'ip': ip } temp_dict[response.json()['uuid']] = {'ip': ip}
# update the dictionary of the currently available consumers # update the dictionary of the currently available consumers
consumer_list_redis.update(temp_dict) consumer_list_redis.update(temp_dict)