GCP存储中的重复文件名

from google.cloud import storage
import uuid

def upload_blob(bucket_name, source_file_name, destination_blob_name):
    """Uploads a file to the bucket."""
    storage_client = storage.Client()
    bucket = storage_client.bucket(bucket_name)
    blob = bucket.blob(destination_blob_name)

    # Check if the blob already exists
    if blob.exists():
        # Generate a unique filename
        destination_blob_name = f"{destination_blob_name}_{uuid.uuid4().hex[:6]}"
        blob = bucket.blob(destination_blob_name)

    blob.upload_from_filename(source_file_name)
    print(f"File {source_file_name} uploaded to {destination_blob_name}.")

def upload_blob_with_metadata(bucket_name, source_file_name, destination_blob_name):
    storage_client = storage.Client()
    bucket = storage_client.bucket(bucket_name)
    blob = bucket.blob(destination_blob_name)

    # Add custom metadata
    metadata = {"original_filename": source_file_name}
    blob.metadata = metadata

    blob.upload_from_filename(source_file_name)
    print(f"File {source_file_name} uploaded to {destination_blob_name} with metadata.")

def migrate_data(source_bucket_name, destination_bucket_name):
    source_storage_client = storage.Client()
    destination_storage_client = storage.Client()
    source_bucket = source_storage_client.bucket(source_bucket_name)
    destination_bucket = destination_storage_client.bucket(destination_bucket_name)

    blobs = source_bucket.list_blobs()
    for blob in blobs:
        destination_blob_name = blob.name
        if destination_bucket.blob(destination_blob_name).exists():
            # Generate a unique filename
            destination_blob_name = f"{blob.name}_{uuid.uuid4().hex[:6]}"
        new_blob = destination_bucket.blob(destination_blob_name)
        new_blob.rewrite(blob)
        print(f"Migrated {blob.name} to {destination_blob_name}.")