チュートリアル: Dapr Publish と Subscribe を使用したマイクロサービス通信

[アーティクル]
08/09/2024

このチュートリアルでは、Dapr pub/sub API を利用して、イベント駆動型アーキテクチャのメッセージを使って通信する、パブリッシャーとサブスクライバーのマイクロサービスを作成します。次のことを行います。

Dapr pub/sub API を活用して、イベントドリブンアーキテクチャのメッセージを使用して通信するパブリッシャーマイクロサービスとサブスクライバーマイクロサービスを作成します。
提供されている Bicep を使用して、Azure Developer CLI を介して Azure Container Apps にアプリケーションをデプロイします。

サンプルの pub/sub プロジェクトには、次のものが含まれます。

特定のトピックのメッセージを生成するメッセージジェネレーター checkout サービス (パブリッシャー)。
特定のトピックの checkout サービスからのメッセージをリッスンする order-processor サービス (サブスクライバー)。

pub/sub サンプルの図。

前提条件

Azure Developer CLI をインストールする
Dapr のインストールと初期化
Docker Desktop
Git

Node.js アプリケーションをローカルで実行する

Azure Container Apps にアプリケーションをデプロイする前に、Dapr と Azure Service Bus を使用して order-processor サービスと checkout サービスをローカルで実行します。

プロジェクトを準備する

サンプルアプリケーションをローカルコンピューターにクローンします。
```
git clone https://github.com/Azure-Samples/pubsub-dapr-nodejs-servicebus.git
```
サンプルのルートディレクトリに移動します。
```
cd pubsub-dapr-nodejs-servicebus
```

Dapr CLI を使用してアプリケーションを実行する

最初に、order-processor サブスクライバーサービスを実行します。

サンプルのルートディレクトリから、ディレクトリを order-processor に変更します。
```
cd order-processor
```
依存関係をインストールします。
```
npm install
```

order-processor サービスを実行します。

dapr run --app-port 5001 --app-id order-processing --app-protocol http --dapr-http-port 3501 --resources-path ../components -- npm run start

新しいターミナルウィンドウで、サンプルのルートディレクトリから checkout パブリッシャーサービスに移動します。
```
cd checkout
```
依存関係をインストールします。
```
npm install
```

checkout サービスを実行します。

dapr run --app-id checkout --app-protocol http --resources-path ../components -- npm run start

想定される出力

どちらのターミナルでも、checkout サービスは終了する前に order-processor サービスが受信した 10 個のメッセージを発行します。

checkout 出力:

== APP == Published data: {"orderId":1}
== APP == Published data: {"orderId":2}
== APP == Published data: {"orderId":3}
== APP == Published data: {"orderId":4}
== APP == Published data: {"orderId":5}
== APP == Published data: {"orderId":6}
== APP == Published data: {"orderId":7}
== APP == Published data: {"orderId":8}
== APP == Published data: {"orderId":9}
== APP == Published data: {"orderId":10}

order-processor 出力:

== APP == Subscriber received: {"orderId":1}
== APP == Subscriber received: {"orderId":2}
== APP == Subscriber received: {"orderId":3}
== APP == Subscriber received: {"orderId":4}
== APP == Subscriber received: {"orderId":5}
== APP == Subscriber received: {"orderId":6}
== APP == Subscriber received: {"orderId":7}
== APP == Subscriber received: {"orderId":8}
== APP == Subscriber received: {"orderId":9}
== APP == Subscriber received: {"orderId":10}

次のコマンドを実行して、両方のアプリケーションが停止していることを確認します。チェックアウトターミナルで、次の手順を実行します。
```
dapr stop --app-id checkout
```
オーダープロセッサーターミナルで、次の手順を実行します。
```
dapr stop --app-id order-processor
```

Azure Developer CLI を使用してアプリケーションテンプレートをデプロイする

azd を使用して、アプリケーションを Azure Container Apps にデプロイします。

