次の方法で共有


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 イベントにリンクされ、さらにアクションを待機していることを示します。 アクションには、リアルタイム ハブの [ファブリック イベント] タブでパイプラインやノートブックなどのファブリック ジョブ 項目を実行するデータ アクティベーターを使用したアラートの作成が含まれます。

    ストリーミングされていない Azure Blob Storage イベントを示すスクリーンショット。[Stream イベント] ボタンが表示されています。

  • ストリーミング イベント。 これらのイベントは継続的なイベントに変換され、リアルタイムの変換と Fabric のさまざまな宛先へのルーティングを可能にして、詳細な分析を行うことができます。 イベントストリームで、ストリーミングされていない Azure Blob Storage ソースの [Stream events]\(ストリーム イベント\) ボタンを選択すると、イベントが連続イベントに変換されます。 その後、イベントストリームには既定のストリームが割り当てられ、操作を追加して Fabric の他の宛先にルーティングできます。

    イベントストリーム内のストリーミングされた Azure Blob Storage イベントを示すスクリーンショット。

前提条件

  • 投稿者以上の権限を持つ Fabric プレミアム ワークスペースへのアクセス権
  • Azure Blob Storage StorageV2 (汎用 v2)BlockBlobStorage、または BlobStorage アカウントへのアクセス。 ストレージ (汎用 v1) ストレージの種類は、Fabric イベント ストリームとの統合をサポートしていません。

Note

1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。

Event Grid ソースとしての Azure Blob Storage

  1. [イベントストリーム]を選択して新しいイベントストリームを作成します。 [拡張機能 (プレビュー)] オプションが有効になっていることを確認します。

    新しいイベントストリームの作成を示すスクリーンショット。

  2. 次の画面で、外部ソースの追加を選択します。

    [外部ソースの追加] を選択したスクリーンショット。

Azure Blob Storage イベントを構成して接続する

  1. [データ ソースの選択] 画面で、Azure Blob Storage イベントを選択します。

    Azure Blob Storage イベントの選択のスクリーンショット。

  2. [接続] 画面で、イベントストリームでキャプチャするサブスクリプションストレージ アカウントを選択します。

    [接続]画面のスクリーンショット。

  3. [次へ] を選択します。

  4. [確認と作成] 画面で概要を確認し、[追加] を選択して Azure Blob Storage イベントの構成を完了します。

    ホーム画面のスクリーンショット。

接続が作成されると、編集モードでイベントストリームに追加された Azure Blob Storage イベント ソースを確認できます。 [発行] を選択してイベントストリームを発行し、Azure Blob Storage イベントのキャプチャを開始します。

eventstream に追加された Azure Blob Storage イベント ソースのスクリーンショット。

Note

エディターの Eventstream ノードには、既定のストリームが作成されていません。 これは、Blob Storage イベントは引き続き個別のイベントの形式であり、まだストリームに変換されていないか、イベントストリームに接続されていないためです。

変更を発行すると、Azure Blob Storage アカウントがリアルタイム ハブリンクされます。 リアルタイム ハブ > ファブリック イベントの Azure Blob Storage イベント>に移動します。ドロップダウン リストで Azure Blob Storage アカウントを見つけ、BLOB ストレージ イベントに対してアクションを実行するトリガーを設定できます。

[リアルタイム ハブのファブリック イベント] で [Azure Blob Storage イベント] を選択するスクリーンショット。

リアルタイム ハブの [Azure Blob Storage イベント] ページのスクリーンショット。

Azure Blob Storage イベントを変換する

Azure Blob Storage イベントをリアルタイム ハブの Fabric イベントにリンクした後、これらのイベントをストリームに変換し、eventstreams 内で変換を実行できます。

  1. 編集モードで Azure Blob Storage イベント ソースを追加した後、ソースの [ストリーム イベント] を選択して、Blob Storage イベントをデータ ストリームに変換します。

    ストリーム イベントが強調表示されている編集モードのストリーミングされていないイベント ソースのスクリーンショット。

  2. Blob Storage イベントをイベントストリームにストリーミングするかどうかを確認するポップアップに対して、[はい] と応答します。

    ストリーミング イベントの確認ポップアップのスクリーンショット。

  3. エディターでは、既定のストリームが eventstream ノード内に作成され、Blob Storage イベントが既定のストリームとしてストリームに変換されることを示します。

    既定のストリームを示す編集モードの eventstream のスクリーンショット。

  4. 次に、変換またはルーティングを続行するために、イベントストリームを発行し、Azure Blob Storage からトリガーされるイベントが少なくとも 1 つあることを確認する必要があります。

    ライブ ビューの発行済みイベントストリームのスクリーンショット。

  5. イベントがイベント ストリームに送られたら、編集モードに入り、ストリーミングされた Blob Storage イベントを変換する操作を追加します。 次の例は、Blob Storage イベントが集計され、KQL データベースにルーティングされることを示しています。

    編集モードで変換されたイベントストリームのスクリーンショット。

  6. 変更が発行されると、ストリーミングされた Azure Blob Storage イベントが変換され、Fabric で指定された宛先にルーティングされます。

    既定のストリームを示すライブ モードで変換されたイベントストリームのスクリーンショット。

    検証のために、リアルタイム ハブの [データ ストリーム] タブでデータ ストリームを表示することもできます。

    リアルタイム ハブの [データ ストリーム] の下に表示されているイベントストリームのスクリーンショット。

既知の制限事項

  • 現時点では、個別のイベント ソースでエラーが発生した場合、エラー メッセージは使用できません。
  • 現時点では、データ プレビュー機能は個別のイベント ソースでは使用できません。