AWS Lambda Python函数指定自定义CloudWatch日志组与日志流失败求助

我来帮你排查这个问题，你遇到的情况其实挺常见的，主要是Lambda执行环境的特性和日志初始化时机不对导致的，咱们一步步来解决：

问题根源分析 #

1. Handler初始化位置错误：你把LOGGER.addHandler()放在了lambda_handler函数内部，而Lambda的执行容器是会复用的。每次函数调用时都会重复添加Handler，不仅会导致日志重复输出，还可能干扰日志的正常路由，第一次初始化不彻底的话，后续调用的日志行为会混乱。
2. 默认日志捕获机制：Lambda默认会捕获stdout和stderr的输出并发送到默认日志组，你添加的console_handler就是把日志输出到stdout，这也是为什么日志会出现在默认组的核心原因之一。
3. 日志流创建时机：Watchtower的CloudWatchLogHandler只有在实际发送日志时才会尝试创建日志流，如果权限不足或者初始化有问题，就会导致日志流无法生成。

解决方案步骤 #

1. 修正日志初始化位置 #

把日志Handler的初始化移到函数外部，确保整个容器生命周期内只初始化一次：

import watchtower
import logging

# 初始化日志配置，放在函数外部，仅执行一次
LOGGER = logging.getLogger('sample_logger')
LOGGER.setLevel(logging.INFO)

# 移除console_handler，避免日志被Lambda默认捕获到默认组
# console_handler = logging.StreamHandler()
# LOGGER.addHandler(console_handler)

# 初始化CloudWatch Handler
cw_handler = watchtower.CloudWatchLogHandler(log_group='Pink', stream_name='Panther')
LOGGER.addHandler(cw_handler)

def lambda_handler(event, context):
    LOGGER.info("some message")
    return {"statusCode": 200, "body": "Log sent successfully"}

2. 检查Lambda执行角色权限 #

确保你的Lambda执行角色拥有以下CloudWatch Logs权限（可通过IAM策略添加）：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "logs:CreateLogGroup",
                "logs:CreateLogStream",
                "logs:PutLogEvents"
            ],
            "Resource": "arn:aws:logs:你的区域:你的账号ID:log-group:Pink:*"
        }
    ]
}

虽然你说日志组已经创建，但日志流的创建和日志推送需要CreateLogStream和PutLogEvents权限，这一步不能省略。

3. 验证日志流生成 #

部署修正后的代码后，调用一次Lambda函数，然后去CloudWatch控制台查看Pink日志组，此时应该能看到Panther日志流，并且里面有你输出的日志信息。

额外注意事项 #

• 如果需要同时输出到控制台（方便调试）和自定义日志组，可以保留console_handler，但此时默认日志组仍然会有一份日志，这是Lambda的默认行为。
• 确保你使用的watchtower版本是最新的，旧版本可能存在与Lambda环境兼容的问题，可以通过pip install --upgrade watchtower更新。
• 如果日志还是没有出现，可以在Lambda的监控页面查看是否有权限相关的错误，或者在函数中添加错误捕获来排查：

def lambda_handler(event, context):
    try:
        LOGGER.info("some message")
        return {"statusCode": 200, "body": "Log sent successfully"}
    except Exception as e:
        print(f"Error sending log: {e}")
        raise e

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