Python連接Azure Storage進行數(shù)據(jù)交互的實現(xiàn)

更新時間：2023年02月13日 10:27:23 作者：理想國の糕

本文主要介紹了Python連接Azure Storage進行數(shù)據(jù)交互的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

做項目的時候，數(shù)據(jù)被要求存儲在云端，需要使用Azure的Storage功能，我自己是用了Python寫的項目，所以需要調用Python接口來進行相應的開發(fā)工作
記錄一下自己的踩坑和代碼供自己以后參考（當然Azure一直在更新，還是要不斷更新知識庫）

默認你有相應的Azure的訂閱賬號，否則下面的內容都將無法展開

1、需要的前期操作以及Python包

1、你需要安裝Azure Client然后登錄，在命令行輸入az login
2、接著安裝azure-storage-blob 、azure-identity兩個包

pip install azure-storage-blob azure-identity

2、步驟以及示例代碼

本次僅僅涉及到數(shù)據(jù)的上傳下載，一般我們會在所有流程之前先確定一個固定的資源組和Storage account，于是涉及到Python接口的部分主要是在Storage account中創(chuàng)建容器和上傳/下載blob

2.1 在Azure門戶中創(chuàng)建Storage Account

首先先創(chuàng)建資源組（基礎，默認你已經(jīng)會了）
再創(chuàng)建Storage Account

在這里插入圖片描述

這里基本都是默認設置（比較繁瑣，按下不表）

2.2 將角色分配給Azure AD用戶賬戶

這一步一開始我跳過了（因為我以為資源組的owner應該是有所有權限的，其實不是），后續(xù)就遇到了上傳no permission的問題

在 Azure 門戶中，使用主搜索欄或左側導航找到存儲帳戶。

在存儲帳戶概述頁的左側菜單中選擇“訪問控制 (IAM)”。

在“訪問控制 (IAM)”頁上，選擇“角色分配”選項卡。

從頂部菜單中選擇“+ 添加”，然后從出現(xiàn)的下拉菜單中選擇“添加角色分配”。

使用搜索框將結果篩選為所需角色。在此示例中，搜索“存儲 Blob 數(shù)據(jù)參與者”并選擇匹配的結果，然后選擇“下一步”。

在“訪問權限分配對象”下，選擇“用戶、組或服務主體”，然后選擇“+ 選擇成員”。

在對話框中，搜索 Azure AD 用戶名（通常為 user@domain 電子郵件地址），然后選擇對話框底部的“選擇”。

選擇“查看 + 分配”轉到最后一頁，然后再次選擇“查看 + 分配”完成該過程

2.3 Python 調用接口進行上傳和下載blob文件

2.3.1 創(chuàng)建container

import os, uuid
from azure.identity import DefaultAzureCredential
from azure.storage.blob import BlobServiceClient, BlobClient, ContainerClient

from azure.identity import DefaultAzureCredential
account_url = "https://<storage account>.blob.core.windows.net"
default_credential = DefaultAzureCredential()

# Create the BlobServiceClient object
blob_service_client = BlobServiceClient(account_url, credential=default_credential)

# 創(chuàng)建容器
try:
    # 創(chuàng)建一個叫test2的container
    container_name = 'test2'
    print(container_name)
    # Create the container
    container_client = blob_service_client.create_container(container_name)

except Exception as ex:
    print('Exception:')
    print(ex)

可以在Azure門戶網(wǎng)頁中看到創(chuàng)建成功

在這里插入圖片描述

2.3.2 上傳blob

# 將blob上傳到容器中
try:
    # Create a local directory to hold blob data
    local_path = "./testdir1"
    os.mkdir(local_path)

    # Create a file in the local data directory to upload and download
    local_file_name = "test2" + ".txt"
    upload_file_path = os.path.join(local_path, local_file_name)

    # Write text to the file
    file = open(file=upload_file_path, mode='w')
    file.write("Hello, World!")
    file.close()

    # Create a blob client using the local file name as the name for the blob
    container_name="test2"
    blob_client = blob_service_client.get_blob_client(container=container_name, blob=local_file_name)

    print("\nUploading to Azure Storage as blob:\n\t" + local_file_name)

    # Upload the created file
    with open(file=upload_file_path, mode="rb") as data:
        blob_client.upload_blob(data)

except Exception as ex:
    print('Exception:')
    print(ex)

成功后會顯示如下：

在這里插入圖片描述

可以用以下接口查看container中的文件

print("\nListing blobs...")

# List the blobs in the container
blob_list = container_client.list_blobs()
for blob in blob_list:
    print("\t" + blob.name)