Python Azure Blob 直接上传

Question

我正在尝试将 csv 从 Azure blob 以流形式读取到 Python 中，然后直接将其写回 Azure blob。读取操作工作得很好，但写入输出流只是将一个空文件写入 blob。以下代码在 print(df) 之前有效，但在此之后无效。

下面是代码:

代码:

from io import BytesIO, StringIO

with BytesIO() as input_blob:   

  with BytesIO() as output_blob:

    block_blob_service = BlockBlobService(account_name='aaaccc', account_key='*/*/*--')

    block_blob_service.get_blob_to_stream('test', 'Source.csv', input_blob)

    input_blob.seek(0)

    df=pd.read_csv(input_blob)

    print(df)

    copyfileobj(input_blob, output_blob)

    block_blob_service.create_blob_from_stream('test', 'OutFilePy.csv', output_blob)

Answer 1

问题是在pd.read_csv之后，input_blob的光标位于EOF处。因此，copyfileobj只需将任何内容复制到output_blob即可。

您只需在 read_csv 之后添加 input_blob.seek(0) 即可解决此问题。