Browse Source

添加elk日志配置

dongzhaorui 1 year ago
parent
commit
e925f6a583
1 changed files with 3 additions and 2 deletions
  1. 3 2
      FworkSpider/feapder/utils/log.py

+ 3 - 2
FworkSpider/feapder/utils/log.py

@@ -112,7 +112,6 @@ def get_logger(
     @result:
     """
     # 加载setting里最新的值
-    # name = os.path.split(os.getcwd())[-1]
     name = name or setting.LOG_NAME
     path = path or setting.LOG_PATH
     log_level = log_level or setting.LOG_LEVEL
@@ -165,7 +164,9 @@ def get_logger(
         logger.addHandler(rf_handler)
 
     if is_send_to_logstash:
-        logger.addHandler(logstash.TCPLogstashHandler(setting.LOGSTASH_IP, setting.LOGSTASH_PORT, version=1))
+        stash_handler = logstash.TCPLogstashHandler(
+            setting.LOG_STASH_IP, setting.LOG_STASH_PORT, version=1)
+        logger.addHandler(stash_handler)
 
     if color and is_write_to_console:
         loguru_handler = InterceptHandler()