GoldenPogacsa/producer
GoldenPogacsa/producer
Archived
7
0
Fork 0
Code Issues Pull Requests Releases Activity

Added logging about failover
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Pünkösd Marcell 2020-04-22 03:59:34 +02:00
parent 49d686a4ec
commit 8a5f9efd08
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
consumerlocator.py
View File

@ -8,6 +8,7 @@ import datetime
from communicator import Communicator from communicator import Communicator
import os import os
from redisconnector import RedisConnector from redisconnector import RedisConnector
import logging
__author__ = "@dscharnitzky" __author__ = "@dscharnitzky"
__copyright__ = "Copyright 2020, GoldenPogácsa Team" __copyright__ = "Copyright 2020, GoldenPogácsa Team"
@ -15,7 +16,7 @@ __module_name__ = "consumerlocator"
__version__text__ = "1" __version__text__ = "1"
KNOWNCONSUMER = os.getenv("PRODUCER_KNOWNCONSUMER", '10.69.42.1') KNOWNCONSUMER = os.getenv("PRODUCER_KNOWNCONSUMER", '10.69.42.1')
LOGGER = logging.getLogger(__name__)
class ConsumerLocator: class ConsumerLocator:
@ -59,6 +60,7 @@ class ConsumerLocator:
contains = True contains = True
if not contains: if not contains:
LOGGER.info(f"Learned about new consumer at {recconsumer}")
consumer_list.append({"Host": recconsumer, "State": True, "LastOk": datetime.datetime.now().timestamp()}) consumer_list.append({"Host": recconsumer, "State": True, "LastOk": datetime.datetime.now().timestamp()})
self.red.consumerlist = consumer_list self.red.consumerlist = consumer_list
@ -109,6 +111,7 @@ class ConsumerLocator:
self.red.currentconsumer = newcurrentconsumer self.red.currentconsumer = newcurrentconsumer
if self.red.currentconsumer is not None: if self.red.currentconsumer is not None:
LOGGER.warning(f"Falling back to consumer at {newcurrentconsumer['Host']}")
self.learnconsumerlist() self.learnconsumerlist()
if self.red.currentconsumer is not None: if self.red.currentconsumer is not None: