PythonでAzure Blob Storageからcsvを取得する方法について

投稿日：2022年4月20日更新日：2022年6月4日

＜目次＞

(１) PythonでAzure Blob Storageからcsvを取得する方法について
　 (１-１) STEP1：Pythonの依存性解決
　 (１-２) STEP2：AzureストレージアカウントのURL確認
　 (１-３) STEP3：Azureストレージアカウント内の「コンテナー」との疎通
　 (１-４) （参考）上記以外のやり方のご紹介（APIのURLを直接コールする方法）

(１) PythonでAzure Blob Storageからcsvを取得する方法について

(１-１) STEP1：Pythonの依存性解決

まずはPython側で事前に必要となるパッケージをpipでインストールしておきます。

（コマンド）

> pip install azure-identity azure-storage-blob --user

（図１１１①）pipコマンドの実行

↓

（実行結果）一部抜粋

～略～
Successfully installed azure-core-1.21.1 azure-identity-1.7.1 azure-storage-blob-12.9.0 isodate-0.6.1 msal-1.16.0 msal-extensions-0.3.1 msrest-0.6.21 oauthlib-3.1.1 portalocker-2.3.2 requests-oauthlib-1.3.0
～略～

（図１１１②）インストール成功

コマンドの末尾の「–user」については、下記記事で詳しく記載しておりますので、ご興味ある方はご覧下さい。

⇒（参考）Pythonで「ERROR: Could not install packages due to an OSError: [WinError 2]」が出た時の原因と対処方法について

＞目次にもどる

(１-２) STEP2：AzureストレージアカウントのURL確認

Azure Portal上で、目的のストレージアカウントに接続するためのURLを確認します。

・①Azure Storageのリソースを開きます。

（図１２１①）

・②「概要」ブレードで「JSONビュー」を選択します。

（図１２１②）

↓

・③JSONデータの中で「”primaryEndpoints”」キーの中の「”blob”」キーに対応する値（URL）を控えます（次のSTEPで使います）。

（図１２１③）

↓

・④「アクセスキー」ブレードを押下し、「key1」の値を控えます（次のSTEPで使います）。

（図１２１④）

＞目次にもどる

(１-３) STEP3：Azureストレージアカウント内の「コンテナー」との疎通

先ほど取得したURLを用いて、Azureストレージアカウント内にある「BLOBコンテナー」内にあるBLOBファイル（例：csv）のデータを取得してみます。

（図１３１①）イメージ図

・①テストのため、予め適当なcsvをコンテナーに登録しておきます。

（図１３１②）

・②VS CodeのPythonモジュールに下記のサンプルプログラムを貼り付けて実行してみます。

※もしAzure AD配下のストレージアカウントに対して試す場合は、変数「creds」にSTEP2④で確認した「key」の値を設定します。

（サンプルプログラム）

from azure.storage.blob import BlobClient
account_url = "https://storageaccountrainbow1.blob.core.windows.net/"

# 認証情報（Keyなど）の設定
# 　⇒ Azure AD配下のリソースに対してアクセスする場合
creds = "[※Azure AD配下のコンテナーの場合、ここにKeyを指定]"

# BLOBのURLを定義（[ストレージアカウントURL]/[コンテナ名]/[BLOBファイル名]
container_name="test-container"
blob_name = "Test.csv"
blob_url = f"{account_url}/{container_name}/{blob_name}"

blob_client = BlobClient.from_blob_url(
    # BLOBファイルのURL
    blob_url=blob_url,
    # Azure AD配下のリソースの場合はKeyを指定
    credentials= creds
)
# BLOB（csvファイル）をダウンロード
blob_download = blob_client.download_blob()
# ダウンロードしたBLOBのコンテンツを取得
blob_content = blob_download.readall().decode("utf-8")
# コンテンツをコンソールに表示
print(f"{blob_content}")

（図１３２）