プロジェクトを準備する

新しいターミナルウィンドウで、サンプルのルートディレクトリに移動します。

cd pubsub-dapr-nodejs-servicebus

Azure Developer CLI を使用したプロビジョニングとデプロイ

azd init を実行してプロジェクトを初期化します。
```
azd init
```

ターミナルでメッセージが表示されたら、次のパラメーターを指定します。

パラメーター	説明
Environment Name	すべての Azure リソースを保持するために作成されたリソースグループのプレフィックス。
Azure の場所	リソースの Azure の場所。
Azure サブスクリプション	リソースの Azure サブスクリプション。

azd up を実行して、1 つのコマンドでインフラストラクチャをプロビジョニングしてアプリケーションを Azure Container Apps にデプロイします。
```
azd up
```
この処理は、完了までに時間がかかる場合があります。 azd up コマンドが完了すると、CLI 出力に、デプロイの進行状況を監視するための 2 つの Azure portal リンクが表示されます。また、出力では、次の azd up の方法も示されます。
- azd provision を使用して、./infra ディレクトリ内の指定されている Bicep ファイルを使用して、必要なすべての Azure リソースを作成して構成します。 Azure Developer CLI によってプロビジョニングされると、Azure portal からこれらのリソースにアクセスできます。 Azure リソースをプロビジョニングするファイルは次のとおりです。
  - main.parameters.json
  - main.bicep
  - 機能別に整理された app リソースディレクトリ
  - azd テンプレートで使用される Bicep モジュールを含む core リファレンスライブラリ
- azd deploy を使用したコードのデプロイ
想定される出力
```
Initializing a new project (azd init)


Provisioning Azure resources (azd provision)
Provisioning Azure resources can take some time

  You can view detailed progress in the Azure Portal:
  https://portal.azure.com

  (✓) Done: Resource group: resource-group-name
  (✓) Done: Application Insights: app-insights-name
  (✓) Done: Portal dashboard: portal-dashboard-name
  (✓) Done: Log Analytics workspace: log-analytics-name
  (✓) Done: Key vault: key-vault-name
  (✓) Done: Container Apps Environment: ca-env-name
  (✓) Done: Container App: ca-checkout-name
  (✓) Done: Container App: ca-orders-name


Deploying services (azd deploy)

  (✓) Done: Deploying service checkout
  (✓) Done: Deploying service orders
  - Endpoint: https://ca-orders-name.endpoint.region.azurecontainerapps.io/

SUCCESS: Your Azure app has been deployed!
You can view the resources created under the resource group resource-group-name in Azure Portal:
https://portal.azure.com/#@/resource/subscriptions/subscription-id/resourceGroups/resource-group-name/overview
```

デプロイが成功したことを確認する

Azure portal で、checkout サービスが Azure Service Bus トピックにメッセージを公開していることを確認します。

ターミナル出力から checkout コンテナーアプリ名をコピーします。
Azure portal にサインインし、名前でコンテナーアプリリソースを検索します。
Container Apps ダッシュボードで、[監視]>[ログストリーム] を選択します。
checkout コンテナーが先ほどのターミナルと同じ出力をログに記録しているかどうかを確認します。
order-processor サービスに対して同じことを行います。

何が起きましたか?

azd up コマンドが正常に完了した場合、次のようになります。

Azure Developer CLI は、サンプルプロジェクトの ./infra ディレクトリで参照されている Azure リソースを、指定した Azure サブスクリプションにプロビジョニングしました。これにより Azure portal から、これらの Azure リソースを表示できるようになりました。
Azure Container Apps にデプロイされたアプリ。ポータルから、完全に機能するアプリを参照できます。

Python アプリケーションをローカルで実行する

プロジェクトを準備する

サンプルアプリケーションをローカルコンピューターにクローンします。
```
git clone https://github.com/Azure-Samples/pubsub-dapr-python-servicebus.git
```
サンプルのルートディレクトリに移動します。
```
cd pubsub-dapr-python-servicebus
```

