Fabric リアルタイム ハブでの Azure Blob Storage イベントの探索 (プレビュー)

  • [アーティクル]

Note

リアルタイム ハブは現在プレビュー段階です。

この記事では、Fabric リアルタイム ハブで Azure BLOB ストレージ イベントを調べる方法について説明します。 Azure BLOB ストレージ イベントを使用すると、BLOB で特定のアクションが発生したときに通知を受信できます。 たとえば、新しい BLOB が作成されたとき、または既存の BLOB が変更されたときに通知を受け取ることができます。 これらのイベントを使用して、データベースの更新や通知の送信など、他のアクションやワークフローにアラートを設定できます。 この記事では、Azure Blob Storage イベントのプロパティとスキーマについて説明します。

Note

イベントストリームまたはデータ アクティベーターの容量リージョンが次のリージョンにある場合、イベントストリームまたはデータ アクティベーターを介した Fabric イベントの消費はサポートされません: ドイツ中西部、米国中南部、米国2 西部、米国3 西部、インド西部。

Azure Blob Storage イベントの詳細ページを表示する

  1. リアルタイム ハブで、[ファブリック イベント]タブに切り替えます。

  2. 一覧から [Azure Blob Storage イベント]を選択します。

    [ファブリック イベント] タブでの Azure BLOB ストレージ イベントの選択を示すスクリーンショット。

  3. Azure BLOB ストレージ イベントの詳細ページが表示されます。

    Azure BLOB ストレージ イベントの詳細ページを示すスクリーンショット。

アクション

Azure BLOB ストレージ イベントの詳細ページの上部には、次の 2 つのアクションが表示されます。

  • イベントストリームの作成 - 選択した Azure BLOB ストレージからのイベントに基づいてイベントストリームを作成できます。

  • アラートの設定 - Azure Blob Storage アーティファクトに対して操作が完了したときにアラートを設定できます。 たとえば、BLOB が作成または削除されたときにアラートを設定できます。

    Azure BLOB ストレージ イベントの詳細ページの[アクション]セクションを示すスクリーンショット。

このカテゴリの使用方法を確認する

このセクションでは、Azure Blob Storage イベントを使用したアーティファクトを示します。 一覧に表示される列とその説明を以下に示します。

列 説明
Name Azure Blob Storage イベントを使用しているアーティファクトの名前。
Type 成果物の種類 – Reflex またはイベントストリーム
ワークスペース 成果物が存在するワークスペース。
ソース ソースの名前（Azure Storage Blob アカウント）。

[Azure Blob Storage イベントの詳細]ページのセクションの[使用している内容を確認する]を示すスクリーンショット。

Azure Blob Storage イベントのプロファイル

[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 の構造は <storage-account-name>.blob.core.windows.net\<container-name>\<file-name> です。 クライアントが Data Lake Storage REST API を使用する場合、url の構造は <storage-account-name>.dfs.core.windows.net/<file-system-name>/<file-name> です。

 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}}

関連するコンテンツ