使用boto3在Lambda脚本中批量更新多资源标签仅生效最后一项的修复方法

你的代码存在两个核心问题，导致仅能更新部分资源（或最后一个资源）的标签：

1. 未处理资源分页查询 #

get_resources接口默认分页返回结果，你当前仅调用一次接口，只能获取第一页最多100个资源。若账号内资源数量超过100，后续资源完全不会被遍历到；此外如果循环中因异常中断，也会导致前面的资源未完成更新。

2. 缺少异常捕获机制 #

如果某个资源的标签更新请求失败（比如权限不足、资源不存在），会直接抛出异常终止Lambda执行，后续所有资源的更新操作都会被中断。

修复后的完整代码 #

import boto3

s3_client = boto3.client('s3')
client = boto3.client('resourcegroupstaggingapi')

def get_resource_tag(resource_name):
    # 替换为从Excel读取对应资源标签的逻辑
    # 示例：根据资源ARN返回对应的标签键值对，需保证格式为 [tag_key, tag_value]
    return ['uniqueexample', f'value_{resource_name[-10:]}']

def update_resources_dict(resource):
    resource_name = resource["ResourceARN"]
    try:
        tag_to_update = get_resource_tag(resource_name)
        # 校验标签格式有效性
        if len(tag_to_update) != 2:
            print(f"资源{resource_name}的标签格式错误，跳过更新")
            return None
        
        tag_key, tag_value = tag_to_update
        # 调用标签更新接口
        response = client.tag_resources(
            ResourceARNList=[resource_name],
            Tags={tag_key: tag_value}
        )
        
        # 检查是否有更新失败的资源
        if 'FailedResourcesMap' in response and response['FailedResourcesMap']:
            print(f"资源{resource_name}标签更新失败: {response['FailedResourcesMap']}")
        return response
    except Exception as e:
        print(f"处理资源{resource_name}时出错: {str(e)}")
        return None

def lambda_handler(event, context):
    pagination_token = None
    while True:
        # 分页获取所有资源
        if pagination_token:
            all_resources = client.get_resources(
                ResourcesPerPage=100,
                PaginationToken=pagination_token
            )
        else:
            all_resources = client.get_resources(ResourcesPerPage=100)
        
        # 遍历当前页的所有资源并更新标签
        for resource in all_resources["ResourceTagMappingList"]:
            update_resources_dict(resource)
        
        # 判断是否还有下一页资源
        if 'PaginationToken' not in all_resources or not all_resources['PaginationToken']:
            break
        pagination_token = all_resources['PaginationToken']
    
    print("所有资源标签更新处理完成")

关键修复点说明 #

• 全量资源遍历：通过PaginationToken循环调用get_resources，确保获取账号内所有资源，不会遗漏分页数据。
• 异常隔离处理：在单个资源更新逻辑中添加try-except块，单个资源更新失败不会中断整个流程，同时打印错误信息便于排查问题。
• 参数有效性校验：检查标签返回格式，避免因格式错误导致的无效更新请求。
• 更新结果校验：通过FailedResourcesMap捕获更新失败的资源，及时记录异常信息。

另外，你需要将get_resource_tag函数替换为实际的Excel读取逻辑：比如先从S3下载Excel文件，使用pandas或openpyxl读取内容，根据资源ARN匹配对应的标签键值对。

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