From 77d4f7cac2ef5a5607bb2935ad49a81c4c9ac59f Mon Sep 17 00:00:00 2001 From: Clark Boylan Date: Thu, 5 Mar 2015 11:14:15 -0800 Subject: [PATCH] Lazily connect to logstash Because boot order is such a mess we will lazily connect to the logstash TCP/UDP ports to allow for logstash to come up before we start writing to it. This takes advantage of existing logstash restart handler code in the log processors. Change-Id: I836c55806c88cc86b7973b3d40f4bfce076970f5 --- log_processor/worker.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/log_processor/worker.py b/log_processor/worker.py index 428ab83..74acc00 100644 --- a/log_processor/worker.py +++ b/log_processor/worker.py @@ -299,7 +299,7 @@ class INETLogProcessor(object): self.logq = logq self.host = host self.port = port - self._connect_socket() + self.socket = None def _connect_socket(self): logging.debug("Creating socket.") @@ -309,6 +309,8 @@ class INETLogProcessor(object): def handle_log_event(self): log = self.logq.get() try: + if self.socket is None: + self._connect_socket() self.socket.sendall((json.dumps(log) + '\n').encode('utf-8')) except: logging.exception("Exception sending INET event.")