Fabric リアルタイム ハブでの Azure Blob Storage イベントの探索 (プレビュー)
Note
リアルタイム ハブは現在プレビュー段階です。
この記事では、Fabric リアルタイム ハブで Azure BLOB ストレージ イベントを調べる方法について説明します。 Azure BLOB ストレージ イベントを使用すると、BLOB で特定のアクションが発生したときに通知を受信できます。 たとえば、新しい BLOB が作成されたとき、または既存の BLOB が変更されたときに通知を受け取ることができます。 これらのイベントを使用して、データベースの更新や通知の送信など、他のアクションやワークフローにアラートを設定できます。 この記事では、Azure Blob Storage イベントのプロパティとスキーマについて説明します。
Note
イベントストリームまたはデータ アクティベーターの容量リージョンが次のリージョンにある場合、イベントストリームまたはデータ アクティベーターを介した Fabric イベントの消費はサポートされません: ドイツ中西部、米国中南部、米国2 西部、米国3 西部、インド西部。
Azure Blob Storage イベントの詳細ページを表示する
リアルタイム ハブで、[ファブリック イベント] を選択します。
一覧から [Azure Blob Storage イベント]を選択します。
Azure BLOB ストレージ イベントの詳細ページが表示されます。
アクション
Azure BLOB ストレージ イベントの詳細ページの上部には、次の 2 つのアクションが表示されます。
イベントストリームの作成 - 選択した Azure BLOB ストレージからのイベントに基づいてイベントストリームを作成できます。
アラートの設定 - Azure Blob Storage アーティファクトに対して操作が完了したときにアラートを設定できます。 たとえば、BLOB が作成または削除されたときにアラートを設定できます。
このカテゴリの使用方法を確認する
このセクションでは、Azure Blob Storage イベントを使用したアーティファクトを示します。 一覧に表示される列とその説明を以下に示します。
列 | 説明 |
---|---|
Name | Azure Blob Storage イベントを使用しているアーティファクトの名前。 |
Type | 成果物の種類 – Reflex またはイベントストリーム |
ワークスペース | 成果物が存在するワークスペース。 |
ソース | ソースの名前(Azure Storage Blob アカウント)。 |
Azure Blob Storage イベントのプロファイル
イベントの種類
イベント タイプ名 | 説明 |
---|---|
Microsoft.Storage.BlobCreated | このイベントは、新しい BLOB が追加されたとき、または既存の BLOB が更新されたときにアクティブ化されます。 イベントは、Azure Data Lake Storage Gen2 REST API で確認できる、CreateFile およびFlushWithClose 操作を使用するクライアントによってトリガーされます。 |
Microsoft.Storage.BlobDeleted | このイベントは、BLOB が削除されたときにアクティブ化されます。 クライアントが Azure Data Lake Storage Gen2 REST API で確認できる DeleteFile 操作を使用した場合に、このイベントがトリガーされます。 |
Microsoft.Storage.BlobRenamed | このイベントは、BLOB が名前の変更を受けた場合、特にユーザーが Azure Data Lake Storage Gen2 REST API で見つかったRenameFile 関数を使用する場合にアクティブになります。 |
Microsoft.Storage.BlobTierChanged | このイベントは、BLOB REST API の SetBlobTier 操作によって BLOB アクセス層が変更されるとアクティブ化され、変更が完全に処理されるとトリガーされます。 |
Microsoft.Storage.AsyncOperationInitiated | このイベントは、データがアーカイブからホット層またはクール層に移動またはコピーされるときに発生します。 クライアントが SetBlobTier API を使用して、アーカイブ層からホット層またはクール層に BLOB を移動するとき、またはクライアントが CopyBlob API を使用して、アーカイブ層の BLOB からホット層またはクール層の BLOB にデータをコピーするときに発生します。 |
Microsoft.Storage.DirectoryCreated | このイベントは、新しいディレクトリが作成されたとき、またはクライアントが Azure Data Lake Storage Gen2 REST API で提供される CreateDirectory 操作を利用して新しいディレクトリを形成するときにアクティブになります。 |
Microsoft.Storage.DirectoryRenamed | このイベントは、ディレクトリが名前の変更を受けた場合、特にクライアントが Azure Data Lake Storage Gen2 REST API の RenameDirectory 機能を使用する場合にアクティブになります。 |
Microsoft.Storage.DirectoryDeleted | このイベントは、お客様が Azure Data Lake Storage Gen2 REST API に存在するDeleteDirectory 機能を利用するときに、ディレクトリが削除されたときにアクティブ化されます。 |
Microsoft.Storage.BlobInventoryPolicyCompleted | このイベントは、インベントリ ポリシーとして指定されたポリシーに対してインベントリの実行が完了するとアクティブになります。 また、誤ったポリシーや存在しない宛先コンテナーなど、開始前にユーザー エラーが原因でインベントリの実行が失敗した場合にもアクティブ化されます。 |
Microsoft.Storage.LifecyclePolicyCompleted | このイベントは、定義されたアクションが実行されたときのライフサイクル管理ポリシーのアクティブ化を指します。 |
スキーマ
イベントのトップレベルのデータを次に示します。
プロパティ | タイプ | 説明設定 | 例 |
---|---|---|---|
source |
string | イベント ソースの完全なリソース パス。 このフィールドは書き込み可能ではありません。 この値は Event Grid によって指定されます。 | /subscriptions/{subscription-id}/resourceGroups/Storage/providers/Microsoft.Storage/storageAccounts/my-storage-account |
subject |
string | 発行元が定義したイベントの対象のパス。 | /blobServices/default/containers/my-file-system/blobs/new-file.txt |
type |
string | このイベント ソース用に登録されたイベントの種類のいずれか。 | Microsoft.Storage.BlobCreated |
time |
string | プロバイダーの UTC 時刻に基づくイベントの生成時刻。 | 2017-06-26T18:41:00.9584103Z |
id |
string | イベントの一意識別子。 | 00000000-0000-0000-0000-000000000000 |
data |
object | Blob Storage イベントのデータ。 | {{Data object}} |
specversion |
string | CloudEvents スキーマ仕様バージョン。 | 1.0 |
fabricsource |
string | Azure Blob Storage イベント ソースの Fabric イベントストリームの ID。 | /tenants/00000000-0000-0000-0000-000000000000/workspaces/00000000-0000-0000-0000-000000000000/items/00000000-0000-0000-0000-000000000000 |
fabricsubject |
string | Azure Blob Storage イベント ソースのイベント リンクの ID。 | eventLinks/00000000-0000-0000-0000-000000000000 |
data
オブジェクトには、次のプロパティがあります。
プロパティ | タイプ | 説明設定 | 例 |
---|---|---|---|
api |
string | イベントのトリガーとなった操作。 | CreateFile |
clientRequestId |
string | ストレージ API 操作に対するクライアントで提供された要求 ID です。 この ID は、ログの "client-request-id" フィールドを使って Azure Storage 診断ログに関連付けるために使うことができ、クライアント要求で "x-ms-client-request-id" ヘッダーを使って提供できます。 「Storage Analytics のログの形式」をご覧ください。 | 00000000-0000-0000-0000-000000000000 |
requestId |
string | ストレージ API 操作に対するサービスで生成された要求 ID です。 ログの "request-id-header" フィールドを使って Azure Storage 診断ログに関連付けるために使うことができ、開始 API 呼び出しから "x-ms-request-id" ヘッダーで返されます。 「Storage Analytics のログの形式」をご覧ください。 | 00000000-0000-0000-0000-000000000000 |
eTag |
string | この値を使用することで、条件に応じて操作を実行することができます。 | \"0x8D4BCC2E4835CD0\" |
contentType |
string | BLOB に関して指定されたコンテンツの種類。 | text/plain |
contentLength |
整数 (integer) | BLOB のサイズ (単位: バイト)。 | 0 |
blobType |
string | BLOB の種類。 有効な値は BlockBlob または PageBlob です。 |
BlockBlob |
contentOffset |
数値 | イベントをトリガーしたアプリケーションがファイルへの書き込みを完了した時点で実行される書き込み操作のバイト単位のオフセット。 階層型名前空間を持つ BLOB ストレージ アカウントでトリガーされるイベントに対してのみ表示されます。 |
0 |
destinationUrl |
string | 操作の完了後に存在するファイルの url。 たとえば、ファイルの名前が変更された場合、destinationUrl プロパティには新しいファイル名の url が含まれています。 階層型名前空間を持つ BLOB ストレージ アカウントでトリガーされるイベントに対してのみ表示されます。 |
https://my-storage-account.dfs.core.windows.net/my-file-system/new-file.txt |
sourceUrl |
string | 操作が実行される前に存在するファイルの url。 たとえば、ファイルの名前が変更された場合、sourceUrl には、名前変更操作が行われる前の元のファイル名の url が含まれています。 階層型名前空間を持つ BLOB ストレージ アカウントでトリガーされるイベントに対してのみ表示されます。 |
https://my-storage-account.dfs.core.windows.net/my-file-system/my-original-directory |
url |
string | BLOB へのパス。 クライアントが BLOB REST API を使用する場合、url の構造は |
https://myaccount.blob.core.windows.net/container01/file.txt |
recursive |
string | すべての子ディレクトリに対して操作を実行する場合は真、それ以外の場合は偽。 階層型名前空間を持つ BLOB ストレージ アカウントでトリガーされるイベントに対してのみ表示されます。 |
true |
sequencer |
string | 特定の BLOB 名に対するイベントの論理シーケンスを表す非透過的な文字列値です。 ユーザーは、標準的な文字列比較を使って、同じ BLOB 名での 2 つのイベントの相対的な順序を理解できます。 | 00000000000004420000000000028963 |
identity |
string | イベントに関連付けられた ID を表す文字列値。 SFTP の場合、値がローカル ユーザー名です。 | localuser |
storageDiagnostics |
オブジェクト | Azure Storage サービスによって追加されることがある診断データです。 含まれる場合、イベントのコンシューマーは無視する必要があります。 | {{Storage diagnostic object}} |