This commit is contained in:
parent
9d94dbd6d6
commit
aed27cba95
2
app.py
2
app.py
@ -78,8 +78,10 @@ def main():
|
|||||||
# wait for the next update time
|
# wait for the next update time
|
||||||
|
|
||||||
if current_ip != socket.gethostbyname(host_name):
|
if current_ip != socket.gethostbyname(host_name):
|
||||||
|
logging.debug('Check ip : Done')
|
||||||
current_ip = socket.gethostbyname(host_name)
|
current_ip = socket.gethostbyname(host_name)
|
||||||
keys = redis.keys('producer_*')
|
keys = redis.keys('producer_*')
|
||||||
|
logging.debug('Get producer list from redis: Done')
|
||||||
for key in keys:
|
for key in keys:
|
||||||
ip = redis.get(key)
|
ip = redis.get(key)
|
||||||
if not ip:
|
if not ip:
|
||||||
|
Reference in New Issue
Block a user