Azure Files を使用する Python アプリケーションを開発する

[アーティクル]
05/13/2024

ファイルデータの格納に Azure Files を使用するアプリまたはサービスを開発するための Python の基本的な使い方について説明します。コンソールアプリを作成し、Python と Azure Files を使用した基本アクションの実行方法を確認します。

Azure ファイル共有を作成する
ディレクトリを作成する
Azure ファイル共有のファイルとディレクトリを列挙する
ファイルのアップロード、ダウンロード、および削除
スナップショットを使用してファイル共有バックアップを作成する

Note

Azure Files は SMB 経由でアクセスできるため、標準の Python I/O クラスと関数を使って Azure ファイル共有にアクセスする簡単なアプリケーションを作成できます。この記事では、Azure Storage SDK for Python を使用するアプリを記述する方法を説明します。これは、Azure Files との通信に Azure Files REST API を使用します。

適用対象

ファイル共有の種類	SMB	NFS
Standard ファイル共有 (GPv2)、LRS/ZRS
Standard ファイル共有 (GPv2)、GRS/GZRS
Premium ファイル共有 (FileStorage)、LRS/ZRS

Microsoft Azure Storage SDK for Python をダウンロードしてインストールする

Note

Azure Storage SDK for Python 0.36 以前のバージョンからアップグレードする場合は、pip uninstall azure-storage を使用して以前の SDK をアンインストールしてから、最新のパッケージをインストールします。

Python 用 Azure Files クライアントライブラリには、Python 3.8 以降が必要です。

PyPI でインストールする

Python Package Index (PyPI) でインストールするには、次のように入力します。

pip install azure-storage-file-share

Azure Files を使用するようにアプリケーションを設定する

この記事のコードスニペットを使用するには、Python ソースファイルの先頭近くに次のコードを追加します。

from azure.core.exceptions import (
    ResourceExistsError,
    ResourceNotFoundError
)

from azure.storage.fileshare import (
    ShareServiceClient,
    ShareClient,
    ShareDirectoryClient,
    ShareFileClient
)

Azure Files への接続を設定する

ShareServiceClient を使用して、共有、ディレクトリ、ファイルを操作できます。このコードによって、ストレージアカウント接続文字列を使用する ShareServiceClient オブジェクトが作成されます。

# Create a ShareServiceClient from a connection string
service_client = ShareServiceClient.from_connection_string(connection_string)

次のコードサンプルでは、共有が存在しない場合は ShareClient オブジェクトを使用してそれが作成されます。

def create_file_share(self, connection_string, share_name):
    try:
        # Create a ShareClient from a connection string
        share_client = ShareClient.from_connection_string(
            connection_string, share_name)

        print("Creating share:", share_name)
        share_client.create_share()

    except ResourceExistsError as ex:
        print("ResourceExistsError:", ex.message)

ディレクトリを作成する

ルートディレクトリにすべてのファイルを置くのではなく、サブディレクトリ内に置いてストレージを整理することができます。

次のメソッドでは、ShareDirectoryClient オブジェクトを使用して、指定されたファイル共有のルートにディレクトリが作成されます。

def create_directory(self, connection_string, share_name, dir_name):
    try:
        # Create a ShareDirectoryClient from a connection string
        dir_client = ShareDirectoryClient.from_connection_string(
            connection_string, share_name, dir_name)

        print("Creating directory:", share_name + "/" + dir_name)
        dir_client.create_directory()

    except ResourceExistsError as ex:
        print("ResourceExistsError:", ex.message)

ファイルをアップロードする

このセクションでは、ローカルストレージから Azure Files にファイルをアップロードする方法について説明します。

次のメソッドでは、指定されたファイルの内容が、指定された Azure ファイル共有内の指定されたディレクトリにアップロードされます。