Dapr CLI を使用してアプリケーションを実行する

最初に、order-processor サブスクライバーサービスを実行します。

サンプルのルートディレクトリから、ディレクトリを order-processor に変更します。
```
cd order-processor
```
依存関係をインストールします。
```
pip3 install -r requirements.txt
```

order-processor サービスを実行します。

dapr run --app-id order-processor --resources-path ../components/ --app-port 5001 -- python3 app.py

新しいターミナルウィンドウで、サンプルのルートディレクトリから checkout パブリッシャーサービスに移動します。
```
cd checkout
```
依存関係をインストールします。
```
pip3 install -r requirements.txt
```

checkout サービスを実行します。

dapr run --app-id checkout --resources-path ../components/ -- python3 app.py

想定される出力

どちらのターミナルでも、checkout サービスは終了する前に order-processor サービスが受信した 10 個のメッセージを発行します。

checkout 出力:

== APP == Published data: {"orderId":1}
== APP == Published data: {"orderId":2}
== APP == Published data: {"orderId":3}
== APP == Published data: {"orderId":4}
== APP == Published data: {"orderId":5}
== APP == Published data: {"orderId":6}
== APP == Published data: {"orderId":7}
== APP == Published data: {"orderId":8}
== APP == Published data: {"orderId":9}
== APP == Published data: {"orderId":10}

order-processor 出力:

== APP == Subscriber received: {"orderId":1}
== APP == Subscriber received: {"orderId":2}
== APP == Subscriber received: {"orderId":3}
== APP == Subscriber received: {"orderId":4}
== APP == Subscriber received: {"orderId":5}
== APP == Subscriber received: {"orderId":6}
== APP == Subscriber received: {"orderId":7}
== APP == Subscriber received: {"orderId":8}
== APP == Subscriber received: {"orderId":9}
== APP == Subscriber received: {"orderId":10}

次のコマンドを実行して、両方のアプリケーションが停止していることを確認します。チェックアウトターミナルで、次の手順を実行します。
```
dapr stop --app-id checkout
```
オーダープロセッサーターミナルで、次の手順を実行します。
```
dapr stop --app-id order-processor
```

Azure Developer CLI を使用してアプリケーションテンプレートをデプロイする

azd を使用して、アプリケーションを Azure Container Apps にデプロイします。

プロジェクトを準備する

新しいターミナルウィンドウで、サンプルのルートディレクトリに移動します。

cd pubsub-dapr-python-servicebus

Azure Developer CLI を使用したプロビジョニングとデプロイ

azd init を実行してプロジェクトを初期化します。
```
azd init
```

ターミナルでメッセージが表示されたら、次のパラメーターを指定します。

パラメーター	説明
Environment Name	すべての Azure リソースを保持するために作成されたリソースグループのプレフィックス。
Azure の場所	リソースの Azure の場所。
Azure サブスクリプション	リソースの Azure サブスクリプション。

azd up を実行して、1 つのコマンドでインフラストラクチャをプロビジョニングしてアプリケーションを Azure Container Apps にデプロイします。
```
azd up
```
この処理は、完了までに時間がかかる場合があります。 azd up コマンドが完了すると、CLI 出力に、デプロイの進行状況を監視するための 2 つの Azure portal リンクが表示されます。また、出力では、次の azd up の方法も示されます。
- azd provision を使用して、./infra ディレクトリ内の指定されている Bicep ファイルを使用して、必要なすべての Azure リソースを作成して構成します。 Azure Developer CLI によってプロビジョニングされると、Azure portal からこれらのリソースにアクセスできます。 Azure リソースをプロビジョニングするファイルは次のとおりです。
  - main.parameters.json
  - main.bicep
  - 機能別に整理された app リソースディレクトリ
  - azd テンプレートで使用される Bicep モジュールを含む core リファレンスライブラリ
