Blob Storage イベントへの対応

[アーティクル]
03/25/2023

Azure Storage イベントをアプリケーションで使用すると、BLOB の作成、削除などのイベントに対応できます。複雑なコードや、高価で非効率的なポーリングサービスは必要ありません。最もよい点は、使用した分だけ支払うということです。

Blob Storage イベントは、Azure Event Grid を使用して、Azure Functions、Azure Logic Apps などのサブスクライバー、または独自の HTTP リスナーにもプッシュされます。 Event Grid は、豊富な再試行ポリシーおよび配信不能を使用して、ご利用のアプリケーションに信頼性の高いイベント配信を提供します。

Blob Storage でサポートされるイベントの完全な一覧については、Blob Storage イベントのスキーマに関する記事を参照してください。

Blob Storage イベントの一般的なシナリオとしては、画像やビデオの処理、検索インデックスの作成、ファイル指向のワークフローなどがあります。非同期のファイルアップロードは、イベントに最適です。変更の頻度が低くても、即時の応答性が必要なシナリオでは、イベントベースのアーキテクチャは特に効果的です。

Blob Storage イベントを試す場合は、次のクイックスタートの記事のいずれかを参照してください。

使うツール:	参照する記事:
Azure portal	クイックスタート: Azure portal で Blob Storage のイベントを Web エンドポイントにルーティングする
PowerShell	クイックスタート: PowerShell を使用してストレージイベントを Web エンドポイントにルーティングする
Azure CLI	クイックスタート: Azure CLI を使用してストレージイベントを Web エンドポイントにルーティングする

Azure 関数を使用した BLOB ストレージイベントへの対応の詳細な例については、以下の記事をご覧ください。

Note

Storage (汎用 v1) では、Event Grid との統合はサポート "されていません"。

イベントモデル

Event Grid は、イベントサブスクリプションを使用して、イベントメッセージをサブスクライバーにルーティングします。この図は、イベント発行元、イベントサブスクリプション、およびイベントハンドラーの間の関係を示しています。

Event Grid Model

最初に、イベントにエンドポイントをサブスクライブします。その後、イベントがトリガーされると、Event Grid サービスにより、そのイベントに関するデータがエンドポイントに送信されます。

Blob Storage イベントのスキーマに関する記事を参照し、以下を確認してください。

Blob Storage イベントの全一覧と各イベントがトリガーされる方法。
これらの各イベントに対して Event Grid が送信するデータの例。
データに表示される各キー値ペアの目的。

イベントのフィルター処理

BLOB イベントは、イベントの種類、コンテナー名、作成または削除されたオブジェクトの名前によってフィルター処理できます。 Event Grid のフィルターは、サブジェクトの先頭または末尾を照合するため、件名が一致したイベントはサブスクライバーに送られます。

フィルターを適用する方法の詳細については、「Event Grid のイベントのフィルター処理」をご覧ください。

Blob Storage イベントのサブジェクトには次の形式が使われます。

/blobServices/default/containers/<containername>/blobs/<blobname>

ストレージアカウントのすべてのイベントと一致させるには、サブジェクトフィルターを空のままにできます。

プレフィックスを共有する一連のコンテナーで作成された BLOB からのイベントと一致させるには、次のような subjectBeginsWith フィルターを使います。

/blobServices/default/containers/containerprefix

特定のコンテナーで作成された BLOB からのイベントと一致させるには、次のような subjectBeginsWith フィルターを使います。

/blobServices/default/containers/containername/

BLOB 名プレフィックスを共有する特定のコンテナーで作成された BLOB からのイベントと一致させるには、次のような subjectBeginsWith フィルターを使います。

/blobServices/default/containers/containername/blobs/blobprefix

BLOB サフィックスを共有する特定のコンテナーで作成された BLOB からのイベントと一致させるには、".log" や ".jpg" などの subjectEndsWith フィルターを使います。詳しくは、「Event Grid の概念」をご覧ください。

イベントの使用に関する手法

Blob Storage イベントを処理するアプリケーションは、いくつかの推奨される手法に従う必要があります。

同じイベントハンドラーにイベントをルーティングするように複数のサブスクリプションが構成されている可能性があるので、イベントが特定のソースからのものであると思い込まず、メッセージのトピックを調べて、想定しているストレージアカウントからのものであることを確認することが重要です。
同様に、受信するすべてのイベントが予期した種類のものであると想定してはならず、イベントの種類が処理できるものであることを確認する必要があります。
メッセージが到着するまでにかかる時間に関するサービスレベルアグリーメントはありません。メッセージの到着するまでに 30 分から 2 時間かかることは珍しくありません。メッセージは、少し遅れて到着する可能性があるので、etag フィールドを使って、オブジェクトに関する情報がまだ最新の状態かどうかを確認します。 etag フィールドの使用方法については、「BLOB ストレージ内でのコンカレンシーの管理」を参照してください。
メッセージは順不同で到着する可能性があるので、sequencer フィールドを使って、特定のオブジェクトに対するイベントの順序を確認します。 sequencer フィールドは、特定の BLOB 名に対するイベントの論理シーケンスを表す文字列値です。標準的な文字列比較を使って、同じ BLOB 名での 2 つのイベントの相対的な順序を理解できます。
Storage イベントにより、サブスクライバーへの少なくとも 1 回の配信が保証され、すべてのメッセージが確実に出力されます。ただし、バックエンドノードとサービス間の再試行、またはサブスクリプションの可用性のために、メッセージの重複が発生することがあります。メッセージの配信と再試行の詳細については、「Event Grid によるメッセージの配信と再試行」を参照してください。
blobType フィールドを使って、BLOB に対して許可されている操作の種類と、BLOB にアクセスするために使う必要があるクライアントライブラリの種類を確認します。有効な値は BlockBlob または PageBlob です。
CloudBlockBlob および CloudAppendBlob コンストラクターでは、url フィールドを使って BLOB にアクセスします。
わからないフィールドは無視します。この手法に従うと、将来追加されるかもしれない新しい機能に弾力的に対応できます。
ブロック BLOB が完全にコミットされた場合に限り Microsoft.Storage.BlobCreated イベントがトリガーされるようにするには、CopyBlob、PutBlob、PutBlockList、または FlushWithClose REST API 呼び出しのイベントをフィルター処理します。データがブロック BLOB に完全にコミットされた後でのみ、これらの API 呼び出しによって Microsoft.Storage.BlobCreated イベントがトリガーされます。フィルターの作成方法の詳細については、「Event Grid のイベントのフィルター処理」をご覧ください。

機能サポート

Data Lake Storage Gen2、Network File System (NFS) 3.0 プロトコル、または SSH ファイル転送プロトコル (SFTP) を有効にすると、この機能のサポートが影響を受ける場合があります。これらの機能のいずれかを有効にしている場合は、「Azure Storage アカウントでの Blob Storage 機能のサポート」を参照して、この機能のサポートを評価してください。

次のステップ

Event Grid の詳細について理解し、Blob Storage イベントを試してみてください。