はい。Salesforce Data Captureは、データウェアハウスやERPから分析プラットフォーム、イベントストリーミングシステムまで、さまざまなデータツールと連携できます。
CDCは、レコードの作成、更新、削除、削除取り消しが行われるたびにイベント通知を発行します。外部ツールはそのイベントを受信し、CRMとのデータ同期を維持できます。本記事では、Salesforce CDCに対応するツール、接続の仕組み、管理型プラットフォームと独自開発を選ぶ際の検討事項を解説します。
Salesforce CDCイベントを受信できるツール
ツールは、データウェアハウスへのデータ移行、業務アプリケーションとの同期、イベントドリブン型ワークフローの構築など、実現したい目的に応じて3つのカテゴリーに分けられます。
複数システムを同期する連携プラットフォーム
統合プラットフォームはCDCイベントを受信し、1つのワークフローで変更情報を複数の接続先へ振り分けます。認証、イベント解析、データ変換、エラー処理をプラットフォーム側で担うため、インフラではなく業務ロジックに集中できます。1件のCDCイベントを起点に、データウェアハウス、ERP、通知システムを同時に更新することも可能です。多くのiPaaSベンダーは、CDC対応機能を備えた構築済みのSalesforceコネクターを提供しています。
データウェアハウスへ取り込むデータパイプラインツール
ETLやELTツールはCDCイベントを取得し、データウェアハウスへ差分データを順次取り込みます。実行のたびにテーブル全体を走査する全件抽出と比べ、CDCイベントに基づく差分取り込みは処理時間とコンピューティングコストを削減できます。これらのツールは、Salesforceとデータウェアハウス間のスキーマ変更やデータ型の対応付けにも対応します。一般にデータパイプラインツールは双方向同期ではなく、Salesforceからデータウェアハウスへの一方向のデータ移送に重点を置きます。
複数システムへ配信するイベントストリーミング基盤
イベントストリーミング基盤は、複数の利用システムが個別に購読できるトピックへCDCイベントを書き込みます。同じSalesforceの変更を起点に、複数の後続システムで同時に処理を実行したい企業に適した構成です。すでにストリーミングアーキテクチャを運用しており、その経路にSalesforceデータを流したい場合に効果を発揮します。
ERP・業務アプリケーションとの同期
SAP、Oracle、NetSuite、Microsoft DynamicsなどのERPは、Salesforce CDCを直接受信できません。中継ツールがCDCイベントを取得し、ERPが処理できるAPI呼び出しやデータベース書き込みへ変換します。代表的な用途は、Accountの変更をERPの顧客マスタへ反映する、Opportunityの成約情報を会計システムと同期する、SalesforceのOrder変更に応じて在庫レコードを更新する、といった処理です。中継ツールが、2つのシステム間におけるデータ形式の変換、エラー復旧、更新競合の解消を担います。
Salesforce CDC接続の仕組み
Salesforce CDCへの接続方法は、管理型プラットフォームを利用する方法と、独自のイベント受信機能を開発する方法があります。管理型プラットフォームは、OAuth認証、Salesforce Streaming APIとの常時接続、受信したCDCイベントの解析を担います。独自開発の場合は、SalesforceのEMP Connectorと自社コードを使って、これらの基盤を構築する必要があります。
管理型プラットフォームが接続基盤を担う
OAuth認証情報を設定し、追跡するSalesforceオブジェクトを選択します。プラットフォームがCDCチャネルを購読し、イベントを解析して、配信に失敗した場合は自動で再試行します。Salesforceの項目と接続先のスキーマは、視覚的な設定画面またはコードで対応付けます。Salesforce APIの更新やCDCの仕様変更には、プラットフォームベンダーが対応するため、運用負荷を抑えられます。
独自開発では高度なエンジニアリングが必要
Salesforceは、独自のイベント受信機能を構築するために、JavaベースのCometDクライアントであるEMP ConnectorをGitHubで提供しています。OAuth 2.0認証、トークン更新、常時接続の維持を自社で実装しなければなりません。切断後に未処理イベントを復元する再処理ロジックや、JSON形式のイベントデータを解析して後続処理を実行するコードも必要です。既存コネクターでは対応できない特殊な要件がある場合に適した方法です。
リアルタイム処理とバッチ処理の選び方
リアルタイム同期はイベント発生時にデータを取得・配信し、遅延は秒単位です。バッチ処理は一定時間のイベントをまとめ、設定したスケジュールで配信します。カスタマーサービスのダッシュボード、在庫状況の可視化、注文ステータス更新など、後続システムに最新データが必要な用途にはリアルタイム同期が適しています。夜間のデータウェアハウス取り込みや週次レポート更新など、即時性より処理量を重視する用途にはバッチ処理が適しています。
Salesforce CDC連携が難しい理由
Salesforce CDC連携を構築する企業は、常時接続の維持、障害発生後のイベント再処理、CDCデータを後続システムで扱える形式へ変換する作業など、技術的な課題に直面します。
Salesforceのイベント数には上限がある
Salesforceでは、契約エディションごとに1日当たりのプラットフォームイベント割当数が定められ、組織が発行できるCDCイベント数に上限があります。キャンペーンや移行作業で主要オブジェクトが頻繁に更新されると、イベント量が急増し、上限に達する可能性があります。
イベント受信側の接続が切断される
ネットワーク障害、Salesforceのメンテナンス、OAuthトークンの期限切れにより、イベント受信側の接続が切断されることがあります。独自開発では、切断の検知、再接続、最後に処理した位置からの未処理イベント再実行を実装しなければなりません。管理型プラットフォームは自動で再接続しますが、独自開発で信頼性を維持するには継続的なエンジニアリング対応が必要です。
システム間でスキーマが異なる
Salesforceオブジェクトの構造が、接続先のスキーマと完全に一致することはほとんどありません。参照関係や階層構造を持つオブジェクトでは、関連データを取得するための追加クエリが必要です。Salesforceと外部システムのレコードを照合するには、信頼できる識別子または重複排除ロジックも欠かせません。項目追加やオブジェクト名変更などSalesforce側のスキーマが変わるたびに、後続システムのマッピングも更新する必要があります。
双方向同期では更新ループが発生する
Salesforce CDCが変更をERPへ送信し、ERP連携が同じ変更をSalesforceへ返すと、無限ループが発生します。これを防ぐには、各変更の発生元を識別し、連携処理自身が発生させたイベントを除外する必要があります。こうした制御により、双方向同期の実装は複雑になります。
管理型プラットフォームと独自開発の判断基準
管理型プラットフォームと独自開発のどちらを選ぶかは、連携対象のシステム数、接続ロジックを保守できるエンジニアリング体制、連携要件の変更頻度によって決まります。
管理型プラットフォームで継続的な保守負荷を削減
構築済みコネクターを使えば、Salesforceや主要な接続先向けの独自開発が不要になります。APIの変更、セキュリティパッチ、信頼性確保はベンダーが対応します。自社チームは基盤開発ではなく、連携の設定と監視に集中できます。専任の連携エンジニアを確保する必要がないため、利用料を含めても総所有コストを抑えられる場合が多くあります。
独自開発は自由度と引き換えに複雑性が高まる
コードを自社で保有するため、特殊な要件や性能上の制約に合わせて最適化できます。一方、接続管理、再試行ロジック、スキーマ更新、監視、障害対応を含む保守責任も自社が負います。既存コネクターが接続先システムに対応できない場合や、遅延・処理量の要件が管理型プラットフォームの範囲を超える場合には、独自開発が適しています。ただし、多くの企業は独自の連携コードを長期保守する負担を過小評価しています。
管理型と独自開発を組み合わせる方法
標準的な連携には管理型プラットフォームを使い、例外的な要件には独自コードを使う企業もあります。管理型プラットフォームでCDCイベントを取得してメッセージキューへ配信し、独自の受信処理でイベントを処理する構成も可能です。一般的な用途では開発を迅速化しながら、特殊な要件には柔軟に対応できます。
選定前に確認すべき事項
- Salesforce CDCイベントを受信する接続先システムはいくつあるか。
- 独自のイベント受信機能を長期にわたり開発・保守できるエンジニアがいるか。
- 許容できる遅延はどの程度か。管理型プラットフォームでその要件を満たせるか。
- Salesforceのスキーマはどの程度の頻度で変わるか。後続システムのマッピングを誰が更新するか。
- 転送中のデータにどのようなコンプライアンス・セキュリティ要件が適用されるか。
Salesforce CDCを自社のデータ基盤へ接続
Salesforce CDCは、データウェアハウス、ERP、イベントストリーミング基盤など、ほぼあらゆるデータツールと連携できます。判断すべきなのは、接続を自社で構築・保守するか、接続基盤を担うプラットフォームを利用するかです。
Boomi Enterprise PlatformにはSalesforce Platform Eventsコネクターが搭載されています。CDCチャネルを購読し、変更イベントを解析して、200種類以上の構築済み接続先コネクターへデータを振り分けます。
OAuth認証情報を設定し、追跡するオブジェクトを選び、項目を接続先スキーマへ対応付けてデプロイします。接続ライフサイクル、再試行ロジック、イベント解析はBoomiが一元管理するため、自社チームはデータの移動方法ではなく、データを業務でどう活かすかに集中できます。
「The Business Case for Change Data Capture」 を入手し、変更データキャプチャによって運用負荷を軽減し、収益向上につなげる方法をご確認ください。