Я пытаюсь прочитать csv из большого двоичного объекта Azure в Python в виде потока и напрямую записать его обратно в большой двоичный объект Azure. Операция чтения работает отлично, но запись выходного потока просто записывает пустой файл в большой двоичный объект. Следующий код работает до печати (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)
copyfileobj
? Вы можете отредактировать свой вопрос и вставить определение этого? - person Saher Ahwal   schedule 24.04.2018input_blob
находится в EOF послеpd.read_csv
.input_blob.seek(0)
послеread_csv
может быть полезно. - person Sraw   schedule 25.04.2018