问题描述
我正在尝试将数据从 python 数据帧上传到 Azure Blob。
我一直在使用它从 Azure Blob 下载数据，它有效：
from azure.storage.blob import BlobServiceClient,BlobClient,ContainerClient
import pandas as pd
from pandas import DataFrame as df
from io import StringIO
blob_service_client =
BlobServiceClient.from_connection_string(os.environ["blob_conn_string"])
blob_client = blob_service_client.get_blob_client(blob_container,file_name)
Localfile = blob_client.download_blob().content_as_text()
df_data = pd.read_csv(StringIO(Localfile))
我想将 df_data 加载回 Azure blob 容器。 我尝试了以下代码：
blob_client.upload_blob(df_data)
谁能建议我做错了什么？
解决方法
这是我为解决这个问题所做的：
def blob_conn(df,blob_name):
blob_service_client = BlobServiceClient.from_connection_string(os.environ["blob_conn_str"])
blob_client = blob_service_client.get_blob_client(container=os.environ["container"],blob=blob_name)
blob_client.upload_blob(df,overwrite = True)
我使用数据框和 blob_name 作为位置将“df”作为 csv 文件传递。
,正如 flow_me_over 在评论中所说，blob_client.upload_blob(df_data) 是不可能的。
upload_blob() 中允许的类型应该是 Union[Iterable[AnyStr],IO[AnyStr]]，但 df_data 的类型是 TextFileReader。
以下代码可以正常工作：
blob_client2.upload_blob(Localfile)
或
blob_client2.upload_blob(data=df_data.to_csv(index=False))