Python读取Azure Blob CSV流后写入空文件问题求助

嘿，我看你遇到了把Azure Blob里的CSV流读取处理后，写回去变成空文件的问题——刚好之前也踩过这个坑！核心问题其实很简单，大概率是输出流的指针位置没重置，再加上可能的流类型和编码配合问题，我给你详细拆解下：

问题根源 #

当你往output_blob这个BytesIO流里写完内容后，流的指针会停在内容的最后一位。这时候直接调用Blob服务的上传方法，它会从指针当前位置开始读取，自然读不到任何内容，最后就生成了空文件。另外，如果用pandas处理CSV时，写入BytesIO没指定编码，也可能导致内容写入出现隐形异常。

修正后的完整代码 #

我把你的代码补全并修正了关键问题，你可以参考：

from io import BytesIO
import pandas as pd
from azure.storage.blob import BlockBlobService

# 初始化Blob服务（替换成你的账号信息）
block_blob_service = BlockBlobService(account_name='aaaccc', account_key='你的密钥')

# 读取Blob到输入流
with BytesIO() as input_blob:
    # 把Blob内容读取到输入流
    block_blob_service.get_blob_to_stream(
        container_name='你的容器名称',
        blob_name='源CSV文件名.csv',
        stream=input_blob
    )
    # 重置输入流指针到开头，pandas才能正确读取
    input_blob.seek(0)
    # 读取CSV为DataFrame
    df = pd.read_csv(input_blob)
    print(df)  # 这里正常输出说明读取没问题

    # 写入到输出流并上传
    with BytesIO() as output_blob:
        # 将DataFrame写入BytesIO，指定编码避免乱码
        df.to_csv(output_blob, index=False, encoding='utf-8')
        # 最关键的一步：把输出流指针移回开头！
        output_blob.seek(0)
        # 上传到目标Blob
        block_blob_service.create_blob_from_stream(
            container_name='你的容器名称',
            blob_name='目标CSV文件名.csv',
            stream=output_blob
        )

几个关键注意点 #

• 必须重置流指针：不管是读取后的输入流，还是写入后的输出流，都要调用seek(0)把指针移到流的起始位置，这样后续的读取/上传操作才能获取到完整内容。
• 编码要明确：写入CSV到BytesIO时，指定encoding='utf-8'（或你实际使用的编码），避免文本转二进制时出现编码错误。
• 库版本兼容：如果你用的是新版azure-storage-blob（12.x+），BlockBlobService已经被弃用，建议改用BlobClient，但核心逻辑还是写完流后seek(0)再上传。

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