GCP Cloud Jobs中Python日志被拆分为多行如何解决？

以下是几个实用的解决办法：

• 清理日志消息中的换行符
  若日志内容本身包含\n这类换行符，GCP日志系统会直接将其拆分为多条日志。输出前可把换行符替换为空格或其他分隔符，示例：

  log.info("你的日志内容".replace("\n", " "))
  

• 使用Google Cloud Logging官方库替代原生logging
  原生Python logging模块的输出逻辑和GCP日志采集管道存在兼容问题，容易导致日志被逐行拆分。使用官方google-cloud-logging库，能将日志作为完整条目发送，从根源避免拆分。示例代码：

  import google.cloud.logging
  from google.cloud.logging_v2.handlers import CloudLoggingHandler
  import logging
  
  # 初始化GCP日志客户端
  client = google.cloud.logging.Client()
  # 创建Cloud Logging处理器
  handler = CloudLoggingHandler(client)
  
  log = logging.getLogger()
  # 移除原有处理器避免重复输出
  for old_handler in log.handlers[:]:
      log.removeHandler(old_handler)
  # 添加官方处理器
  log.addHandler(handler)
  log.setLevel(logging.INFO)
  
  # 应用你原有的日志格式
  log_formatter = logging.Formatter(
      "[%(process)d] [%(threadName)s] %(asctime)s %(name)s: %(message)s"
  )
  handler.setFormatter(log_formatter)
  

• 调整原生logging的输出终止符
  若坚持使用原生logging，可修改StreamHandler的终止符，确保每条日志仅输出一行：

  import logging
  from logging import StreamHandler
  
  log = logging.getLogger()
  log_formatter = logging.Formatter(
      "[%(process)d] [%(threadName)s] %(asctime)s %(name)s: %(message)s"
  )
  
  # 重新设置处理器，强制终止符为空
  for handler in log.handlers[:]:
      log.removeHandler(handler)
  stream_handler = StreamHandler()
  stream_handler.setFormatter(log_formatter)
  # 取消自动添加换行，让日志内容自己控制格式
  stream_handler.terminator = ""
  log.addHandler(stream_handler)
  log.setLevel(logging.INFO)
  

内容的提问来源于stack exchange，提问作者gd vigneshwar