def _upload_from_stream(self, blobname: str, stream: TextIOBase):
upload_directory = path.join(getenv('AZURE_ROOT'), self._container)
makedirs(upload_directory, exist_ok=True)
local_filename = path.join(upload_directory, blobname)
with open(local_filename, 'wb') as fobj:
copyfileobj(stream, fobj)
评论列表
文章目录