diff --git a/app.py b/app.py index 3162c61..ddf3390 100644 --- a/app.py +++ b/app.py @@ -7,6 +7,7 @@ import os import redis import json import logging +import socket """ Scheduler @@ -35,6 +36,9 @@ def main(): consumer_list_redis = json.loads((r.get('consumer_list') or b'{}').decode('utf-8')) logging.debug('Get consumer list from redis at first: Done') temp_dict = { } + + hostname = socket.gethostname() + current_ip = socket.gethostbyname(host_name) for ip in ip_list: try: @@ -58,13 +62,12 @@ def main(): ip = info['ip'] try: # 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: continue 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 consumer_list_redis.update(temp_dict)