はじめに
昨今業務システムのクラウドサービス活用も進み、マルチクラウド、オンプレ×クラウドのハイブリッドで利用されている企業も多くなってきています。
しかし、各アプリケーションで必要なデータはオーバラップしていることが多く、特に取引先・顧客情報などは様々なアプリケーションで必要かつ利用されていることが実情です。
そこで今回はRSSBus Connectを用いて、Salesforceの取引先企業情報を既存のDBへ同期する方法を紹介したいと思います。
RSSBus Coonectとは？
RSSBus Connectは、ファイル、データベース、またはクラウドアプリケーションのデータをすべて1つのアプリケーションで簡単に統合することができるソフトウェアです。
アプリケーションとデータの接続を行い、Mrketoなどのマーケティングサービスから得た潜在顧客情報をSalesforce等のSFAに連係したり、バイナリファイル転送・EDIによるプロセスの自動化も行うことが可能です。
RSSBus Connectは以下のようにフロー形式のUIで各データソースを繋ぐようにデータ連携のプロセスを開発することが可能です。
本記事で実装するシナリオ
本記事では、Salesforceで発生した取引先（Account）の情報をPostgreSQLの既存のテーブル（例えばCustomer）にUpsertする方法をお伝えします。
以下のSalesforceのデータを
PostgreSQLのテーブルへ同期しています。
事前準備
RSSBus Connectのダウンロード・インストール
まず、RSSBus Connectをダウンロードします。
RSSBus Connectは30日間無償の試用版が提供されているので、以下からダウンロードしてください。
本記事ではWindows版（Windowsサービスで実行）を使用します。
ダウンロード後、インストーラーが立ち上がるので、ダイアログに沿ってインストールを実施します。
インストール後自動的にRSSBus Connectの画面が立ち上がるので、インストーラーで設定したID・PWを用いてログインします。
ログイン後の画面でトライアルキーのインストールができるので［Activate 30-Day Trial］をクリックします。
Name, Emailなどの必要情報を入力の上、ライセンス規約に同意し、［Activate Trial］をクリックします。
以上で、RSSBus Connectのインストールは完了です。
Salesforce Portのダウンロード
続いて本フローを作成するにあたり必要となるSalesforceのモジュール（RSSBus ConnectではPortと呼びます）を追加でインストールします。
RSSBus Connectでは標準でも多様なPortが備わっていますが、以下のページから追加でPortをダウンロードし、機能を拡張することが可能です。
Port一覧からSalesforceをクリックし
［Download Port］をクリックすることで、インストーラーを入手できます。
Portインストーラーはダイアログに沿って進めるだけで簡単にインストールすることが可能です。
PostgreSQLのテーブル構成
本記事では以下のようなPostgreSQLのテーブルを構成し、データの同期先としています。
フローの作成
作成手順
それでは、実際にフローを作成していきたいと思います。
本記事では、前述の通り、Salesforceから以下のようなフローを作成します。
大まかな手順は以下の通りです。
RSSBus Connectでは、それぞれの処理単位であるPortを構成し、つなぎ合わせることで一連のフローを形作ることが可能です。
-
Salesforce のデータを受信するPortの構成
-
PostgreSQL へデータを送信するPortの構成
-
SalesforceのデータをPostgreSQLへ送信するための変換を行うPortの構成
-
各Portの接続
Salesforce Receive Portの構成
まず最初にSalesforceのデータを受信するためのPortを構成します。
画面上のメニューから［FLOW］を選択すると、フローデザイナーの画面へ移動します。この画面で基本的なフローの作成が可能です。
左メニューにSalesforceのPortがあるので、ドラッグアンドドロップでキャンパスに配置します。
PortのNameの入力が求められるので、任意の名称を入力の上［＋Create Port］をクリックします。
なお、Port Nameは重複できませんので、注意していください。
配置したSalesforce Portをクリックすると、画面右にPortのプロパティペインが表示されるので、Salesforceへの接続情報となる［User］［Password］［Security Token］を入力し、［Save Changes］をクリックします。なお［Test Connection］をクリックすることで、接続情報に問題が無いかどうかを確認することが可能です。
次にこのPortでSalesforce上のどのデータを受信するかを設定します。
Portのプロパティペインの下にあるMappings から［Output］を選択し、［＋］ボタンから［Table or View］をクリックします。
クリック後、Salesforceのテーブルとビュー一覧が表示されるので、［Account］を選択し［Next］をクリックします。
この画面で取得するカラムと取得の条件を設定することができます。
今回は特定のカラムのデータを都度全件取得するように設定します。
任意のカラムを選択し、［Create］をクリックします。
対象のテーブルが追加されたことを確認し、［Save Changes］をクリックします。
Receiveの設定は初期値では手動実行状態になっているので、［Automation］タブから自動処理に設定を変更します。
データの送信は必要無いため［Send］のチェックは外し、［Receive］のチェックを入れて、任意の実行間隔を設定します。
今回はDefaultのまま、60分間隔としました。
以上で、Salesforceのデータ取得用Portの構成は完了です。
PostgreSQL Sent Port の構成
続いて、PostgreSQLへデータを送信するためのPortを構成します。
先程と同じようにPortの一覧からドラッグアンドドロップでPostgreSQLのPortをキャンパスへ配置します。
任意のPort Nameを入力の上［＋Create Port］をクリックします。
配置したPostgreSQL Portを選択し、PostgreSQLへの接続情報［Host］［Port］［Database］［User］［Password］を入力の上、［Save Changes］をクリックします。
今度はデータを送信するためのPortのため、Mappingsから［Input］を選択し、［＋］ボタンから［Table or View］をクリックします。
事前に作成しておいた、［Customer］テーブルを選択し［Next］をクリック
挿入対象のカラムを選択の上［Create］をクリックします。
なおInput用PortはKeyカラムが存在する場合、自動的にUpsert処理を実施します。
対象テーブルが追加されたことを確認後、［Save Changes］をクリックします。
以上で、PostgreSQLへのSend Portの構成は完了です。
MAP Port の構成
続いて、SalesforceのデータをPostgreSQLに連係できるように、データの形式を変換するためのMAP Portを構成します。
RSSBusは内部的には1レコード・1XMLファイル単位で処理するよう設計されており、そのXMLの構成に準じて、データの変換や挿入が実施されます。
今回は、SalesforceのAccountテーブルから取得したデータ（XMLフォーマット）を、PostgreSQLのCustomerテーブルへ挿入できるデータ変換処理をこのMAP Portを用いて構成します。
先程と同様に左のPort一覧から今度は［MAP］Portをドラッグアンドドロップでキャンパスに配置します。
任意のPort Nameを入力の上、［Create Port］をクリックします。
MAPは元となるXMLファイルをベースにすることで簡単に構成することができます。
事前に設定したSalesforce Receive Portでは以下のようなデータが送られるので、このファイルをアップロードします。
<Items>
<Account>
<Id>0010I00001c0vLnQAI</Id>
<BillingStreet>ミューア ロード 9068</BillingStreet>
<Name>シティ パワー & ライト</Name>
</Account>
</Items>
SourceFileから［Select］→［Upload Sample File］をクリックし
上記XMLファイルを選択の上、［Upload］をクリックします。
続いて送信先です。送信先は以下のようなXMLフォーマットとなります。
<Items>
<Customer>
<Guid key="true" />
<AccountName />
<Address />
</Customer>
</Items>
同じように今度は［Destination File］から［Select］→［Upload Sample File］をクリックし
上記XMLファイルを選択の上［Upload］をクリックします。
各ファイルをアップロード後、下のMapping画面にそれぞれのXMLフィアルを元にした項目一覧が表示されるため、任意の項目同士をマッピングします。
マッピング完了後、［Save Changes］をクリックします。
以上でMAP Portの構成は完了です。
各Port の接続
最後に、それぞれ構成したPortをコネクタで接続します。
それぞれの始点と終点をドラッグアンドドロップで紐づけます。
以下のように紐づけたら、画面右下の［保存］マークをクリックします。
以上で、すべて構成が完了しました。
手動実行
それでは、実際に実行してみましょう。
今回の設定では60分ごとにSalesforce のReceive Portがデータを受信し、処理を開始しますが、手動で実行することも可能です。
Salesforce Portを選択し［Receive］タブを選択し［Receive］ボタンをクリックします。
自動的にデータが取得され、処理が行われます。
実行ログの確認
RSSBus Connectは各ポートから実行ログを確認することが可能です。
Salesforce Receive Portは、Receiveタブから取得した結果生成されたXMLの履歴を確認できます。
Map Portは変換結果を［Send］タブから確認できます。File Nameをクリックすることで、変換後に生成されたXMLファイルをダウンロードすることも可能です。
PostgreSQLでは、［Send］タブから、データベースへの送信結果を確認することができます。
StatusがSentになっているものは正常に処理されたデータとなります。
おわりに
いかがでしたでしょうか。もともとEDIの機能が中心であったため、XMLファイルに都度変換して、各Portでやり取りを行っているという点を理解することがRSSBus Connectを用いた開発を行う上でのポイントとなります。
是非様々なクラウド・アプリケーション連係シナリオで活用してみてください。
また、RSSBus Connectでは、下記にようなKnowledgeやドキュメントがOnline上で公開されているので、是非参考にしてみてください。
Sample Package では、各種シナリオに応じたフローがダウンロードし、自身のRSSBusへインストールの上、設定値などが確認できるので、とても参考になるかと思います。
Online Knowledge Base
Sample Package
Product Document