如何将Automation Anywhere A360日志推送至Cloud Logging？

1. 复用GCP客户端连接，避免每次初始化 #

不要每次推送单条日志就启动一次Python脚本，改成让脚本保持长连接并持续处理日志：

• 让Python脚本常驻后台，监听本地日志文件的新增内容（比如用watchdog库监控文件变化，或者循环读取日志的末尾新增行），初始化一次GCP Cloud Logging客户端后，持续推送新产生的日志条目，直到手动停止脚本。
• 示例思路：

  import google.cloud.logging
  import time
  import os
  
  # 仅初始化一次客户端
  client = google.cloud.logging.Client()
  logger = client.logger("a360-bot-log")
  
  LOG_FILE_PATH = "C:/path/to/your/log.txt"
  # 记录上次读取的文件位置
  last_pos = os.path.getsize(LOG_FILE_PATH)
  
  while True:
      with open(LOG_FILE_PATH, "r") as f:
          f.seek(last_pos)
          new_lines = f.readlines()
          if new_lines:
              for line in new_lines:
                  logger.log_text(line.strip())
              last_pos = f.tell()
      time.sleep(1)
  

• A360只需正常写入本地日志，无需每次调用脚本，由常驻脚本自动处理推送。

2. 批量推送日志，减少连接次数 #

在A360流程中缓存日志条目，达到阈值后一次性推送：

• 用A360的列表变量临时存储日志内容，当日志条数达到设定值（比如50条）或每隔固定时间（比如5分钟），再调用Python脚本一次性推送所有缓存的日志。
• 脚本接收批量日志参数，初始化一次客户端后批量写入Cloud Logging，避免每次单条日志都触发连接初始化。

3. 部署GCP Ops Agent（推荐方案） #

在每台Windows Bot Runner上部署GCP Ops Agent，让代理自动采集并转发本地日志，完全无需修改A360流程：

• 安装Ops Agent：下载对应Windows版本的安装包，执行静默安装（msiexec /i ops-agent-windows-amd64.msi /qn）。
• 配置日志采集：在C:\Program Files\Google\Cloud Operations\Ops Agent\config\config.yaml中添加日志采集规则，示例如下（针对txt日志）：

  logging:
    receivers:
      a360_bot_log:
        type: files
        include_paths:
          - "C:/path/to/your/bot/logs/*.txt"
        record_log_file_path: true
    processors:
      parse_a360_log:
        type: parse_regex
        regex: "^(?P<timestamp>\\d{4}-\\d{2}-\\d{2} \\d{2}:\\d{2}:\\d{2}) - (?P<level>[A-Z]+) - (?P<message>.*)$"
    service:
      pipelines:
        default_pipeline:
          receivers: [a360_bot_log]
          processors: [parse_a360_log]
  

• 重启Ops Agent服务（net restart google-cloud-ops-agent），代理会持续监控日志文件，自动批量推送至Cloud Logging，自带连接复用、缓存和重试机制，彻底消除脚本调用的连接耗时。

4. 优化Python脚本的认证与初始化 #

如果必须保留脚本调用的方式，优化初始化逻辑：

• 使用服务账号密钥文件认证，确保脚本只加载一次密钥，避免重复读取或认证流程：

  import google.cloud.logging
  
  # 全局初始化客户端，仅执行一次
  client = google.cloud.logging.Client.from_service_account_json("path/to/service-account-key.json")
  logger = client.logger("a360-bot-log")
  
  def push_logs(log_entries):
      logger.log_entries([{"text_payload": entry} for entry in log_entries])
  

• 禁用GCP客户端的不必要调试日志或重试机制，减少初始化时的额外开销。

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