クイックスタート: Azure CLI と Event Grid を使用してカスタム イベントを Azure Event Hubs にルーティングする

Azure Event Grid は、非常にスケーラブルなサーバーレスのイベント ブローカーであり、イベントを使ってアプリケーションを統合するために使用できます。 Event Grid はイベントをサポートされているイベント ハンドラーに配信し、Azure Event Hubs はその 1 つです。 この記事では、Azure CLI を使って次の手順のようにします。

1. Event Grid のカスタム トピックを作成します。
2. カスタム トピック用の Azure Event Hubs サブスクリプションを作成します。
3. サンプル イベントをカスタム トピックに送信します。
4. それらのイベントがイベント ハブに配信されることを確認します。

Azure サブスクリプションをお持ちでない場合は、開始する前に Azure 無料アカウントを作成してください。

リソース グループを作成する

Event Grid のトピックは Azure リソースであり、Azure リソース グループに配置する必要があります。 リソース グループは、Azure リソースをまとめてデプロイして管理するための論理上のコレクションです。

az group create コマンドを使用して、リソース グループを作成します。 次の例では、gridResourceGroup という名前のリソース グループを westus2 の場所に作成します。

注意

CLI の例の横にある [使ってみる] を選び、右側のペインで Cloud Shell を起動します。 [コピー] ボタンを選んでコマンドをコピーし、Cloud Shell ウィンドウに貼り付けてから、Enter キーを押してコマンドを実行します。

az group create --name gridResourceGroup --location westus2

Event Grid リソース プロバイダーを有効にする

1. Azure サブスクリプションで Event Grid を使用したことがない場合は、Event Grid リソース プロバイダーを登録する必要がある可能性があります。 以下のプロバイダーを登録するコマンドを実行します。

   az provider register --namespace Microsoft.EventGrid
   

2. 登録完了まで少し時間がかかることがあります。 状態を確認するには、次のコマンドを実行します。

   az provider show --namespace Microsoft.EventGrid --query "registrationState"
   

   registrationState が Registered になったら、次に進めることができます。

カスタム トピックの作成

Event Grid のトピックは、イベントの送信先となるユーザー定義のエンドポイントになります。 次の例では、リソース グループにカスタム トピックを作成します。 <topic_name> は、カスタム トピックの一意の名前に置き換えてください。 Event Grid トピック名は、ドメイン ネーム システム (DNS) エントリによって表されるため、一意である必要があります。

1. トピックの名前を指定します。

   topicname="<TOPIC NAME>"
   

2. 次のコマンドを実行して、トピックを作成します。

   az eventgrid topic create --name $topicname -l westus2 -g gridResourceGroup
   

イベント ハブの作成

カスタム トピックをサブスクライブする前に、イベント メッセージ用のエンドポイントを作成しましょう。 イベントを収集するためのイベント ハブを作成します。

1. Event Hubs 名前空間の一意の名前を指定します。

   namespace="<EVENT HUBS NAMESPACE NAME>"
   

2. 次のコマンドを実行して、Event Hubs 名前空間を作成し、その名前空間内に demohub という名前のイベント ハブを作成します。

   hubname=demohub
   
   az eventhubs namespace create --name $namespace --resource-group gridResourceGroup
   az eventhubs eventhub create --name $hubname --namespace-name $namespace --resource-group gridResourceGroup
   

カスタム トピックへのサブスクライブ

Event Grid トピックをサブスクライブすることによって、追跡対象のイベントを Event Grid に伝えます。次の例では、作成したカスタム トピックをサブスクライブし、エンドポイントのイベント ハブのリソース ID を渡します。 エンドポイントの形式は次のとおりです。

/subscriptions/<AZURE SUBSCRIPTION ID>/resourceGroups/<RESOURCE GROUP NAME>/providers/Microsoft.EventHub/namespaces/<NAMESPACE NAME>/eventhubs/<EVENT HUB NAME>

次のスクリプトは、イベント ハブのリソース ID を取得して、Event Grid トピックをサブスクライブします。 エンドポイントの種類を eventhub に設定し、エンドポイントのイベント ハブ ID を使用します。

hubid=$(az eventhubs eventhub show --name $hubname --namespace-name $namespace --resource-group gridResourceGroup --query id --output tsv)
topicid=$(az eventgrid topic show --name $topicname -g gridResourceGroup --query id --output tsv)

az eventgrid event-subscription create \
  --source-resource-id $topicid \
  --name subtoeventhub \
  --endpoint-type eventhub \
  --endpoint $hubid

イベント サブスクリプションを作成するアカウントは、イベント ハブへの書き込みアクセス権を持っている必要があります。

カスタム トピックへのイベントの送信

イベントをトリガーして、Event Grid がメッセージをエンドポイントに配信するようすを見てみましょう。 まず、カスタム トピックの URL とキーを取得します。

endpoint=$(az eventgrid topic show --name $topicname -g gridResourceGroup --query "endpoint" --output tsv)
key=$(az eventgrid topic key list --name $topicname -g gridResourceGroup --query "key1" --output tsv)

この記事では、単純化するために、サンプル イベント データをカスタム トピックに送信します。 通常はイベント データをアプリケーションまたは Azure サービスから送信することになります。 CURL は、HTTP 要求を送信するユーティリティです。 この記事では、CURL を使用して、イベントをカスタム トピックに送信します。 次の例では、3 つのイベントを Event Grid トピックに送信します。

for i in 1 2 3
do
   event='[ {"id": "'"$RANDOM"'", "eventType": "recordInserted", "subject": "myapp/vehicles/motorcycles", "eventTime": "'`date +%Y-%m-%dT%H:%M:%S%z`'", "data":{ "make": "Ducati", "model": "Monster"},"dataVersion": "1.0"} ]'
   curl -X POST -H "aeg-sas-key: $key" -d "$event" $endpoint
done

Azure portal の Event Hubs 名前空間の [概要] ページで、Event Grid によってそれらの 3 つのイベントがイベント ハブに送信されたことを確認します。 demohub Event Hubs インスタンス ページの [概要] ページに、同じグラフが表示されます。

通常は、イベント ハブからイベントを取得するアプリケーションを作成します。 イベント ハブからメッセージを取得するアプリケーションを作成するには、以下を参照してください。

• .NET Standard で EventProcessorHost を使用したメッセージ受信を開始する
• Java を使用して Azure Event Hubs からイベントを受信する
• Apache Storm を使用して Azure Event Hubs からイベントを受信する

リソースをクリーンアップする

引き続きこのイベントを使用する場合は、この記事で作成したリソースをクリーンアップしないでください。 それ以外の場合は、次のコマンドを使用して、この記事で作成したリソースを削除します。

az group delete --name gridResourceGroup

次のステップ

トピックを作成し、イベントをサブスクライブする方法がわかったら、Event Grid でできることについて、さらに情報を収集しましょう。

• Event Grid について
• Blob Storage のイベントをカスタム Web エンドポイントにルーティングする
• Azure Event Grid と Logic Apps で仮想マシンの変更を監視する
• ビッグ データをデータ ウェアハウスにストリーミングする

さまざまなプログラミング言語を使用して Event Grid でイベントを発行および使用する方法については、次のサンプルを参照してください。

• .NET 用の Azure Event Grid サンプル
• Java 用の Azure Event Grid サンプル
• Python 用の Azure Event Grid サンプル
• JavaScript 用の Azure Event Grid サンプル
• TypeScript 用の Azure Event Grid サンプル