Azure Blob Storage イベント ソースを eventstream に追加する (プレビュー)
この記事では、Azure Event Hubs のソースをイベントストリームを追加する方法について説明します。 イベントは、システム内で発生した何かを詳細に記述する最小限の情報です。 これらのイベントは、クライアントが BLOB REST API を呼び出して BLOB を作成、置換、または削除するときにトリガーされます。 Microsoft Fabric イベント ストリームを使用すると、Blob Storage イベントをリアルタイム ハブの Fabric イベントにリンクできます。
Azure Blob Storage イベントをイベントストリーム ソースとして追加すると、Blob Storage アカウントにシステム イベントが自動的に作成され、リアルタイム ハブの Fabric イベントにリンクされます。 その後、これらのイベントを連続データ ストリームに変換し、それらを変換してから、Fabric のさまざまな宛先にルーティングできます。
ファブリック イベント ストリームでは、次の種類の Blob Storage イベントがサポートされます。
イベント名 | 説明 |
---|---|
Microsoft.Storage.BlobCreated | BLOB が作成または置換されたときにトリガーされます。 |
Microsoft.Storage.BlobDeleted | BLOB が削除されたときにトリガーされます。 |
Microsoft.Storage.BlobRenamed | BLOB の名前が変更されたときにトリガーされます。 |
Microsoft.Storage.BlobTierChanged | BLOB のアクセスレイヤーが変更されたときにトリガーされます。 |
Microsoft.Storage.DirectoryCreated | ディレクトリが作成されたときにトリガーされます。 |
Microsoft.Storage.DirectoryRenamed | ディレクトリの名前が変更されたときにトリガーされます。 |
Microsoft.Storage.AsyncOperationInitiated | アーカイブレイヤーからホットレイヤーまたはクールレイヤーへのデータの移動またはコピーを伴う操作が開始されたときにトリガーされます。 |
Microsoft.Storage.DirectoryDeleted | ディレクトリが削除されたときにトリガーされます。 |
Microsoft.Storage.BlobInventoryPolicyCompleted | インベントリ ポリシーで定義されたルールに対してインベントリの実行が完了したときにトリガーされます。 |
Microsoft.Storage.LifecyclePolicyCompleted | ライフサイクル管理ポリシーで定義されたアクションが実行されたときにトリガーされます。 |
使用可能なイベントの種類の詳細については、Event Grid ソースとしての Azure Blob Storage に関するページを参照してください。
重要
Fabric イベント ストリームの拡張機能は現在プレビュー段階です。
Note
このソースは、ワークスペースの容量の以下の地域ではサポートされていません。ドイツ中西部、米国中南部、米国西部 2、米国西部 3、インド西部。
ストリーミングされていないイベントとストリーミングされたイベント
Azure Blob Storage イベントは、明確な開始点と終了点を持つ個別のイベントです。 ファブリック リアルタイム ハブでは、次の 2 つの形式でこれらのイベントをキャプチャできます。
ストリーミングされていないイベント。 これらのイベントは、未加工の形式で個別のイベントとして表されます。 Azure Blob Storage イベントがイベントストリームでストリーミングされない場合、イベントストリームに直接接続されず、既定のストリームは作成されません。
この状態は、イベントがリアルタイム ハブの Fabric イベントにリンクされ、さらにアクションを待機していることを示します。 アクションには、リアルタイム ハブの [ファブリック イベント] タブでパイプラインやノートブックなどのファブリック ジョブ 項目を実行するデータ アクティベーターを使用したアラートの作成が含まれます。
ストリーミング イベント。 これらのイベントは継続的なイベントに変換され、リアルタイムの変換と Fabric のさまざまな宛先へのルーティングを可能にして、詳細な分析を行うことができます。 イベントストリームで、ストリーミングされていない Azure Blob Storage ソースの [Stream events]\(ストリーム イベント\) ボタンを選択すると、イベントが連続イベントに変換されます。 その後、イベントストリームには既定のストリームが割り当てられ、操作を追加して Fabric の他の宛先にルーティングできます。
前提条件
- 投稿者以上の権限を持つ Fabric プレミアム ワークスペースへのアクセス権
- Azure Blob Storage StorageV2 (汎用 v2)、 BlockBlobStorage、または BlobStorage アカウントへのアクセス。 ストレージ (汎用 v1) ストレージの種類は、Fabric イベント ストリームとの統合をサポートしていません。
Note
1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。
Event Grid ソースとしての Azure Blob Storage
[イベントストリーム]を選択して新しいイベントストリームを作成します。 [拡張機能 (プレビュー)] オプションが有効になっていることを確認します。
次の画面で、外部ソースの追加を選択します。
Azure Blob Storage イベントを構成して接続する
[データ ソースの選択] 画面で、Azure Blob Storage イベントを選択します。
[接続] 画面で、イベントストリームでキャプチャするサブスクリプションとストレージ アカウントを選択します。
[次へ] を選択します。
[確認と作成] 画面で概要を確認し、[追加] を選択して Azure Blob Storage イベントの構成を完了します。
接続が作成されると、編集モードでイベントストリームに追加された Azure Blob Storage イベント ソースを確認できます。 [発行] を選択してイベントストリームを発行し、Azure Blob Storage イベントのキャプチャを開始します。
Note
エディターの Eventstream ノードには、既定のストリームが作成されていません。 これは、Blob Storage イベントは引き続き個別のイベントの形式であり、まだストリームに変換されていないか、イベントストリームに接続されていないためです。
変更を発行すると、Azure Blob Storage アカウントがリアルタイム ハブにリンクされます。 リアルタイム ハブ > ファブリック イベントの Azure Blob Storage イベント>に移動します。ドロップダウン リストで Azure Blob Storage アカウントを見つけ、BLOB ストレージ イベントに対してアクションを実行するトリガーを設定できます。
Azure Blob Storage イベントを変換する
Azure Blob Storage イベントをリアルタイム ハブの Fabric イベントにリンクした後、これらのイベントをストリームに変換し、eventstreams 内で変換を実行できます。
編集モードで Azure Blob Storage イベント ソースを追加した後、ソースの [ストリーム イベント] を選択して、Blob Storage イベントをデータ ストリームに変換します。
Blob Storage イベントをイベントストリームにストリーミングするかどうかを確認するポップアップに対して、[はい] と応答します。
エディターでは、既定のストリームが eventstream ノード内に作成され、Blob Storage イベントが既定のストリームとしてストリームに変換されることを示します。
次に、変換またはルーティングを続行するために、イベントストリームを発行し、Azure Blob Storage からトリガーされるイベントが少なくとも 1 つあることを確認する必要があります。
イベントがイベント ストリームに送られたら、編集モードに入り、ストリーミングされた Blob Storage イベントを変換する操作を追加します。 次の例は、Blob Storage イベントが集計され、KQL データベースにルーティングされることを示しています。
変更が発行されると、ストリーミングされた Azure Blob Storage イベントが変換され、Fabric で指定された宛先にルーティングされます。
検証のために、リアルタイム ハブの [データ ストリーム] タブでデータ ストリームを表示することもできます。
既知の制限事項
- 現時点では、個別のイベント ソースでエラーが発生した場合、エラー メッセージは使用できません。
- 現時点では、データ プレビュー機能は個別のイベント ソースでは使用できません。