通过boto3同步两个存储桶

import boto3
from botocore.exceptions import ClientError

def sync_buckets(src_bucket, dest_bucket):
    s3_client = boto3.client('s3')
    
    try:
        # 获取源存储桶中的所有对象
        paginator = s3_client.get_paginator('list_objects_v2')
        for page in paginator.paginate(Bucket=src_bucket):
            if 'Contents' in page:
                for obj in page['Contents']:
                    copy_source = {'Bucket': src_bucket, 'Key': obj['Key']}
                    s3_client.copy_object(CopySource=copy_source, Bucket=dest_bucket, Key=obj['Key'])
                    print(f"Copied {obj['Key']} from {src_bucket} to {dest_bucket}")
    except ClientError as e:
        print(f"Error: {e}")

# 示例调用
sync_buckets('source-bucket-name', 'destination-bucket-name')