Azure CLI を使用して Service Bus トピックとそのサブスクリプションを作成する

[アーティクル]
06/01/2023

このクイックスタートでは、Azure CLI を使用して Service Bus トピックを作成した後、そのトピックのサブスクリプションを作成します。

Service Bus トピックとサブスクリプションとは

Service Bus のトピックとサブスクリプションは、メッセージ通信の 発行/サブスクライブ モデルをサポートします。トピックとサブスクリプションを使用すると、分散アプリケーションのコンポーネントが互いに直接通信することがなくなり、仲介者の役割を果たすトピックを介してメッセージをやり取りすることになります。

TopicConcepts

各メッセージが 1 つのコンシューマーによって処理される Service Bus キューとは異なり、トピックとサブスクリプションは、発行/サブスクライブパターンを使用して "1 対多" 形式の通信を行います。複数のサブスクリプションを 1 つのトピックに登録できます。トピックに送信されたメッセージはサブスクリプションに渡され、各サブスクリプションで独立して処理できます。トピックにとってのサブスクリプションは、トピックに送信されたメッセージのコピーを受け取る仮想キューのようなものです。トピックに対するフィルタールールをサブスクリプション単位で登録することもできます。この場合、トピックに送信されるどのメッセージをどのトピックサブスクリプションで受信するかのフィルター処理や制限が可能になります。

Service Bus のトピックとサブスクリプションを使用すると、多数のユーザーとアプリケーションの間でやり取りされる膨大な数のメッセージを処理することもできます。

前提条件

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

このクイックスタートでは、Azure portal へのサインイン後に起動できる Azure Cloud Shell を使用します。 Azure Cloud Shell の詳細については、「Azure Cloud Shell の概要」を参照してください。 Azure PowerShell を自分のマシンにインストールして使用することもできます。

Service Bus トピックとサブスクリプションを作成する

トピックへの各サブスクリプションは、各メッセージのコピーを受信できます。トピックは完全にプロトコルであり、意味的には Service Bus キューと互換性があります。 Service Bus のトピックは、フィルターの条件を持つさまざまな選択ルールをサポートしています。メッセージのプロパティを設定または変更するオプションのアクションもあります。ルールが一致するたびに、メッセージが生成されます。ルール、フィルター、およびアクションの詳細については、こちらのリンクを参照してください。

Azure portal にサインインします。
次の画像に示すアイコンを選択して Azure Cloud Shell を起動します。 Cloud Shell が PowerShell モードになっている場合は Bash モードに切り替えます。
次のコマンドを実行して、Azure リソースグループを作成します。必要に応じて、リソースグループの名前と場所を更新します。
```
az group create --name MyResourceGroup --location eastus
```
次のコマンドを実行して、Service Bus メッセージング名前空間を作成します。名前空間は、一意の名前となるように更新してください。
```
namespaceName=MyNameSpace$RANDOM
az servicebus namespace create --resource-group MyResourceGroup --name $namespaceName --location eastus
```

次のコマンドを実行して、名前空間にトピックを作成します。

az servicebus topic create --resource-group MyResourceGroup   --namespace-name $namespaceName --name MyTopic

トピックの 1 つ目のサブスクリプションを作成します。

az servicebus topic subscription create --resource-group MyResourceGroup --namespace-name $namespaceName --topic-name MyTopic --name S1

トピックの 2 つ目のサブスクリプションを作成します。

az servicebus topic subscription create --resource-group MyResourceGroup --namespace-name $namespaceName --topic-name MyTopic --name S2

トピックの 3 つ目のサブスクリプションを作成します。

az servicebus topic subscription create --resource-group MyResourceGroup --namespace-name $namespaceName --topic-name MyTopic --name S3

1 つ目のサブスクリプションにフィルターを作成します。カスタムプロパティを使用してフィルター (StoreId が Store1、Store2、Store3 のいずれか) を設定してください。

az servicebus topic subscription rule create --resource-group MyResourceGroup --namespace-name $namespaceName --topic-name MyTopic --subscription-name S1 --name MyFilter --filter-sql-expression "StoreId IN ('Store1','Store2','Store3')"

2 つ目のサブスクリプションにフィルターを作成します。カスタムプロパティを使用してフィルター (StoreId = Store4) を設定してください。

az servicebus topic subscription rule create --resource-group MyResourceGroup --namespace-name $namespaceName --topic-name myTopic --subscription-name S2 --name MySecondFilter --filter-sql-expression "StoreId = 'Store4'"

3 つ目のサブスクリプションにフィルターを作成します。カスタムプロパティを使用してフィルター (StoreId が Store1、Store2、Store3、Store4 のいずれでもない) を設定してください。

az servicebus topic subscription rule create --resource-group MyResourceGroup --namespace-name $namespaceName --topic-name MyTopic --subscription-name S3 --name MyThirdFilter --filter-sql-expression "StoreId NOT IN ('Store1','Store2','Store3', 'Store4')"

次のコマンドを実行して、名前空間のプライマリ接続文字列を取得します。この接続文字列を使用してキューに接続し、メッセージを送受信します。
```
az servicebus namespace authorization-rule keys list --resource-group MyResourceGroup --namespace-name $namespaceName --name RootManageSharedAccessKey --query primaryConnectionString --output tsv    
```
接続文字列とトピック名を書き留めておきます。これらの情報を使用して、メッセージを送受信します。

次の手順

トピックにメッセージを送信してそれらのメッセージをサブスクリプション経由で受信する方法については、次の記事を参照してください。TOC からプログラミング言語を選択してください。

メッセージの発行とサブスクライブ

次の方法で共有