- azd deploy を使用したコードのデプロイ
想定される出力
```
Initializing a new project (azd init)


Provisioning Azure resources (azd provision)
Provisioning Azure resources can take some time

  You can view detailed progress in the Azure Portal:
  https://portal.azure.com

  (✓) Done: Resource group: resource-group-name
  (✓) Done: Application Insights: app-insights-name
  (✓) Done: Portal dashboard: portal-dashboard-name
  (✓) Done: Log Analytics workspace: log-analytics-name
  (✓) Done: Key vault: key-vault-name
  (✓) Done: Container Apps Environment: ca-env-name
  (✓) Done: Container App: ca-checkout-name
  (✓) Done: Container App: ca-orders-name


Deploying services (azd deploy)

  (✓) Done: Deploying service checkout
  (✓) Done: Deploying service orders
  - Endpoint: https://ca-orders-name.endpoint.region.azurecontainerapps.io/

SUCCESS: Your Azure app has been deployed!
You can view the resources created under the resource group resource-group-name in Azure Portal:
https://portal.azure.com/#@/resource/subscriptions/subscription-id/resourceGroups/resource-group-name/overview
```

デプロイが成功したことを確認する

Azure portal で、checkout サービスが Azure Service Bus トピックにメッセージを公開していることを確認します。

ターミナル出力から checkout コンテナーアプリ名をコピーします。
Azure portal にサインインし、名前でコンテナーアプリリソースを検索します。
Container Apps ダッシュボードで、[監視]>[ログストリーム] を選択します。
checkout コンテナーが先ほどのターミナルと同じ出力をログに記録しているかどうかを確認します。
order-processor サービスに対して同じことを行います。

何が起きましたか?

azd up コマンドが正常に完了した場合、次のようになります。

Azure Developer CLI は、サンプルプロジェクトの ./infra ディレクトリで参照されている Azure リソースを、指定した Azure サブスクリプションにプロビジョニングしました。これにより Azure portal から、これらの Azure リソースを表示できるようになりました。
Azure Container Apps にデプロイされたアプリ。ポータルから、完全に機能するアプリを参照できます。

.NET アプリケーションをローカルで実行する

プロジェクトを準備する

サンプルアプリケーションをローカルコンピューターにクローンします。
```
git clone https://github.com/Azure-Samples/pubsub-dapr-csharp-servicebus.git
```
サンプルのルートディレクトリに移動します。
```
cd pubsub-dapr-csharp-servicebus
```

Dapr CLI を使用してアプリケーションを実行する

最初に、order-processor サブスクライバーサービスを実行します

サンプルのルートディレクトリから、ディレクトリを order-processor に変更します。
```
cd order-processor
```
依存関係をインストールします。
```
dotnet build
```

order-processor サービスを実行します。

dapr run --app-id order-processor --resources-path ../components/ --app-port 7001 -- dotnet run --project .

新しいターミナルウィンドウで、サンプルのルートディレクトリから checkout パブリッシャーサービスに移動します。
```
cd checkout
```
依存関係をインストールします。
```
dotnet build
```

checkout サービスを実行します。

dapr run --app-id checkout --resources-path ../components/ -- dotnet run --project .

想定される出力

どちらのターミナルでも、checkout サービスは終了する前に order-processor サービスが受信した 10 個のメッセージを発行します。

checkout 出力:

== APP == Published data: {"orderId":1}
== APP == Published data: {"orderId":2}
== APP == Published data: {"orderId":3}
== APP == Published data: {"orderId":4}
== APP == Published data: {"orderId":5}
== APP == Published data: {"orderId":6}
== APP == Published data: {"orderId":7}
== APP == Published data: {"orderId":8}
== APP == Published data: {"orderId":9}
== APP == Published data: {"orderId":10}

order-processor 出力:

