提交

Author: cnaafhvk

README.md

@@ -19,13 +19,59 @@ HELLOWORLD
 
     demon1
 
-    ```python
-
+    ```
     from logger import Logger
     class MyClass(Logger):
         name = "log_name"
         def __init__(self, settings_file):
             super(MyClass, self).__init__(settings_file)
             self.logger.debug("....")
+    ```
+
+    demon2
+
+    ```
+    import os
+    from logger import CustomLogFactory
+    from cloghandler import ConcurrentRotatingFileHandler
+    my_dir = "logs"
+    try:
+        os.makedirs(my_dir)
+    except OSError as exception:
+        if exception.errno != errno.EEXIST:
+            raise
+    logger = CustomLogFactory.get_instance(name="test_name")
+    logger.set_handler(
+        ConcurrentRotatingFileHandler(
+            os.path.join(my_dir, "test.log"),
+            backupCount=5,
+            maxBytes=10240))
+    logger.info("this is a log. ")
+    ```
+
+    demon3
+
+    ```
+    from logger import CustomLogFactory, KafkaHandler
+    settings = {"KAFKA_HOSTS":"192.168.200.90:9092", "TOPIC":"jay-cluster-logs"}
+    logger = CustomLogFactory.get_instance(name="test_name", json=True)
+    kafka_handler = KafkaHandler(settings)
+    logger.set_handler(kafka_handler)
+    logger.info("this is a log. ")
+    ```
+
+    demon4
+    ```
+    import sys
+    import logging
+    from logger import CustomLogFactory
+    logger = CustomLogFactory.get_instance(name="test_name")
+    logger.set_handler(logging.StreamHandler(sys.stdout))
+    logger.info("this is a log. ")
+    ```
 
-```
+    demon5
+    ```
+    # 编写自定义handler
+    # 请参见KafkaHandler的实现方式
+    ```

logger.py

@@ -10,7 +10,6 @@
 import inspect
 from functools import wraps
 from kafka import KafkaClient, SimpleProducer
-from argparse import ArgumentParser
 from kafka.common import FailedPayloadsError
 from cloghandler import ConcurrentRotatingFileHandler
 from scutils.log_factory import LogFactory, LogObject
@@ -142,15 +141,18 @@ def set_logger(self, logger=None):
                     maxBytes=my_bytes))
 
 
-class SignalLogger(Logger):
+class ThreadClosing(object):
 
     alive = True
 
-    def __init__(self, settings):
-        super(SignalLogger, self).__init__(settings)
+    def __init__(self):
         self.threads = []
         self.int_signal_count = 1
         self.open()
+        self.logger = LogFactory.get_instance()
+
+    def set_logger(self, logger):
+        self.logger = logger
 
     def stop(self, *args):
         if self.int_signal_count > 1:
@@ -169,14 +171,6 @@ def open(self):
     def set_force_interrupt(self, thread):
         self.threads.append(thread)
 
-    @classmethod
-    def parse_args(cls):
-        parser = ArgumentParser()
-        parser.add_argument("-s", "--settings", dest="settings", help="settings", default="settings_kafkadump.py")
-        parser.add_argument("-c", "--consumer", required=False, dest="consumer", help="comsumer id")
-        parser.add_argument("-t", "--topic", required=True, dest="topic", help="topic")
-        return cls(**vars(parser.parse_args()))
-
     def _async_raise(self, name, tid, exctype):
         """raises the exception, performs cleanup if needed"""
         tid = ctypes.c_long(tid)