def upload_local_file(self, connection_string, local_file_path, share_name, dest_file_path):
    try:
        source_file = open(local_file_path, "rb")
        data = source_file.read()

        # Create a ShareFileClient from a connection string
        file_client = ShareFileClient.from_connection_string(
            connection_string, share_name, dest_file_path)

        print("Uploading to:", share_name + "/" + dest_file_path)
        file_client.upload_file(data)

    except ResourceExistsError as ex:
        print("ResourceExistsError:", ex.message)

    except ResourceNotFoundError as ex:
        print("ResourceNotFoundError:", ex.message)

サブディレクトリ内のファイルとディレクトリを一覧表示するには、list_directories_and_files メソッドを使用します。このメソッドでは、反復可能な自動ページングが返されます。次のコードでは、指定されたディレクトリ内の各ファイルとディレクトリの名前がコンソールに出力されます。

def list_files_and_dirs(self, connection_string, share_name, dir_name):
    try:
        # Create a ShareClient from a connection string
        share_client = ShareClient.from_connection_string(
            connection_string, share_name)

        for item in list(share_client.list_directories_and_files(dir_name)):
            if item["is_directory"]:
                print("Directory:", item["name"])
            else:
                print("File:", dir_name + "/" + item["name"])

    except ResourceNotFoundError as ex:
        print("ResourceNotFoundError:", ex.message)

ファイルをダウンロードする

ファイルからデータをダウンロードするには、download_file を使用します。

次の例では、指定したファイルの内容を download_file を使用して取得し、ファイル名の先頭に DOWNLOADED- を追加してローカルに保存する操作が示されています。

def download_azure_file(self, connection_string, share_name, dir_name, file_name):
    try:
        # Build the remote path
        source_file_path = dir_name + "/" + file_name

        # Add a prefix to the filename to 
        # distinguish it from the uploaded file
        dest_file_name = "DOWNLOADED-" + file_name

        # Create a ShareFileClient from a connection string
        file_client = ShareFileClient.from_connection_string(
            connection_string, share_name, source_file_path)

        print("Downloading to:", dest_file_name)

        # Open a file for writing bytes on the local system
        with open(dest_file_name, "wb") as data:
            # Download the file from Azure into a stream
            stream = file_client.download_file()
            # Write the stream to the local file
            data.write(stream.readall())

    except ResourceNotFoundError as ex:
        print("ResourceNotFoundError:", ex.message)

ファイル共有全体の特定の時点のコピーを作成できます。

def create_snapshot(self, connection_string, share_name):
    try:
        # Create a ShareClient from a connection string
        share_client = ShareClient.from_connection_string(
            connection_string, share_name)

        # Create a snapshot
        snapshot = share_client.create_snapshot()
        print("Created snapshot:", snapshot["snapshot"])

        # Return the snapshot time so 
        # it can be accessed later
        return snapshot["snapshot"]

    except ResourceNotFoundError as ex:
        print("ResourceNotFoundError:", ex.message)

共有とスナップショットの一覧表示

特定の共有のすべてのスナップショットを一覧表示できます。

def list_shares_snapshots(self, connection_string):
    try:
        # Create a ShareServiceClient from a connection string
        service_client = ShareServiceClient.from_connection_string(connection_string)

        # List the shares in the file service
        shares = list(service_client.list_shares(include_snapshots=True))

        for share in shares:
            if (share["snapshot"]):
                print("Share:", share["name"], "Snapshot:", share["snapshot"])
            else:
                print("Share:", share["name"])

    except ResourceNotFoundError as ex:
        print("ResourceNotFoundError:", ex.message)

各共有スナップショットを参照して、その時点のファイルとディレクトリを取得できます。

def browse_snapshot_dir(self, connection_string, share_name, snapshot_time, dir_name):
    try:
        # Create a ShareClient from a connection string
        snapshot = ShareClient.from_connection_string(
            conn_str=connection_string, share_name=share_name, snapshot=snapshot_time)

        print("Snapshot:", snapshot_time)

        for item in list(snapshot.list_directories_and_files(dir_name)):
            if item["is_directory"]:
                print("Directory:", item["name"])
            else:
                print("File:", dir_name + "/" + item["name"])

    except ResourceNotFoundError as ex:
        print("ResourceNotFoundError:", ex.message)

