---
schema_version: "1"
id: e131c07ae606b4be6fefe7b12a09715d8460c2847da80b65e056e50e76772007
title: イベント駆動型アーキテクチャ
collection: architect
version: next
locale: ja-jp
portal_url: https://docs.salesforce.com/architect/next/ja-jp/decision-guides/guides/event-driven.md
canonical_url: https://staging.architect.salesforce.com/docs/architect/ja-jp/decision-guides/guide/event-driven.html
source_site: staging.architect.salesforce.com
content_type: documentation
content_hash: 03ea17848d87d0635a066858cbbc21f87b41d45f069d3df3437dceb64c27d4dc
products:
  - 決定ガイド
  - Architect Site Content Repo
updated_at: 2026-03-01T00:00:00Z
---
# イベント駆動型アーキテクチャに適したツールとパターンの使用

## 概要

イベント駆動型アーキテクチャでは、システムまたはアプリケーションの状態の変更を伝えるイベントの効率的な生産と消費がサポートされます。これらのアーキテクチャにより、システム間の柔軟な接続が可能になり、システム全体で動作するプロセスとほぼリアルタイムの更新がサポートされます。イベント駆動型アーキテクチャの利点は簡単にわかりますが、実装の詳細は必ずしも明確ではありません。イベント駆動型アーキテクチャパターンで考慮する必要がある機能は?これらのパターンでは具体的にどのような問題を解決しますか?ソリューションに適用される特別な考慮事項と、その解決に最適なパターンは?

このガイドでは、Salesforce テクノロジーを使用するときに、最適なイベント駆動型アーキテクチャを構築するために使用するパターンについて説明します。また、Salesforce で使用可能なイベントツールについて説明し、選択した使用事例のツールの推奨事項を示します。Salesforce に関連するデータレベルインテグレーションについての詳細は、『[Data Integration Decision Guide](/docs/architect/ja-jp/decision-guides/guide/data-integration) (データインテグレーション決定ガイド)』を参照してください。

## ポイント

