Python Azure Blob 直接上传

Question

我正在尝试将 Azure blob 中的 csv 作为流读取到 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) 来解决此问题。