共有スナップショットからファイルをダウンロードできます。これにより、以前のバージョンのファイルを復元できます。

def download_snapshot_file(self, connection_string, share_name, snapshot_time, dir_name, file_name):
    try:
        # Build the remote path
        source_file_path = dir_name + "/" + file_name

        # Add a prefix to the local filename to 
        # indicate it's a file from a snapshot
        dest_file_name = "SNAPSHOT-" + file_name

        # Create a ShareFileClient from a connection string
        snapshot_file_client = ShareFileClient.from_connection_string(
            conn_str=connection_string, share_name=share_name, 
            file_path=source_file_path, snapshot=snapshot_time)

        print("Downloading to:", dest_file_name)

        # Open a file for writing bytes on the local system
        with open(dest_file_name, "wb") as data:
            # Download the file from Azure into a stream
            stream = snapshot_file_client.download_file()
            # Write the stream to the local file
            data.write(stream.readall())

    except ResourceNotFoundError as ex:
        print("ResourceNotFoundError:", ex.message)

単一の共有スナップショットを削除できます。

def delete_snapshot(self, connection_string, share_name, snapshot_time):
    try:
        # Create a ShareClient for a snapshot
        snapshot_client = ShareClient.from_connection_string(conn_str=connection_string, share_name=share_name, snapshot=snapshot_time)

        print("Deleting snapshot:", snapshot_time)

        # Delete the snapshot
        snapshot_client.delete_share()

    except ResourceNotFoundError as ex:
        print("ResourceNotFoundError:", ex.message)

ファイルを削除する

ファイルを削除するには、delete_file を呼び出します。

def delete_azure_file(self, connection_string, share_name, file_path):
    try:
        # Create a ShareFileClient from a connection string
        file_client = ShareFileClient.from_connection_string(
            connection_string, share_name, file_path)

        print("Deleting file:", share_name + "/" + file_path)

        # Delete the file
        file_client.delete_file()

    except ResourceNotFoundError as ex:
        print("ResourceNotFoundError:", ex.message)

スナップショットを含む共有を削除するには、delete_share を delete_snapshots=True を指定して呼び出します。

def delete_share(self, connection_string, share_name):
    try:
        # Create a ShareClient from a connection string
        share_client = ShareClient.from_connection_string(
            connection_string, share_name)

        print("Deleting share:", share_name)

        # Delete the share and snapshots
        share_client.delete_share(delete_snapshots=True)

    except ResourceNotFoundError as ex:
        print("ResourceNotFoundError:", ex.message)

次のステップ

Python での Azure Files を操作する方法を習得したので、詳細について次のリンクを参照してください。

非推奨の Python バージョン 2 SDK を使用する関連コードサンプルについては、「Python バージョン 2 を使用したコードサンプル」を参照してください。

次の方法で共有

Azure Files を使用する Python アプリケーションを開発する

適用対象

Microsoft Azure Storage SDK for Python をダウンロードしてインストールする

PyPI でインストールする

Azure Files を使用するようにアプリケーションを設定する

Azure Files への接続を設定する

ディレクトリを作成する

ファイルをアップロードする

ファイルをダウンロードする

共有とスナップショットの一覧表示

ファイルを削除する

次のステップ

フィードバック

その他のリソース

次の方法で共有

Azure Files を使用する Python アプリケーションを開発する

適用対象

Microsoft Azure Storage SDK for Python をダウンロードしてインストールする

PyPI でインストールする

Azure Files を使用するようにアプリケーションを設定する

Azure Files への接続を設定する

Azure ファイル共有を作成する

ディレクトリを作成する

ファイルをアップロードする

Azure ファイル共有のファイルとディレクトリを列挙する

ファイルをダウンロードする

共有スナップショットを作成する

共有とスナップショットの一覧表示

共有スナップショットの参照

共有スナップショットからのファイルの取得

単一の共有スナップショットの削除

ファイルを削除する

共有スナップショットが存在する場合の共有の削除

次のステップ

フィードバック

その他のリソース