部分Go日志无法同步至SUMO的问题排查求助

问题描述 #

我在Cloud Function中通过log.AddHook()配置了与SUMO日志的连接，大部分日志能正常同步到SUMO，但存在部分日志仅出现在Cloud Function日志中，未同步至SUMO。具体情况：

• Init()函数负责初始化日志钩子
• 主函数调用文件读取函数funcFileReader，其中的"file complete"日志能正常同步到SUMO
• 但funcFileReader中调用的sendMessage函数内的"message sent"日志无法同步到SUMO
• 怀疑调用栈中丢失了日志钩子，尝试调整日志位置、调试logrus对象，但无法查看logrus对象的调试值

相关代码片段：

func funcFileReader(...){

    for _, line := range file {
        if condition {
            sendMessage(...)
        }
    }
    // ... 其他代码 ...
    log.WithFields(log.Fields{
        "EOF":            true,
        "fileType":       fileType.ToString(),
        // ... 其他字段
    }).Info("file complete")
}

func sendMessage(...) Document {
    log.WithFields(log.Fields{
        "accountNumber": ...,
        "fileDate":      ...,
        "fileType":      ...,
    }).Info("message sent")
}

排查与解决步骤 #

1. 确认logrus实例一致性 #

检查sendMessage中使用的log对象是否和Init()中添加钩子的是同一个全局实例：

• 避免在代码中创建新的logrus实例（比如logrus.New()），如果sendMessage里用了局部实例，钩子不会生效
• 确保全局log变量在Init()中正确添加了SUMO钩子，没有被后续代码重新赋值覆盖

2. 检查异步调用导致的生命周期问题 #

如果sendMessage是异步执行（比如用goroutine），Cloud Function可能在日志钩子完成发送前就结束了：

• 同步等待所有sendMessage执行完成再结束函数，比如用sync.WaitGroup：

func funcFileReader(...){
    var wg sync.WaitGroup
    for _, line := range file {
        if condition {
            wg.Add(1)
            go func(line ...) {
                defer wg.Done()
                sendMessage(...)
            }(line)
        }
    }
    wg.Wait() // 等待所有异步调用完成
    
    // ... 其他代码 ...
    log.WithFields(...).Info("file complete")
}

• 调整Cloud Function的执行超时时间，确保足够覆盖所有日志发送的时间

3. 调试logrus钩子状态 #

如果无法直接查看logrus对象的调试值，可以通过以下方式验证钩子是否存在：

• 在Init()之后、sendMessage调用前，添加代码打印全局log实例的钩子数量：

// 打印当前钩子数量，确认钩子已添加
fmt.Printf("Current log hooks count: %d\n", len(log.Hooks))

• 在SUMO钩子的Fire方法中添加本地日志（比如打印到Cloud Function日志），确认是否收到了"message sent"的日志事件

4. 检查日志级别与字段过滤 #

确认SUMO钩子是否配置了日志级别过滤，或者字段过滤规则：

• 检查钩子是否只处理特定级别（比如只处理Info及以上，但sendMessage的日志级别是否被误设为Debug）
• 确认sendMessage中的日志字段是否符合SUMO钩子的过滤规则，没有被钩子忽略

5. 检查Cloud Function资源限制 #

Cloud Function的网络限制可能导致日志发送失败：

• 确认Cloud Function的VPC配置允许访问SUMO的日志端点
• 检查是否有防火墙规则阻止了出站请求到SUMO服务器

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