commit 3a724e37d49be1990fe2432c4ee7751653336c65
author Konrad Grochowski <hcorg@apache.org> Tue Aug 12 11:48:29 2014 -0400
committer Konrad Grochowski <hcorg@apache.org> Mon Sep 29 23:55:47 2014 +0200
tree c3b2d9bb42161874500b2f86591ad5b80ceb885f
parent 485d71acd10b543890ea3114fda5be8cb88a2f0e

THRIFT-2663: py - per module logger used in python lib

Client: Python-Library
Patch: Dustin Spicuzza

This enables per module log message filtering

This closes #187

lib/py/src/TTornado.py

diff --git a/lib/py/src/TTornado.py b/lib/py/src/TTornado.py
index c8498c5..7cd87ed 100644
--- a/lib/py/src/TTornado.py
+++ b/lib/py/src/TTornado.py
@@ -18,10 +18,12 @@
 #
 
 from __future__ import absolute_import
-import logging
 import socket
 import struct
 
+import logging
+logger = logging.getLogger(__name__)
+
 from thrift.transport.TTransport import TTransportException, TTransportBase, TMemoryBuffer
 
 from io import BytesIO
@@ -79,7 +81,7 @@
 
     @gen.coroutine
     def open(self, timeout=None):
-        logging.debug('socket connecting')
+        logger.debug('socket connecting')
         sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM, 0)
         self.stream = iostream.IOStream(sock)
 
@@ -135,9 +137,9 @@
                 if len(frame_header) == 0:
                     raise iostream.StreamClosedError('Read zero bytes from stream')
                 frame_length, = struct.unpack('!i', frame_header)
-                logging.debug('received frame header, frame length = %d', frame_length)
+                logger.debug('received frame header, frame length = %d', frame_length)
                 frame = yield self.stream.read_bytes(frame_length)
-                logging.debug('received frame payload: %r', frame)
+                logger.debug('received frame payload: %r', frame)
                 raise gen.Return(frame)
 
     def write(self, buf):
@@ -176,7 +178,7 @@
                 iprot = self._iprot_factory.getProtocol(tr)
                 yield self._processor.process(iprot, oprot)
         except Exception:
-            logging.exception('thrift exception in handle_stream')
+            logger.exception('thrift exception in handle_stream')
             trans.close()
 
-        logging.info('client disconnected %s:%d', host, port)
+        logger.info('client disconnected %s:%d', host, port)