如何在python中将数据流式传输到azure块blob

Question

我想用python将数据流式传输到azure块blob。下面的代码创建了blob，但以零字节结束。我该如何做这项工作？

import io 
import struct 
from azure.storage.blob import BlockBlobService 

storage = BlockBlobService('acct-xxx', 'key-xxx') 
stream = io.BytesIO() 
storage.create_blob_from_stream("mycontainer", "myblob", stream) 
stream.write(struct.pack("d", 12.34)) 
stream.write(struct.pack("d", 56.78)) 
stream.close() 

Answer 1

看来你已经错过了代码的关键行：

stream.seek（0）

我设置流的Position property 0，那么你的代码工作。

import io 
import struct 
from azure.storage.blob import BlockBlobService 

storage = BlockBlobService('acct-xxx', 'key-xxx') 
stream = io.BytesIO() 

stream.write(struct.pack("d", 12.34)) 
stream.write(struct.pack("d", 56.78)) 
stream.seek(0) 
storage.create_blob_from_stream("mycontainer", "myblob", stream) 
stream.close() 

您可以参考这个线程Azure storage: Uploaded files with size zero bytes。