== APP == Subscriber received: {"orderId":1}
== APP == Subscriber received: {"orderId":2}
== APP == Subscriber received: {"orderId":3}
== APP == Subscriber received: {"orderId":4}
== APP == Subscriber received: {"orderId":5}
== APP == Subscriber received: {"orderId":6}
== APP == Subscriber received: {"orderId":7}
== APP == Subscriber received: {"orderId":8}
== APP == Subscriber received: {"orderId":9}
== APP == Subscriber received: {"orderId":10}

次のコマンドを実行して、両方のアプリケーションが停止していることを確認します。チェックアウトターミナルで。
```
dapr stop --app-id checkout
```
オーダープロセッサーターミナルで、次の手順を実行します。
```
dapr stop --app-id order-processor
```

Azure Developer CLI を使用してアプリケーションテンプレートをデプロイする

azd を使用して、アプリケーションを Azure Container Apps にデプロイします。

プロジェクトを準備する

新しいターミナルウィンドウで、サンプルのルートディレクトリに移動します。

cd pubsub-dapr-csharp-servicebus

Azure Developer CLI を使用したプロビジョニングとデプロイ

azd init を実行してプロジェクトを初期化します。
```
azd init
```

ターミナルでメッセージが表示されたら、次のパラメーターを指定します。

パラメーター	説明
Environment Name	すべての Azure リソースを保持するために作成されたリソースグループのプレフィックス。
Azure の場所	リソースの Azure の場所。
Azure サブスクリプション	リソースの Azure サブスクリプション。

azd up を実行して、1 つのコマンドでインフラストラクチャをプロビジョニングしてアプリケーションを Azure Container Apps にデプロイします。
```
azd up
```
この処理は、完了までに時間がかかる場合があります。 azd up コマンドが完了すると、CLI 出力に、デプロイの進行状況を監視するための 2 つの Azure portal リンクが表示されます。また、出力では、次の azd up の方法も示されます。
- azd provision を使用して、./infra ディレクトリ内の指定されている Bicep ファイルを使用して、必要なすべての Azure リソースを作成して構成します。 Azure Developer CLI によってプロビジョニングされると、Azure portal からこれらのリソースにアクセスできます。 Azure リソースをプロビジョニングするファイルは次のとおりです。
  - main.parameters.json
  - main.bicep
  - 機能別に整理された app リソースディレクトリ
  - azd テンプレートで使用される Bicep モジュールを含む core リファレンスライブラリ
- azd deploy を使用したコードのデプロイ
想定される出力
```
Initializing a new project (azd init)


Provisioning Azure resources (azd provision)
Provisioning Azure resources can take some time

  You can view detailed progress in the Azure Portal:
  https://portal.azure.com

  (✓) Done: Resource group: resource-group-name
  (✓) Done: Application Insights: app-insights-name
  (✓) Done: Portal dashboard: portal-dashboard-name
  (✓) Done: Log Analytics workspace: log-analytics-name
  (✓) Done: Key vault: key-vault-name
  (✓) Done: Container Apps Environment: ca-env-name
  (✓) Done: Container App: ca-checkout-name
  (✓) Done: Container App: ca-orders-name


Deploying services (azd deploy)

  (✓) Done: Deploying service checkout
  (✓) Done: Deploying service orders
  - Endpoint: https://ca-orders-name.endpoint.region.azurecontainerapps.io/

SUCCESS: Your Azure app has been deployed!
You can view the resources created under the resource group resource-group-name in Azure Portal:
https://portal.azure.com/#@/resource/subscriptions/subscription-id/resourceGroups/resource-group-name/overview
```

デプロイが成功したことを確認する

Azure portal で、checkout サービスが Azure Service Bus トピックにメッセージを公開していることを確認します。

