当前位置:   article > 正文

如何将API 中的excel 文件load 到 Azure blob 中

如何将API 中的excel 文件load 到 Azure blob 中

背景: 项目中一个API 中的excel 加密了,需要完成以下任务:

任务一: 将这个excel 文件从API 获取,解密后将数据load 进SQL SERVER 数据库

任务二:将这个excel 文件从API 获取后,解密后将数据excel 数据load 到 Azure blob 中存储起来

对于第一个任务,先不提供方案,今天就第二个任务提供如下方案:

  1. import os
  2. from io import BytesIO
  3. import pandas as pd
  4. from azure.storage.blob import BlobServiceClient, BlobClient, ContainerClient
  5. # 假设`bytes_data`是您解密后从API获得的Excel数据的BytesIO对象
  6. # bytes_data = ...
  7. # 将BytesIO对象转化为DataFrame
  8. with BytesIO() as bio:
  9. # 加载到Pandas DataFrame中
  10. bio.write(bytes_data.getvalue())
  11. bio.seek(0) # 移动到文件的开头
  12. df = pd.read_excel(bio)
  13. # 将DataFrame转换回Excel文件保存在BytesIO对象中
  14. with BytesIO() as bio:
  15. # 将DataFrame保存到Excel文件格式的BytesIO对象中
  16. with pd.ExcelWriter(bio, engine='openpyxl') as writer:
  17. df.to_excel(writer)
  18. # 准备将Excel文件上传到Azure Blob Storage
  19. bio.seek(0)
  20. excel_data = bio.read()
  21. # 初始化Azure Blob Service Client
  22. # 假设你已经有了AZURE_STORAGE_CONNECTION_STRING
  23. connection_str = os.getenv('AZURE_STORAGE_CONNECTION_STRING')
  24. blob_service_client = BlobServiceClient.from_connection_string(connection_str)
  25. # 创建Blob客户端来上传文件
  26. # 需要Blob容器名称和文件路径在Blob中的名称
  27. container_name = 'your_container_name'
  28. blob_name = 'your_blob_name.xlsx'
  29. blob_client = blob_service_client.get_blob_client(container=container_name, blob=blob_name)
  30. # 上传BytesIO对象中的数据到Azure Blob
  31. blob_client.upload_blob(excel_data, blob_type="BlockBlob", overwrite=True)
  32. print(f'{blob_name} uploaded to {container_name}')
  33. # 注意: 以上代码中的`your_container_name`和`your_blob_name.xlsx`要替换成你的Azure存储账户的实际容器名称和Blob名称。
  34. # 另外,确保你有适当的权限和正确的连接字符串

Note: 在上传到Azure Blob之前,你需要确保你有一个有效的Azure存储账户,并创建了一个容器。同时,你需要将AZURE_STORAGE_CONNECTION_STRING设置为环境变量或以其他方式提供给你的脚本,这样才能认证你的身份并连接到Azure Blob Storage。

在这个过程中,自己走了很多弯路

弯路1,使用XlsxWriter ,走到这里,不知道该如何跟Blob 的 upload_bload 方法结合使用,

  1. import xlsxwriter
  2. bio = io.BytesIO()
  3. workbook = xlsxwriter.Workbook(bio)
  4. worksheet = workbook.add_worksheet()

弯路2,upload_blob 的使用还是一知半解,不知如何变通,后续需要继续研究 upload_blob

blob 中的upload_blob 的官方文档:使用 Python 上传 blob - Azure Storage | Microsoft Learn

提到,将数据上传到块 Blob有如下路子:

1.通过本地文件路径上传块 Blob

2.通过流式传输上传块 Blob

3.将二进制数据上传到块 Blob

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小丑西瓜9/article/detail/541063
推荐阅读
相关标签
  

闽ICP备14008679号