- **要求への同期応答を必要としないプロセスには、イベント駆動型アーキテクチャを使用します。**このガイドで説明するパターンは、データの一貫性、拡張性、再利用を目的として設計されており、組織のアプリケーション環境が進化するにつれて技術的な負債を最小限に抑えるのに役立ちます。（詳細については、「[適切に設計](/docs/architect/ja-jp/well-architected/guide/reliable#スループット)されたスループット」を参照してください）。

- **MuleSoft または別のエンタープライズサービスバス (ESB) ソリューションが既存のランドスケープの一部である場合は、可能な限りそのソリューションを使用します。**これらのソリューションは、イベント駆動型アーキテクチャパターンをサポートすることを目的として設計されており、企業全体でインテグレーションを再利用できる強力な機能を備えています。

- **今後の公開/登録パターンには、ストリーミング API などの他の API を使用して独自のイベントハンドラを作成するのではなく、Pub/Sub API を使用します。**Pub/Sub API が正式リリースされたので、新しい公開/登録パターンに使用します。ストリーミング API やカスタム Apex サービスなど、他のプラットフォーム API を使用して既存のイベント通信を Pub/Sub API に移行できる場合は移行を計画します。

- **プラットフォームイベントと変更データキャプチャ （CDC） は、他のシステムで消費する必要があるレコードおよび項目の変更を公開するための推奨メカニズムです。**新しい実装では、PushTopic および Generic イベントを使用することはお勧めしません。Salesforce は、現在の機能の範囲内で引き続き PushTopic および汎用イベントをサポートしますが、この技術にさらに投資する予定はありません。

## 範囲内の商品

<table style="border:none;width:100%">
  <tbody>
    <tr style="border:none">
      <td style="text-align:center;vertical-align:middle;border:none;padding:0.25rem 0"><!-- Image: Salesforce Platform logo --><img style="border:none;margin:2rem 0rem;width:52px;height:52px;object-fit:contain" src="https://a.sfdcstatic.com/developer-website/prod/images/architect/salesforce.svg" alt="Salesforce Platform"></td>
      <td style="vertical-align:middle;border:none;padding:0.25rem 0"><a href="https://www.salesforce.com/platform/agentforce-platform">Salesforce Platform</a>は、従業員、自律型AIエージェント、会社のデータ、アプリケーションを単一の信頼できるシステムに統合し、生産性とカスタマー エクスペリエンスを向上させる包括的なAI駆動型プラットフォームです。Customer 360アプリケーション、Data Cloud、Slackを接続してエンドツーエンドの自動化を実現することで、「エージェント エンタープライズ」の作成を可能にします。</td>
    </tr>
    <tr style="border:none">
      <td style="text-align:center;vertical-align:middle;border:none;padding:0.25rem 0"><!-- Image: MuleSoft logo --><img style="border:none;margin:2rem 0rem;width:52px;height:52px;object-fit:contain" src="https://architect.salesforce.com/ns-assets/logos/mulesoft-new.png" alt="MuleSoft"></td>
      <td style="vertical-align:middle;border:none;padding:0.25rem 0"><a href="https://www.salesforce.com/mulesoft/">MuleSoft</a>は、オン プレミス環境とクラウド環境でアプリケーション、データ、デバイスを接続できるSalesforceの主要な統合プラットフォームです。MuleSoft は、システム全体のデータをロック解除し、拡張性の高いインテグレーションおよび自動化フレームワークを開発し、差別化された接続された環境を迅速に作成するためのプラットフォームを IT 部門に提供するプラットフォームです。</td>
    </tr>
  </tbody>
</table>

## 決定ポイント

イベント駆動型アーキテクチャ (EDA) は、ほぼリアルタイムの通知が必要なシナリオ、大量のメッセージや複雑なメッセージの処理負荷の分散、およびキューイングによる接続の復元性が必要な IoT やモバイルデバイスなどのシステムの統合にお勧めします。ただし、EDA は非同期実行を目的として設計されているため、即時の同期的な人間の応答を必要とするプロセスには実装しないでください。また、ソースデータがそれほど頻繁に変更されないため、一括処理などの単純なパターンで十分である場合にも適していません。

### イベント駆動型アーキテクチャを使用するケース

イベント駆動型アーキテクチャに適していることが多い一般的なシナリオを次に示します。

<table style="width:100%">
<thead>
<tr><th scope="col">決定ポイント</th><th scope="col">ガイダンス</th></tr>
</thead>
<tbody>
<tr><td><strong>ほぼリアルタイムの通知</strong></td><td>公開/登録、ファンアウト、ストリーミングなどのイベント駆動型アーキテクチャパターンは、複数のアプリケーションに状況の変更やレコードの更新をほぼリアルタイムで通知する必要があるシナリオで適切に機能する傾向にあります。</td></tr>
<tr><td><strong>並列処理</strong></td><td>公開/登録などのパターンは、大量のデータや非常に複雑なメッセージで処理の負荷を複数のシステムに分散する必要がある場合に適しています。</td></tr>
<tr><td><strong>大量読み取り</strong></td><td>[合格メッセージ] および [キュー] パターンは、組織で急増が発生し、生成されるメッセージの量が登録者の即時処理能力を超える可能性があるシナリオでよく使用されます。</td></tr>
<tr><td><strong>大量書き込み</strong></td><td>ストリーミングとキューイングのパターンは、生成されるメッセージ数が急増する多くのシナリオで適切に機能します。</td></tr>
<tr><td><strong>異なるシステムへの同じデータの送信</strong></td><td>公開/登録は、同じデータを複数のシステムに送信する必要がある組織にとってかなり一般的なソリューションですが、ここで説明するほとんどのパターンで対処できます。必ず詳細に確認して、最適な方法を見つけてください。</td></tr>
<tr><td><strong>新しいシステムまたはデバイスの頻繁な導入</strong></td><td>公開/登録、ストリーミング、および順番待ちパターンは、新しいシステムやデバイスが定期的に追加され、全体的な状況が変動する傾向があるシナリオに適しています。このシナリオでは、新しいシステムまたはデバイスは、イベントバスの登録者になるか、キューに関連付けられているだけで、メッセージの受信を開始できます。カスタムのポイントツーポイントインテグレーションは必要ありません。</td></tr>
<tr><td><strong>IoTデバイス</strong></td><td>通常、IoT デバイスは頻繁に更新を行い、一部のシナリオではメッセージの急増も発生するため、ストリーミングとキューイングのパターンは IT ランドスケープに統合すると適切に機能する傾向にあります。</td></tr>
<tr><td><strong>オフラインモバイルデバイスおよびシステム</strong></td><td>品質が低い、または存在しないインターネットアクセスや、メッセージが配信された時点でオフラインになっている可能性があるシステムで作業する必要があるモバイルデバイスは、キューに接続して、オンラインに戻ったら関連するメッセージを取得できるようにするキューパターンを利用できます。</td></tr>
</tbody>
</table>

ほとんどの大規模組織では、さまざまな機能を備えた複数のシステムが混在した複雑な IT 環境があります。イベント駆動型インテグレーションをサポートしていないレガシーシステムが組織に存在している可能性があります。また、システムでサポートされる場合でも、イベント駆動型インテグレーションが役に立たない使用事例もあります (サードパーティからの SFTP ファイル転送など)。一歩下がって組織の IT ランドスケープ全体を見ると、他のアーキテクチャソリューションと同様に、さまざまなシナリオをサポートするためにさまざまなパターンを採用する可能性があります。イベント駆動型をインテグレーションの推奨アプローチにする場合は、ツールボックスの別のツールと考えてください。適切なシナリオで使用できますが、すべてのシステムに適用されるアプローチではありません。包括的なインテグレーション戦略を作成すると、このガイドで説明されているパターンが適切な場合と適さない場合を判断するのに役立ちます。

### イベント駆動型アーキテクチャを使用しない場合

多くのシナリオではイベント駆動型アーキテクチャが必要です。一部のシナリオでは、イベント駆動型アーキテクチャが最適でなくても機能します。ただし、一部のシナリオでは、イベント駆動型アーキテクチャは使用すべきではありません。次のシナリオを特定するのに役立つ判断基準の質問をいくつか紹介します。

<table style="width:100%">
<thead>
<tr><th scope="col">決定ポイント</th><th scope="col">ガイダンス/質問</th></tr>
</thead>
<tbody>
<tr><td><strong>ビジネス要件</strong></td><td>「イベント駆動型アーキテクチャを使用するケース」セクション(#イベント駆動型アーキテクチャを使用するケース)に記載されている機能のいずれかに、本当にビジネスニーズがありますか?</td></tr>
<tr><td><strong>技術要件</strong></td><td>設計しているインテグレーションは、データ仮想化、バッチ、要求/応答など、明らかに異なるパターンに適していますか?つまり、丸い穴に四角い釘をはめ込もうとしているのでしょうか。</td></tr>
<tr><td><strong>人間が応答を待機する必要があるプロセス</strong></td><td>対象システムからの応答を待機する人間が含まれるインテグレーションは、非同期実行を目的として設計されており、応答時間を保証できないため、イベント駆動型アーキテクチャには適していません。技術的なソリューションを実装する前に、このようなプロセスが組織にとって最適かどうかを検討します。詳細は、「適切に設計されたプロセス設計」を参照してください (/docs/architect/ja-jp/well-architected/guide/automated#プロセス設計)。</td></tr>
<tr><td><strong>頻繁に変更されないソースデータ</strong></td><td>ソースシステムのデータの変更頻度が低すぎて定期的な更新で十分な場合は、イベント駆動型パターンではなく [バッチパターン] (https://developer.salesforce.com/docs/atlas.en-us.integration_patterns_and_practices.meta/integration_patterns_and_practices/integ_pat_batch_data_sync.htm) を使用してアーキテクチャを簡略化できます。</td></tr>
<tr><td><strong>実装要件</strong></td><td>ソリューションに関与するシステムの大半はイベント駆動型アーキテクチャをサポートしていますか?イベント駆動型アーキテクチャをサポートしていないシステム (アップグレード、カスタマイズ、ミドルウェアなど) で使用するには何が必要ですか?これらの要件を満たすには、どの程度の努力が必要ですか?</td></tr>
<tr><td><strong>メッセージ構造の安定性</strong></td><td>メッセージ構造の変更が必要になる頻度は?このような変更の影響を受けるシステムと、その修正プロセスは?</td></tr>
<tr><td><strong>組織ガバナンス</strong></td><td>すべての関係者がメッセージ構造、トリガー、その他のアーキテクチャおよびプロセス関連の意思決定の変更について把握し、検討できるようにするためのガバナンス体制が確立されていますか?</td></tr>
<tr><td><strong>必須スキルセット</strong></td><td>スタッフにイベント駆動型アーキテクチャの経験があり、サポート方法を理解しているか?</td></tr>
</tbody>
</table>

## 使用事例

イベント駆動型アーキテクチャにはさまざまなパターンがあります。イベント駆動型以外の特別な要件がない使用事例に適用できる汎用パターンもあります。たとえば、「[適切に設計](/docs/architect/ja-jp/well-architected/guide/composable#相互運用性)された相互運用性」を参照してください。他のパターンは、大量のデータが含まれるインテグレーションや、より長期間のメッセージ保持を必要とするシナリオなど、ここで説明する特定の使用事例に適用されます。

### 一目でわかるパターン

次の表は、このドキュメントで説明されているパターンの属性を比較したものです。特定の使用事例の潜在的なパターンを特定する必要がある場合のクイックリファレンスとして使用します。

<table style="width:100%">
<thead>
<tr><th scope="col">パターン</th><th scope="col">ほぼリアルタイム</th><th scope="col">一意のメッセージコピー</th><th scope="col">配送の保証</th><th scope="col">メッセージサイズの削減</th><th scope="col">データの変換</th></tr>
</thead>
<tbody>
<tr><td>公開/登録</td><td>✓</td><td>✓</td><td>✓</td><td></td><td></td></tr>
<tr><td>Fanout</td><td>✓</td><td>✓</td><td>✓</td><td></td><td></td></tr>
<tr><td>合格メッセージ</td><td>✓</td><td></td><td>✓</td><td>✓</td><td>✓</td></tr>
<tr><td>ストリーミング</td><td>✓</td><td>✓</td><td>✓</td><td></td><td></td></tr>
<tr><td>キューイング</td><td>✓</td><td>✓</td><td>✓</td><td></td><td></td></tr>
</tbody>
</table>

### イベント駆動型アーキテクチャのツール

Salesforce には、イベント駆動の使用事例に対処するのに役立つ複数のツールが用意されています。次の表に、使用可能なツールの概要を示します。

<table style="width:100%">
<thead>
<tr><th scope="col"></th><th scope="col">ツール</th><th scope="col">説明</th><th scope="col">必須スキル</th></tr>
</thead>
<tbody>
<tr><th scope="row">MuleSoft</th><td><a href="https://docs.mulesoft.com/general/">Anypoint Platform</a></td><td>API レイヤーを使用してデータインテグレーションを可能にするプラットフォーム。</td><td>プロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/salesforce-pubsub-connector/latest/">Salesforce Pub/Sub コネクタ</a></td><td>Pub/Sub API のコネクタ。プラットフォームイベント、リアルタイムイベント監視イベント、変更データキャプチャを 1 つのインターフェースで公開および登録できます。</td><td>プロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/jms-connector/latest/">MuleSoft Anypoint JMS Connector</a></td><td>Java Message Service (JMS) 仕様を実装するメッセージサービスのキューおよびトピックへのメッセージの送受信を可能にするコネクタ。</td><td>プロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/kafka-connector/latest/">MuleSoft Anypoint Apache Kafka Connector</a></td><td>Apache Kafka とエンタープライズアプリケーションおよびサービス間でデータを移動するためのコネクタ。</td><td>プロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://github.com/SolaceProducts/pubsubplus-connector-mule-docs/blob/main/doc/user-guide.md">MuleSoft Anypoint Solace Connector</a></td><td>JCSMP Java SDK を使用したネイティブ API インテグレーションを備えた Solace PubSub+ イベントブローカーのコネクタ</td><td>プロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/mq/mq-connectors">MuleSoft Anypoint MQ Connector</a></td><td>顧客がアプリケーション間で高度な非同期メッセージングを実行できるようにするマルチテナントのクラウドメッセージングサービス。</td><td>プロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/mqtt3-connector/latest/">MuleSoft Anypoint MQTT Connector</a></td><td>MQTT (Message Queuing Telemetry Transport) v3.x プロトコルに準拠した MuleSoft 拡張機能。</td><td>プロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/amqp-connector/latest/">MuleSoft Anypoint AMQP Connector</a></td><td>アプリケーションが AMQP 0.9.1 準拠のブローカーを使用してメッセージを公開および消費できるようにするコネクタ。</td><td>プロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/release-notes/platform/event-driven-api">MuleSoft Anypoint Event-Driven (ASync) API</a></td><td>イベント駆動型 API をイベントレイヤー、チャネルレイヤー、トランスポートレイヤーに分割して公開をサポートする、業種に依存しない言語。</td><td>プロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/mq/">MuleSoft Anypoint MQ</a></td><td>顧客がアプリケーション間で高度な非同期メッセージングを実行できるようにするマルチテナントクラウドメッセージングサービス。</td><td>プロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/mule-runtime/latest/streaming-about">MuleSoft Anypoint Data Streams</a></td><td>MuleSoft Anypoint 内で使用可能な、ストリーミングデータの公開および登録用のフレームワーク。</td><td>プロコード</td></tr>
<tr><th scope="row">Salesforce Platform</th><td><a href="https://elements.heroku.com/addons/heroku-kafka">Heroku での Apache Kafka</a></td><td>Heroku プラットフォームに完全に統合された Apache Kafka をサービスとして提供する Heroku アドオン。</td><td>プロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/atlas.en-us.change_data_capture.meta/change_data_capture/cdc_intro.htm">変更データキャプチャ</a></td><td>Salesforce レコードへの変更を公開する変更イベントログ。変更には、新規レコードの作成、既存のレコードの更新、レコードの削除、レコードの復元などがあります。</td><td>ローコードからプロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/atlas.en-us.api.meta/api/sforce_api_om_outboundmessaging.htm">送信メッセージ</a></td><td>Salesforce 内で項目値が更新されるときに XML メッセージを外部エンドポイントに送信するアクション。</td><td>ローコード</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/atlas.en-us.platform_events.meta/platform_events/platform_events_intro.htm">プラットフォームイベント</a></td><td>カスタムイベントデータを含む安全でスケーラブルなメッセージ。</td><td>ローコードからプロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/platform/pub-sub-api/overview">Pub/Sub API</a></td><td>プラットフォームイベント、変更データキャプチャチャイベント、リアルタイムイベントモニタリングイベントの登録を可能にする API。</td><td>プロコード</td></tr>
<tr><th scope="row"></th><td><a href="https://help.salesforce.com/s/articleView?id=sf.ev_relay_intro.htm">イベントリレー</a></td><td>プラットフォームイベントと変更データキャプチャチャイベントを Salesforce から Amazon EventBridge に送信できるようにします。イベントリレーは AWS Eventbridge にのみ接続します。</td><td>ローコード</td></tr>
<tr><th scope="row"></th><td></td><td></td><td></td></tr>
</tbody>
</table>

### 公開/登録

コアアプリケーション内で重要なレコードの状態が変更された場合 (注文の状況が「処理中」から「出荷済み」に変更された場合など)、他の複数のシステムでそれぞれのタスクを実行するためにほぼリアルタイムの通知が必要になる可能性があります。このような変更の量が多く、メッセージが複雑な場合、特定のビジネスニーズが発生します。従来の 2 地点間インテグレーションは負担が大きく、メンテナンスが困難です。すべての連動アプリケーションに対して脆弱なカスタム接続を確立すると、技術的な負債が発生し、組織の迅速な拡張が妨げられます。これらの頻繁なデータ同期を管理するには、ソースシステムをすべての消費システムに直接結合せずに堅牢なインテグレーションアプローチが必要です。

#### 公開/登録パターン

次の図は、複数のパブリッシャーと登録者がイベントバスを介してデータを共有する一般的な公開/登録パターンを示しています。この基本パターンは、このガイドの残りの部分にあるより具体的なパターンの基礎となります。このパターンの主な特徴を次に示します。

- パブリッシャーと登録者の間に直接のつながりはありません。パブリッシャーは、イベントバスにメッセージを送信するだけで、イベントバスはメッセージをリッスンする他のシステムにブロードキャストします。

- 同じシステムが公開者と登録者の両方になる可能性があります。

- システムは、複数の種別のイベントを公開または登録できます。

- このガイドのすべてのパターンと同様に、公開/登録パターンは、リモートプロシージャ呼び出し (RPI) または単に[「起動](/docs/architect/ja-jp/fundamentals/guide/integration-patterns#リモートプロセスの呼び出し--fire-and-forget-起動と忘れ)後すぐに使用」と呼ばれる一般的なインテグレーションパターンカテゴリに分類されます

<!-- Image: Publish/subscribe pattern diagram (Level 2) -->
<img style="border:1px solid #e5e5e5;margin:2rem 0rem" src="https://a.sfdcstatic.com/developer-website/prod/images/architect/Event Driven Architecture Diagrams - Publish - Subscribe L2.png" alt="次のレベル 2 ダイアグラムは、複数のパブリッシャー、複数の登録者、およびイベントバスのチャネルを介して配信される複数のイベントを含む公開/登録パターンの例を示しています。 このパターンでは、同じシステムがパブリッシャーと登録者の両方になり、システムが複数のイベントを登録できます。">

#### 公開/登録パターンに関連するツール

<table style="width:100%">
<thead>
<tr><th colspan="2" scope="colgroup"></th><th colspan="4" scope="colgroup">イベントフローと動作</th><th colspan="2" scope="colgroup">ペイロードに関する考慮事項</th></tr>
<tr><th scope="col">使用可能なツール</th><th scope="col"></th><th scope="col">必須スキル</th><th scope="col">公開方法</th><th scope="col">登録方法</th><th scope="col">リプレイ期間</th><th scope="col">ペイロード構造</th><th scope="col">ペイロード制限</th></tr>
</thead>
<tbody>
<tr><th scope="row">MuleSoft</th><td><a href="https://docs.mulesoft.com/general/">Anypoint Platform</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/salesforce-pubsub-connector/latest/">Salesforce Pub/Sub コネクタ</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/jms-connector/latest/">MuleSoft Anypoint JMS Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/kafka-connector/latest/">MuleSoft Anypoint Apache Kafka Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://github.com/SolaceProducts/pubsubplus-connector-mule-docs/blob/main/doc/user-guide.md">MuleSoft Anypoint Solace Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/mq/mq-connectors">MuleSoft Anypoint MQ Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/mqtt3-connector/latest/">MuleSoft Anypoint MQTT Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/amqp-connector/latest/">MuleSoft Anypoint AMQP Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/release-notes/platform/event-driven-api">MuleSoft Anypoint Event-Driven (ASync) API</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/mq/">MuleSoft Anypoint MQ</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row">Salesforce Platform</th><td><a href="https://elements.heroku.com/addons/heroku-kafka">Heroku での Apache Kafka</a></td><td>プロコード</td><td>API、Heroku Postgres のレコード変更</td><td>なし</td><td>1 ~ 6 週間</td><td><a href="https://kafka.apache.org/documentation/#messageformat">ユーザー定義</a></td><td><a href="https://kafka.apache.org/documentation/#messageformat">ユーザー定義</a></td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/atlas.en-us.change_data_capture.meta/change_data_capture/cdc_intro.htm">変更データキャプチャ</a></td><td>ローコードからプロコード</td><td>レコードの変更</td><td>Apex、API、Lightning Webコンポーネント(LWC)</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.change_data_capture.meta/change_data_capture/cdc_message_structure.htm">定義済み</a></td><td>1 MB</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/atlas.en-us.api.meta/api/sforce_api_om_outboundmessaging.htm">アウトバウンドメッセージ*</a></td><td>ローコード</td><td>フローおよびワークフロールール</td><td>なし</td><td>24 時間</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.api.meta/api/sforce_api_om_outboundmessaging_wsdl.htm">ユーザー定義</a></td><td>メッセージあたり 100 件の通知</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/atlas.en-us.platform_events.meta/platform_events/platform_events_intro.htm">プラットフォームイベント</a></td><td>ローコードからプロコード</td><td>API、Apex、フロー</td><td>Apex、API、フロー、LWC</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.232.0.platform_events.meta/platform_events/platform_events_define_ui.htm">ユーザー定義</a></td><td>1 MB</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/platform/pub-sub-api/overview">Pub/Sub API</a></td><td>プロコード</td><td>Pub/Sub APIまたはAPI、Apex、フロー</td><td>Pub/Sub API</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/platform/pub-sub-api/overview">ユーザー定義</a></td><td>1 MB</td></tr>
<tr><th scope="row"></th><td><a href="https://help.salesforce.com/s/articleView?id=sf.ev_relay_intro.htm">イベントリレー**</a></td><td>ローコード</td><td>プラットフォームイベント、変更データキャプチャチャ</td><td>API</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.232.0.platform_events.meta/platform_events/platform_events_define_ui.htm">ユーザー定義</a></td><td>1 MB</td></tr>
<tr><td colspan="8">*Salesforce では、引き続き現在の機能の範囲内でアウトバウンドメッセージをサポートしますが、この技術への追加投資は予定していません。</td></tr>
</tbody>
</table>

### Fanout

プッシュ通知やモバイルデバイスへの SMS メッセージなど、多数のクライアントアプリケーションに瞬時に更新を送信する必要がある場合、受信者ごとに一意の送信を作成する従来のプロセスは、すぐに拡張性のボトルネックになります。この場合のコアビジネスニーズは、1 つの情報 (取引先アラートや重要なサービス変更通知など) を多数のエンドポイントアプリケーションに同時に迅速かつハイパフォーマンスに配信することです。この要件を満たすための合理化されたアプローチでは、すべてのメッセージを 1 つのキューでルーティングします。このキューは、すべての消費システムのイベント情報の中心として機能します。この方法では、多数の個別のメッセージコピーを管理する必要がなくなるため、パフォーマンスが向上します。

#### Fanout パターン

fanout パターンでは、メッセージは 1 つのメッセージキューを介して 1 つ以上の宛先 (リスン中のクライアントまたは登録者) に配信されます。登録者は、自分の一意のコピーではなく、キューから同じメッセージを取得します。(これによりパフォーマンスが向上しますが、特定のユーザがメッセージを受信したかどうかの確認がより困難になる可能性があります)。

<!-- Image: Fanout pattern diagram (Level 3) -->
<img style="border:1px solid #e5e5e5;margin:2rem 0rem" src="https://a.sfdcstatic.com/developer-website/prod/images/architect/Event Driven Architecture Diagrams - Fanout L3.png" alt="次のレベル 3 のドキュメントと実装の図は、ファンアウトパターンの例を示しています。この図は、ユーザー操作、フロー、または一括処理ジョブによってレコードが変更されたときに、イベントが 1 つのキューに公開および書き込まれる様子を示しています。 登録者システムには、メッセージキューから同じイベントを受信する複数のサービスがあります。">

#### Fanout パターンに関連するツール

<table style="width:100%">
<thead>
<tr><th colspan="2" scope="colgroup"></th><th colspan="4" scope="colgroup">イベントフローと動作</th><th colspan="2" scope="colgroup">ペイロードに関する考慮事項</th></tr>
<tr><th scope="col">使用可能なツール</th><th scope="col"></th><th scope="col">必須スキル</th><th scope="col">公開方法</th><th scope="col">登録方法</th><th scope="col">リプレイ期間</th><th scope="col">ペイロード構造</th><th scope="col">ペイロード制限</th></tr>
</thead>
<tbody>
<tr><th scope="row">MuleSoft</th><td><a href="https://docs.mulesoft.com/jms-connector/latest/">MuleSoft Anypoint JMS Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/salesforce-pubsub-connector/latest/">Salesforce Pub/Sub コネクタ</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/kafka-connector/latest/">MuleSoft Anypoint Apache Kafka Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://github.com/SolaceProducts/pubsubplus-connector-mule-docs/blob/main/doc/user-guide.md">MuleSoft Anypoint Solace Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/mq/mq-connectors">MuleSoft Anypoint MQ Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/mqtt3-connector/latest/">MuleSoft Anypoint MQTT Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/amqp-connector/latest/">MuleSoft Anypoint AMQP Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/mq/">MuleSoft Anypoint MQ</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row">Salesforce Platform</th><td><a href="https://elements.heroku.com/addons/heroku-kafka">Heroku での Apache Kafka</a></td><td>プロコード</td><td>API、Heroku Postgres のレコード変更</td><td>なし</td><td>1 ~ 6 週間</td><td><a href="https://kafka.apache.org/documentation/#messageformat">ユーザー定義</a></td><td><a href="https://kafka.apache.org/documentation/#messageformat">ユーザー定義</a></td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/atlas.en-us.change_data_capture.meta/change_data_capture/cdc_intro.htm">変更データキャプチャ</a></td><td>ローコードからプロコード</td><td>レコードの変更</td><td>Apex、API、Lightning Webコンポーネント(LWC)</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.change_data_capture.meta/change_data_capture/cdc_message_structure.htm">定義済み</a></td><td>1 MB</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/atlas.en-us.platform_events.meta/platform_events/platform_events_intro.htm">プラットフォームイベント</a></td><td>ローコードからプロコード</td><td>API、Apex、フロー</td><td>Apex、API、フロー、LWC</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.232.0.platform_events.meta/platform_events/platform_events_define_ui.htm">ユーザー定義</a></td><td>1 MB</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/platform/pub-sub-api/overview">Pub/Sub API</a></td><td>プロコード</td><td>Pub/Sub APIまたはApex、API、フロー</td><td>Pub/Sub API</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/platform/pub-sub-api/overview">ユーザー定義</a></td><td>1 MB</td></tr>
<tr><th scope="row"></th><td><a href="https://help.salesforce.com/s/articleView?id=sf.ev_relay_intro.htm">イベントリレー*</a></td><td>ローコード</td><td>プラットフォームイベント、変更データキャプチャチャ</td><td>API</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.232.0.platform_events.meta/platform_events/platform_events_define_ui.htm">ユーザー定義</a></td><td>1 MB</td></tr>
<tr><td colspan="8">*イベントリレーは AWS Eventbridge にのみデータを送信</td></tr>
</tbody>
</table>

### 合格メッセージ

一部のイベントシナリオは、同期および変換プロセスの容量を圧迫する恐れのある大量のメッセージや、イベントデータの処理と変換に必要な複雑な複数ステップのロジックによって特徴付けられます。

たとえば、次のようなものがあります。

- **季節的な量の急増：**オンライン小売業者は、商品の選択が「旬」になると、量が急増する可能性があります。多数の顧客が同時に購入する場合、生成されるイベント数が同期および変換プロセスの容量を一時的に超える可能性があります。詳細は、「[適切に設計](/docs/architect/ja-jp/well-architected/guide/automated#データ処理)されたデータ処理」を参照してください。

- **ケースまたは請求管理：**サービスベースの会社は、停止中にケース数や請求数が急増する可能性があります。

- **複雑なデータ変換：**メッセージを変換するために複雑なロジックを必要とする組織は、多くの場合、変換よりも早くイベントが生成されることを懸念します。

#### 合格メッセージパターン

このパターンは、変換よりも早くメッセージが生成されるという問題に対処します。ストリーミングメッセージプラットフォームとセグメント化されたメッセージ処理ロジックを専用コンポーネントに組み込むことで、大量のメッセージと必要なデータ操作を確実に処理できます。

「合格メッセージ」パターンは、メッセージ処理ロジックを複数のコンポーネントに分割することで機能します。

- 1 つのコンポーネントでメッセージのルーティングを処理し、必要な変換と最終的な送信先を決定します。

- 個別のコンポーネントセットは、メッセージ変換の異なるレイヤー (項目の対応付け、オブジェクトリレーションなど) を処理します。

- 最後のコンポーネントは、最後に変更されたメッセージを書き込みます。

<!-- Image: Passed messages pattern diagram (Level 3) -->
<img style="border:1px solid #e5e5e5;margin:2rem 0rem" src="https://a.sfdcstatic.com/developer-website/prod/images/architect/Event Driven Architecture Diagrams - Passed Messages L3.png" alt="次のレベル 3 のドキュメントと実装図は、パブリッシャー、登録者、およびメッセージを含む、渡されるメッセージパターンのプロセスフローの例を示しています。 メッセージは複数の部分に分割され、個別に変換され、登録者に送信する前に再構成されます。">

#### 合格メッセージパターンに関連するツール

<table style="width:100%">
<thead>
<tr><th colspan="2" scope="colgroup"></th><th colspan="4" scope="colgroup">イベントフローと動作</th><th colspan="2" scope="colgroup">ペイロードに関する考慮事項</th></tr>
<tr><th scope="col">使用可能なツール</th><th scope="col"></th><th scope="col">必須スキル</th><th scope="col">公開方法</th><th scope="col">登録方法</th><th scope="col">リプレイ期間</th><th scope="col">ペイロード構造</th><th scope="col">ペイロード制限</th></tr>
</thead>
<tbody>
<tr><th scope="row">MuleSoft</th><td><a href="https://docs.mulesoft.com/kafka-connector/latest/">MuleSoft Anypoint Apache Kafka Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/salesforce-pubsub-connector/latest/">Salesforce Pub/Sub コネクタ</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row">Salesforce Platform</th><td><a href="https://elements.heroku.com/addons/heroku-kafka">Heroku での Apache Kafka</a></td><td>プロコード</td><td>API、Heroku Postgres のレコード変更</td><td>なし</td><td>1 ~ 6 週間</td><td><a href="https://kafka.apache.org/documentation/#messageformat">ユーザー定義</a></td><td><a href="https://kafka.apache.org/documentation/#messageformat">ユーザー定義</a></td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/atlas.en-us.change_data_capture.meta/change_data_capture/cdc_intro.htm">変更データキャプチャ</a></td><td>ローコードからプロコード</td><td>レコードの変更</td><td>Apex、API、Lightning Webコンポーネント(LWC)</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.change_data_capture.meta/change_data_capture/cdc_message_structure.htm">定義済み</a></td><td>1 MB</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/atlas.en-us.platform_events.meta/platform_events/platform_events_intro.htm">プラットフォームイベント</a></td><td>ローコードからプロコード</td><td>API、Apex、フロー</td><td>Apex、API、フロー、LWC</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.232.0.platform_events.meta/platform_events/platform_events_define_ui.htm">ユーザー定義</a></td><td>1 MB</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/platform/pub-sub-api/overview">Pub/Sub API</a></td><td>プロコード</td><td>Pub/Sub APIまたはAPI、Apexフロー</td><td>Pub/Sub API</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/platform/pub-sub-api/overview">ユーザー定義</a></td><td>1 MB</td></tr>
<tr><th scope="row"></th><td><a href="https://help.salesforce.com/s/articleView?id=sf.ev_relay_intro.htm">イベントリレー*</a></td><td>ローコード</td><td>プラットフォームイベント、変更データキャプチャチャ</td><td>API</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.232.0.platform_events.meta/platform_events/platform_events_define_ui.htm">ユーザー定義</a></td><td>1 MB</td></tr>
<tr><td colspan="8">*イベントリレーは AWS Eventbridge にのみデータを送信</td></tr>
</tbody>
</table>

### ストリーミング

一部のプロデューサーは、イベントの連続ストリームを生成します。一般的な例として、メディアストリーミングがあります。メディアストリーミングには、個別のイベントとして自然に発生するユーザー操作が含まれます。コアストリーミング環境をブロックすることなく、複数のシステムで同じユーザー行動に同時に反応する必要があります。

音楽ストリーミングプラットフォームのイベントについて考えます。これには次のものが含まれます。

- 開始/一時停止/スキップされたイベントを追跡する

- タイムスタンプ付きのリスニングセッションイベント

- プレイリストの作成/変更イベント

- ソーシャル共有イベント

- オフラインリスニング用にダウンロード

#### ストリーミングパターン

ストリーミングパターンでは、登録者は各イベントストリームにアクセスし、イベントを受信した正確な順序で処理します。各メッセージストリームの一意のコピーが各登録者に送信されるため、登録者固有のコンテンツを配信し、どの登録者がどのストリームを受信するかを識別できます。

<!-- Image: Streaming pattern diagram (Level 3) -->
<img style="border:1px solid #e5e5e5;margin:2rem 0rem" src="https://a.sfdcstatic.com/developer-website/prod/images/architect/Event Driven Architecture Diagrams - Streaming - L3.png" alt="次のレベル 3 のドキュメントと実装図は、公開されるイベントのストリームを表すストリーミングパターンの例を示しています。ストリームをリスンしている登録者は、ストリームを受信してそれに応じて処理します。">

#### ストリーミングパターンに関連するツール

<table style="width:100%">
<thead>
<tr><th colspan="2" scope="colgroup"></th><th colspan="4" scope="colgroup">イベントフローと動作</th><th colspan="2" scope="colgroup">ペイロードに関する考慮事項</th></tr>
<tr><th scope="col">使用可能なツール</th><th scope="col"></th><th scope="col">必須スキル</th><th scope="col">公開方法</th><th scope="col">登録方法</th><th scope="col">リプレイ期間</th><th scope="col">ペイロード構造</th><th scope="col">ペイロード制限</th></tr>
</thead>
<tbody>
<tr><th scope="row">MuleSoft</th><td><a href="https://docs.mulesoft.com/mule-runtime/latest/streaming-about">MuleSoft Anypoint Data Streams</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/salesforce-pubsub-connector/latest/">Salesforce Pub/Sub コネクタ</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/kafka-connector/latest/">MuleSoft Anypoint Apache Kafka Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row">Salesforce Platform</th><td><a href="https://elements.heroku.com/addons/heroku-kafka">Heroku での Apache Kafka</a></td><td>プロコード</td><td>API、Heroku Postgres のレコード変更</td><td>なし</td><td>1 ~ 6 週間</td><td><a href="https://kafka.apache.org/documentation/#messageformat">ユーザー定義</a></td><td><a href="https://kafka.apache.org/documentation/#messageformat">ユーザー定義</a></td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/platform/pub-sub-api/overview">Pub/Sub API</a></td><td>プロコード</td><td>Pub/Sub APIまたはAPI、Apexフロー</td><td>Pub/Sub API</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/platform/pub-sub-api/overview">ユーザー定義</a></td><td>1 MB</td></tr>
</tbody>
</table>

#### ストリーミングイベント注文管理

ストリームが理にかなっているためには、そのすべてのイベントと関連するメッセージが正しい順序になっている必要があります。異なるシステムからストリームでデータを取得する場合、設計プロセスの一環として追加の注文ロジックを組み込む必要があります。

### キューイング

キューイングの使用事例は随所に存在します。例として、次のようなものがあります。

- **低品質のインターネット接続:**モバイルデバイスを使用するチームが品質が低く、インターネットアクセスが断続的な地域で作業する必要がある Field Service 組織やその他の組織では、接続が回復すると、これらのデバイスのアプリケーションがキューに接続して関連メッセージを取得できるため、キューが役立ちます。

- **メッセージバッファリング:**メッセージの量が登録者の処理能力を超えることがあり、遅延の増加によって追加の問題が発生しない場合、キューは過剰なメッセージを保存し、データの損失を防ぐためのバッファになります。

- **輸送管理:**法人車両を監視する必要がある物流組織は、このパターンを使用して、各車両が経由するルートをほぼリアルタイムで表示し、運転者の効率を最大限に高めることができます。

- **IoT デバイス:**メーカーは多くの場合、高速データストリームを生成するシステムを使用しており、これらのストリームが追加のシステムに下流の影響を及ぼす可能性があります。このパターンは、複数のシステムにまたがる重大な障害が発生する前に、人間の介入が必要な一連のイベントを識別するために使用できます。

#### 順番待ちパターン

Queuing パターンでは、プロデューサーがキューにメッセージを送信し、登録者が取得するまでキューにメッセージが保持されます。ほとんどのメッセージキューは先入れ先出し (FIFO) 順序に従っており、取得後にすべてのメッセージが削除されます。各登録者には一意のキューがあり、追加の設定手順が必要ですが、配信を保証し、どの登録者がどのメッセージを受信したかを識別できます。

<!-- Image: Queuing pattern diagram (Level 3) -->
<img style="border:1px solid #e5e5e5;margin:2rem 0rem" src="https://a.sfdcstatic.com/developer-website/prod/images/architect/Event Driven Architecture Diagrams - Queuing L3.png" alt="このレベル 3 のドキュメントと実装図は、レコードが変更されたときにイベントが公開されてキューに書き込まれるキューパターンの例を示しています。登録者は、関連付けられたキューからイベントのコピーを受信し、自分のレコードに適切な更新を行います。">

#### キューイングパターンに関連するツール

<table style="width:100%">
<thead>
<tr><th colspan="2" scope="colgroup"></th><th colspan="4" scope="colgroup">イベントフローと動作</th><th colspan="2" scope="colgroup">ペイロードに関する考慮事項</th></tr>
<tr><th scope="col">使用可能なツール</th><th scope="col"></th><th scope="col">必須スキル</th><th scope="col">公開方法</th><th scope="col">登録方法</th><th scope="col">リプレイ期間</th><th scope="col">ペイロード構造</th><th scope="col">ペイロード制限</th></tr>
</thead>
<tbody>
<tr><th scope="row">MuleSoft</th><td><a href="https://docs.mulesoft.com/mq/">MuleSoft Anypoint MQ</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/4.3/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/salesforce-pubsub-connector/latest/">Salesforce Pub/Sub コネクタ</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/kafka-connector/latest/">MuleSoft Anypoint Apache Kafka Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/mq/mq-connectors">MuleSoft Anypoint MQ Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/mqtt3-connector/latest/">MuleSoft Anypoint MQTT Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row"></th><td><a href="https://docs.mulesoft.com/amqp-connector/latest/">MuleSoft Anypoint AMQP Connector</a></td><td>プロコード</td><td>API</td><td>API</td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/redelivery-policy">As Configured</a></td><td><a href="https://docs.mulesoft.com/mule-runtime/latest/about-mule-message">ユーザー定義</a></td><td>なし</td></tr>
<tr><th scope="row">Salesforce Platform</th><td><a href="https://elements.heroku.com/addons/heroku-kafka">Heroku での Apache Kafka</a></td><td>プロコード</td><td>API、Heroku Postgres のレコード変更</td><td>なし</td><td>1 ~ 6 週間</td><td><a href="https://kafka.apache.org/documentation/#messageformat">ユーザー定義</a></td><td><a href="https://kafka.apache.org/documentation/#messageformat">ユーザー定義</a></td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/atlas.en-us.change_data_capture.meta/change_data_capture/cdc_intro.htm">変更データキャプチャ</a></td><td>ローコードからプロコード</td><td>レコードの変更</td><td>Apex、API、Lightning Webコンポーネント(LWC)</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.change_data_capture.meta/change_data_capture/cdc_message_structure.htm">定義済み</a></td><td>1 MB</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/atlas.en-us.platform_events.meta/platform_events/platform_events_intro.htm">プラットフォームイベント</a></td><td>ローコードからプロコード</td><td>API、Apex、フロー</td><td>Apex、API、フロー、LWC</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.232.0.platform_events.meta/platform_events/platform_events_define_ui.htm">ユーザー定義</a></td><td>1 MB</td></tr>
<tr><th scope="row"></th><td><a href="https://developer.salesforce.com/docs/platform/pub-sub-api/overview">Pub/Sub API</a></td><td>プロコード</td><td>Pub/Sub APIまたはAPI、Apex、フロー</td><td>Pub/Sub API</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/platform/pub-sub-api/overview">ユーザー定義</a></td><td>1 MB</td></tr>
<tr><th scope="row"></th><td><a href="https://help.salesforce.com/s/articleView?id=sf.ev_relay_intro.htm">イベントリレー*</a></td><td>ローコード</td><td>プラットフォームイベント、変更データキャプチャチャ</td><td>API</td><td>3 日</td><td><a href="https://developer.salesforce.com/docs/atlas.en-us.232.0.platform_events.meta/platform_events/platform_events_define_ui.htm">ユーザー定義</a></td><td>1 MB</td></tr>
<tr><td colspan="8">*イベントリレーは AWS Eventbridge にのみデータを送信</td></tr>
</tbody>
</table>

#### メモリおよびストレージ管理

Queuing パターンの非同期の性質上、メッセージがキューに追加されてから取得されるまでに長い遅延が発生する可能性があります。キューにはメッセージを保持するためのメモリまたはストレージ容量が必要なため、無制限に拡張することはできません。つまり、無制限にオフラインになっている登録者は、キューに十分なメッセージが蓄積されると、障害が発生する可能性があります。メッセージのバッファリングは、登録者の処理時間が長くなりすぎて大量のメッセージがキューに蓄積された場合にも同じ影響を及ぼす可能性があります。これらのリスクを軽減するには、すべてのメッセージキューのストレージ要件を徹底的に分析し、必要に応じて、メッセージが設定された時間内に取得されなかった場合や、メッセージが事前に定義された量に達した場合にキューを消去および無効にするプロセスを設計します。

## 機能以外の考慮事項

### 2 地点間インテグレーションからの移行

イベント駆動型アーキテクチャが組織に適していると完全に確信していても、すでに多数のポイントツーポイントインテグレーションがある状況から開始している場合があります。すべてのインテグレーションを一度に置き換えるプロジェクトの資金を得ることは困難な場合があります。また、一部のレガシーシステムでイベント駆動型アーキテクチャを直接使用することさえできない場合もあります。これらのシナリオでは、最もビジネスクリティカルなアプリケーションを最初に変換してから、将来のプロジェクトで更新または置き換えられたときに他のシステムを変換することで、より疎結合なアーキテクチャに段階的に移行できます。このアプローチにより、イベントバスに新しいアプリケーションを簡単に追加でき、時間の経過と共にシステムが追加されても IT ランドスケープ全体の拡張性と耐障害性を維持できます。

### 疎結合システム内のトレードオフ

アーキテクトは、すべてのアーキテクチャにはトレードオフがあることを認識しています。イベント駆動型アーキテクチャも例外ではありません。疎結合のシステムでいっぱいのランドスケープは、拡張性と耐障害性に優れていますが、次のようなトレードオフも考慮する必要があります。

- **全体的な統合戦略:**使用するツールやパターンに関係なく、まず、組織内のさまざまなシステムでデータを共有する方法に関する戦略を作成することが重要です。この戦略には、データの目標、データの共有方法と使用パターン、データソース、対象、構造、所有権とアクセスの要件を含める必要があります。

- **レガシーシステムのサポート:**組織にイベント駆動型アーキテクチャパターンをサポートしていないレガシーシステムがある場合があります。回避策 (イベントに登録し、別のデータ転送手段を使用して出力をターゲットシステムに送信するパススルーとして機能するプロセスなど) を構築することは可能ですが、この場合は他のインテグレーション方法を検討することをお勧めします。

- **メッセージの構造の変更：**最初のメッセージ構造が定義され、公開者と登録者の間で合意されると、特に登録者が外部の場合、変更が困難になる可能性があります。この問題に対処する方法はいくつかあります。バージョン管理されたエンドポイントを使用できますが、開発者が同時に多くのバージョンを管理する必要がないように、各バージョンの明確なライフサイクルを定義して伝えてください。Heroku の Apache Kafka がランドスケープの一部である場合は、スキーマレジストリや同様のツールを検討することもできますが、ランドスケープ内の他のシステムでもサポートされている (および使用されている) ことを確認してください。

- **パブリッシャーと登録者間の可視性の欠如:**ほとんどのイベント駆動型アーキテクチャパターンでは、パブリッシャーは登録者の状況を認識しません。そのため、すべての登録者がオフライン中にパブリッシャーが重要なメッセージを送信すると、メッセージが配信されない場合があります。リプレイ機能を使用するか、すべての重要なメッセージに対して別々のサーバで実行される冗長なユーザを追加することで、この問題に対処できます。

- **パフォーマンスのボトルネック：**イベント駆動型アーキテクチャの拡張に伴い、イベントバスが大量の登録者に同時にメッセージを送信しようとするパブリッシャーに圧倒されると、メッセージ配信のボトルネックになる可能性があります。これに対処するには、イベントバスに割り当てられるメモリと処理リソースを増やすか、複数のイベントバスを使用して異なる種別のメッセージを並列処理します。

## 関連するベストプラクティス

### イベント駆動型アーキテクチャの実装

イベント駆動型アーキテクチャを実装する前に、そもそも本当に使用する必要があるかどうかを検討します。前のセクションでは、各イベント駆動型アーキテクチャパターンに適した一般的なビジネスシナリオについて説明します。詳細は、「[適切に構築](/docs/architect/ja-jp/well-architected/guide/composable#相互運用性)された相互運用性」も参照してください。「イベント駆動型アーキテクチャを実装するときに考慮すべき課題」を確認して、想定しているパターンが特定の使用事例に最も適しているかどうかを判断します。

このガイドで扱うシナリオの大部分はインテグレーションに関連しますが、イベント駆動型アーキテクチャでは、プラットフォームイベントなどを使用して 1 つの Salesforce 組織内でメッセージを送信することもできます。プラットフォームイベントを内部メッセージングシステムとして使用するプロセスを設計するときは、該当する[イベント割り当て制限](https://developer.salesforce.com/docs/atlas.en-us.platform_events.meta/platform_events/platform_event_limits.htm)に留意してください。

### アンチパターンの回避

多くの場合、イベント駆動型アーキテクチャのアンチパターンは、Salesforce 組織の内部コミュニケーションの回避策としてイベントを使用することに起因します。一般的なアンチパターンは次のとおりです。

- **同じイベント オブジェクトに関連付けられた Apex トリガーからのイベントのパブリッシュ：**これにより、無限トリガーループが発生します。

- **DML トランザクションが完了する前に Apex からイベントを公開する：**トランザクションが失敗してロールバックされた場合、\[すぐに公開] 公開動作を持つ公開済みイベントはロールバック動作に含まれません。

- **後続の自動化を調整するためのフローでの公開イベント：**複数の自動化間でロジックを調整する最適な方法は、[サブフロー](https://developer.salesforce.com/docs/atlas.en-us.salesforce_vpm_implementation_guide.meta/salesforce_vpm_implementation_guide/vpm_designer_elements_subflow.htm)または[フローオーケストレーター](https://help.salesforce.com/s/articleView?id=sf.orchestrator_flow_orchestrator.htm)を使用することです。

- **実行時連動関係の作成:**実行時の連動関係を排除する適切な[手順](https://medium.com/salesforce-architects/5-anti-patterns-in-package-dependency-design-and-how-to-avoid-them-87bb50331cb8)を実行せずに、パッケージ間の通信を促進するイベントを公開しないでください。

- **不必要に大きいペイロード:**要求を実行するときは、ペイロードでできるだけ少ない量のデータを送受信することをお勧めします。ユーザーのすべてのアクションで複数の要求が発生する可能性があるため、これらを効率的に処理することが重要です。必要以上に多くのデータを送信すると、転送が遅くなり、処理時間が長くなる可能性があります。

- **アプリケーションイベントの選択解除処理：**アプリケーションイベントをリスンするコンポーネントが複数ある場合、開発者はイベントハンドラーが実際に必要で役に立つ場合にのみ実行されることを確認する必要があります。たとえば、Lightning コンソールでは、フォーカスされていないタブに含まれるコンポーネントは、表示されていなくても聞くことができます。開発者は、バックグラウンドユーティリティ項目を唯一のリスナーとして使用したり、getEnclosingTabId() をコールしてコンポーネントのこのインスタンスがフォーカスされたタブ内に含まれるかどうかを判断したりして、各イベントが意図した場合にのみ処理されるようにします。

- **プラットフォームイベントの公開動作を正しく使用しない**プラットフォームイベントには、\[すぐに公開] と \[コミット後に公開] の 2 つの公開動作があります。リアルタイムプラットフォームイベントは、トランザクションが成功して確定したかどうかに関係なくログイベントを公開する必要があるログ記録などの使用事例で使用できます。ただし、リアルタイムプラットフォームイベントでは、\[Publish Immediately (すぐに公開)] を慎重に使用してください。イベントは、登録者が同じトランザクション内で消費し、行ロックやその他の競合状態を引き起こす可能性があります。

### 効果的なイベントの設計

イベント駆動型アーキテクチャを実装する場合、成功への鍵の 1 つはイベント自体の設計方法の標準を設定することです。詳細は組織の使用事例によって異なりますが、一般的なガイドラインを次に示します。

- **イベントペイロードの最適な構造を決定します。**メッセージサイズを小さくすると処理時間が短縮されますが、大量のメッセージを登録者に送信しようとすると、パフォーマンスのボトルネックが発生する可能性があります。適切なバランスを見つけるために、ペイロードのサイズと構造に対して反復処理が必要な場合があります。MuleSoft および同様の ESB ツールでは、イベントに関連付けられたメッセージでカスタムペイロードを設計できるため、登録者側のパフォーマンスを向上させるためにデータ構造を視覚化できます。(詳細については、「[適切な設計 - API](/docs/architect/ja-jp/well-architected/guide/composable#api-管理) 管理」を参照してください)。

- **プロセスをエンドツーエンドで検討します。**インテグレーションがロールアウトされると追跡が困難になる可能性がある「無限ループ」シナリオを作成していないことを確認します。たとえば、レコードが更新されたときにイベントを公開し、同時に相互のイベントをリスンする 2 つのシステムで、処理時に追加の公開イベントがトリガーされます。

  この種別のアンチパターンを修正するには、消費されたイベントの結果として行われた変更によって新しいイベントが公開されないようにするロジックを両方のシステムに追加します。また、すべてのイベント、関連付けられたトリガー、および影響を受ける可能性のあるダウンストリームシステムを文書化する必要があります。このドキュメントは、無限ループや類似するシナリオをできるだけ早くキャッチするための設計セッション中の参照資料として使用します。(詳細については、「[適切な設計 - プロセス設計](/docs/architect/ja-jp/well-architected/guide/automated#プロセス設計)」を参照してください)。

- **システム全体で共通の命名規則を使用します。**イベント駆動型アーキテクチャを含め、すべてのソフトウェア開発で一貫した命名規則を使用することをお勧めします。イベント名、構造、関連付けられたオブジェクト、エラー処理プロセスに関する一連の標準を文書化して、システム全体で一貫性を確保します。(詳細については、「[適切に設計](/docs/architect/ja-jp/well-architected/guide/intentional#設計標準)された設計基準」を参照してください)。

## リソース

<table style="width:100%">
<thead>
<tr><th scope="col">パターン</th><th scope="col">リソース</th></tr>
</thead>
<tbody>
<tr><td>公開/登録</td><td><a href="/docs/architect/ja-jp/well-architected/guide/reliable#スループット">Salesforce の適切なアーキテクチャ - スループット</a><br><a href="/docs/architect/ja-jp/well-architected/guide/automated#データ処理">Salesforce の適切なアーキテクチャ - データ処理</a><br><a href="/docs/architect/ja-jp/well-architected/guide/composable#相互運用性">Salesforce の適切なアーキテクチャ - 相互運用性</a><br><a href="https://medium.com/salesforce-architects/achieve-architectural-efficiency-with-event-relays-c8d4ec7f07af">ブログ投稿:イベントリレーを使用したアーキテクチャの効率化</a><br><a href="https://medium.com/salesforce-architects/announcing-pub-sub-api-generally-available-3980c9eaf0b7">ブログ投稿:Pub/Sub API正式リリース</a>のお知らせ<br><a href="https://blogs.mulesoft.com/dev-guides/api-design/moving-from-restful-to-eventful/">ブログ投稿:RESTful から EVENTful</a> への移行<br><a href="https://blogs.mulesoft.com/dev-guides/event-driven-architectures-asyncapi/">ブログ投稿:イベント駆動型アーキテクチャと AsyncAPI 仕様</a><br><a href="https://youtu.be/0WJjmmw1ryM">動画:パターンの公開/登録のウォークスルー</a></td></tr>
<tr><td>Fanout</td><td><a href="https://developer.salesforce.com/blogs/2021/08/how-to-work-within-platform-events-delivery-limits">ブログ投稿:プラットフォームイベント配信制限</a>内での作業方法<br><a href="https://youtu.be/zSncRUcucEU">動画:Fanout Pattern Walkthrough</a> (ファンアウトパターンウォークスルー)</td></tr>
<tr><td>合格メッセージ</td><td><a href="https://youtu.be/U87nErhMuqw">動画:Passed Messages Pattern Walkthrough (合格メッセージパターンウォークスルー</a>)</td></tr>
<tr><td>ストリーミング</td><td><a href="https://medium.com/salesforce-architects/designing-for-high-volume-writes-in-salesforce-285689a08100">ブログ投稿:Salesforce</a> での大量の書き込みに対応する設計<br><a href="https://youtu.be/-_1CDUI40fY">動画:ストリーミングパターンウォークスルー</a><br><a href="https://docs.mulesoft.com/mule-runtime/4.3/streaming-about">ドキュメント:Mule アプリケーションでのストリーミング</a></td></tr>
<tr><td>キューイング</td><td><a href="https://medium.com/salesforce-architects/designing-for-high-volume-writes-in-salesforce-285689a08100">ブログ投稿:Salesforce</a> での大量の書き込みに対応する設計<br><a href="https://blogs.mulesoft.com/dev-guides/api-design/event-payment-apis/">ブログ投稿:イベント API を使用した支払アーキテクチャの設計方法</a><br><a href="https://youtu.be/jQvSKbMRbh0">動画:Queueing Pattern Walkthrough</a> (キューイングパターンウォークスルー)</td></tr>
</tbody>
</table>