ターミナル出力から checkout コンテナーアプリ名をコピーします。
Azure portal にサインインし、名前でコンテナーアプリリソースを検索します。
Container Apps ダッシュボードで、[監視]>[ログストリーム] を選択します。
checkout コンテナーが先ほどのターミナルと同じ出力をログに記録しているかどうかを確認します。
order-processor サービスに対して同じことを行います。

何が起きましたか?

azd up コマンドが正常に完了した場合、次のようになります。

Azure Developer CLI は、サンプルプロジェクトの ./infra ディレクトリで参照されている Azure リソースを、指定した Azure サブスクリプションにプロビジョニングしました。これにより Azure portal から、これらの Azure リソースを表示できるようになりました。
Azure Container Apps にデプロイされたアプリ。ポータルから、完全に機能するアプリを参照できます。

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

このアプリケーションを引き続き使用しない場合は、次のコマンドを使用して、プロビジョニングした Azure リソースを削除します。

azd down

次のステップ

Azure Container Apps へのアプリケーションのデプロイについて理解を深める。
Dapr 要求のトークン認証を有効にする。
Azure Developer CLI と、アプリケーションを azd と互換性のあるものにすることについての詳細情報。
KEDA スケーラーを使ってアプリケーションをスケーリングする

次の方法で共有

前提条件

Node.js アプリケーションをローカルで実行する

プロジェクトを準備する

Dapr CLI を使用してアプリケーションを実行する

想定される出力

Azure Developer CLI を使用してアプリケーションテンプレートをデプロイする

プロジェクトを準備する

Azure Developer CLI を使用したプロビジョニングとデプロイ

想定される出力

デプロイが成功したことを確認する

何が起きましたか?

Python アプリケーションをローカルで実行する

プロジェクトを準備する

Dapr CLI を使用してアプリケーションを実行する

想定される出力

Azure Developer CLI を使用してアプリケーションテンプレートをデプロイする

プロジェクトを準備する

Azure Developer CLI を使用したプロビジョニングとデプロイ

想定される出力

デプロイが成功したことを確認する

何が起きましたか?

.NET アプリケーションをローカルで実行する

プロジェクトを準備する

Dapr CLI を使用してアプリケーションを実行する

想定される出力

Azure Developer CLI を使用してアプリケーションテンプレートをデプロイする

プロジェクトを準備する

Azure Developer CLI を使用したプロビジョニングとデプロイ

想定される出力

デプロイが成功したことを確認する

何が起きましたか?

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

次のステップ

フィードバック

その他のリソース

次の方法で共有

前提条件

Node.js アプリケーションをローカルで実行する

プロジェクトを準備する

Dapr CLI を使用してアプリケーションを実行する

想定される出力

Azure Developer CLI を使用してアプリケーション テンプレートをデプロイする

プロジェクトを準備する

Azure Developer CLI を使用したプロビジョニングとデプロイ

想定される出力

デプロイが成功したことを確認する

何が起きましたか?

Python アプリケーションをローカルで実行する

プロジェクトを準備する

Dapr CLI を使用してアプリケーションを実行する

想定される出力

Azure Developer CLI を使用してアプリケーション テンプレートをデプロイする

プロジェクトを準備する

Azure Developer CLI を使用したプロビジョニングとデプロイ

想定される出力

デプロイが成功したことを確認する

何が起きましたか?

.NET アプリケーションをローカルで実行する

プロジェクトを準備する

Dapr CLI を使用してアプリケーションを実行する

想定される出力

Azure Developer CLI を使用してアプリケーション テンプレートをデプロイする

プロジェクトを準備する

Azure Developer CLI を使用したプロビジョニングとデプロイ

想定される出力

デプロイが成功したことを確認する

何が起きましたか?

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

次のステップ

フィードバック

その他のリソース

Azure Developer CLI を使用してアプリケーションテンプレートをデプロイする

Azure Developer CLI を使用してアプリケーションテンプレートをデプロイする

Azure Developer CLI を使用してアプリケーションテンプレートをデプロイする