ノーコードでクラウド上のデータとの連携を実現。
詳細はこちら →
ETLツール DataSpirder を使って Bカートの会員データを Salesforce に連携：CData JDBC Driver
こんにちは。CDataリードエンジニアの杉本です。
今回は BtoB EC・Web受発注システム Bカートと Salesforce をETLツールの DataSpirder で接続・連携する方法を紹介します。
Bカート とは？
BカートはBtoB EC・Web受発注システムです。BtoBの受発注業務をEC化し、FAX・電話受注で起こりやすい聞き間違いや誤入力などの人為的ミスを防いだり、属人化の解消、作業時間の短縮に繋げることができるクラウドサービスです。
そのBカート では会員情報や受注情報にアクセスするためのHTTPベースの REST APIを提供しており、本記事ではこのAPIを活用して、ETLツールのDataSpirder経由でSalesforceに会員データを同期する方法を紹介します。
実現イメージ
DataSpirderでは多種多様なコネクタを標準装備していますが、現在Bcartへシームレスに接続できるコネクタは提供されていません。
https://www.hulft.com/software/dataspider/product#anc_02
Web API向けのコネクタを利用することもできますが、各APIに関する知識の習得やページネーションや認証処理を踏まえなければ自由にデータを操作することはできません。
そこで、CData JDBC Driverを使用してこのボトルネックを解消します。
DataSpirderには予めJDBC用のインターフェースが提供されているため、Bカート REST API を CData Driverインターフェースでアクセスできるようにしてしまいます。
これによりユーザーはBカートやSalesforceなど、それぞれ仕様が違うAPIを意識すること無く、DataSpirderなどのETLツールで扱えるようになります。
本記事のシナリオ
本記事では前述の通りBカート上にユーザー登録などで生成された会員情報をSalesforceの取引先担当者へ連携します。
以下のようなデータを50件ほど用意しました。
このデータを以下のSalesforce取引先担当者に連携します。
最終的に出来上がるDataSpirderのフローは以下のイメージです。
実際の操作手順の概要はGIFアニメで記録してみました。
手順
それでは実際に DataSpirder と Bカート・Salesforce の連携方法を説明します。
Bカート API のアクセストークンの取得
Bカート APIに接続するためには、アクセストークンが必要です。
以下の記事で取得方法を解説していますので、予め取得しておきましょう。
REST データ処理用 RSDファイルの作成
次に、Bカート API を CData 各種 REST DeiverがSQLとして解釈できるように設定ファイルを作成します。
以下のGitHubから保存してください。
https://github.com/sugimomoto/CData.REST.Bcart
保存先フォルダは後ほど使用するので「C:\CData_REST\Bcart」といった書き込み可能な任意のフォルダに配置してください。
CData JDBC Driverのインストール
DataSpirder と Bカート API を繋ぐために必要となるCData JDBC REST Driverをインストールします。
まず、以下のURLからCData REST ODBC Driverの30日間の評価版をダウンロードします。ダウンロードの際には、Emailの登録が必要となります。
https://www.cdata.com/jp/drivers/rest/download/jdbc/
ダウンロード後、セットアップを実施します。
また、合わせてSalesforce JDBC Driverも使用していますので、こちらも同様にダウンロード・セットアップを行っておきます。
https://www.cdata.com/jp/drivers/salesforce/download/jdbc/
JDBC Driver の設定
次にDataSpirderでJDBC Driverを利用できるように、JDBC ライブラリファイルをDataSpirderのPluginフォルダに移動します。
必要なファイルは以下の5種類です。
C:\Program Files\CData\CData JDBC Driver for REST 2019J\lib
- cdata.jdbc.rest.jar
- cdata.jdbc.rest.lic
- rssbus.jar
C:\Program Files\CData\CData JDBC Driver for Salesforce 2019J\lib
- cdata.jdbc.salesforce.jar
- cdata.jdbc.salesforce.lic
この5種類のファイルをそのまま以下のフォルダにコピーします。
C:\Program Files (x86)\DataSpiderServista\server\plugin\data_processing\modules\jdbc_adapter
最後にDataSpirderのサービスを再起動すれば準備完了です。
DataSpider Studioの起動と新規プロジェクトの作成
それでは、DataSpirderで作業をはじめていきましょう。DataSpirder Studioを起動し、新規プロジェクトを作成します。
任意のプロジェクト名で作成を行ってください。予めスクリプトも作成しておきましょう。
Bカート データ取得処理作成
次に Bカートからデータの取得処理を作成します。右側のツールボックスから「データベース」→「JDBC」→「テーブルの読み取り」を選択し、フロー画面にドラッグ・アンド・ドロップで配置します。
接続先から「追加」を選択し
以下の情報でJDBCの接続情報を作成します。Locationには先程Bカートの接続ファイルを配置したフォルダ、AccessTokenには予め取得したAPIの接続用トークンを指定してください。
- 名前：Bcart
- ドライバクラス名：cdata.jdbc.rest.RESTDriver
- URL：jdbc:rest:GenerateSchemaFiles=None;Location=C:\CData_REST\Bcart;other="AccessToken=XXXXX;";
接続情報を作成後、テーブル一覧から「customers」テーブルを選択します。「接続テスト」をクリックし、接続が問題なければ、「完了」をクリックし、設定終了です。
Salesforce データ書き込み処理作成
続いてSalesforceへの書き込み処理も作成しましょう。
先程と同様に「データベース」→「JDBC」から、今度は「テーブル書き込み」を選択し、ドラッグ・アンド・ドロップでフロー画面に配置します。
先程と同じように接続先から「追加」をクリックし
以下のように接続情報を入力します。Salesforceへの接続にはセキュリティトークンも必要となります。セキュリティトークの取得方法はこちらの記事で詳しく解説しています。
- 名前：Salesforce
- ドライバクラス名：cdata.jdbc.salesforce.SalesforceDriver
- URL：jdbc:salesforce:User=XXXXXX;Password=XXXX;SecurityToken= XXXX;
接続設定完了後、テーブル一覧から「contact」テーブルを選択し、「完了」をクリックします。
マッピング処理の作成
最後にBカートとSalesforceのデータをマッピングするための処理を作成します。
フロー画面からBカートの処理をドラッグ・アンド・ドロップし、Salesforceの書き込み処理に移動させます。
すると、以下のようなフローの作成画面が表示されるので「プロセスフローとデータフローを引く」を選択し「マッピングを追加する」にチェックを入れて、「OK」をクリックします。
以下のようにマッピング処理が作成されるので、ダブルクリックで詳細画面を表示します。
ここでデータの取得元からデータの書き込み先、それぞれのカラムのマッピングをドラッグ・アンド・ドロップで行います。
以下のように必要な項目をマッピングできればOKです。
あとは「Start」と「End」をそれぞれ接続すれば、すべてのフローが完成です。
実行
それでは実際にフローを実行してみましょう。画面上の「▶」ボタンをクリックします。
実行後スクリプトが正常に完了すると、以下のようなメッセージボックスが表示されます。
実際にSalesforceの画面を見ると、正常にデータが登録されていることがわかりました。
今回はシンプルな登録処理を行いましたが、取得対象の条件抽出や条件による更新処理等、DataSpirderを挟むことで様々なデータ連携が実現できるようになります。
おわりに
本記事では DataSpirder をもとに解説しましたが、CData Driver ではDataSpirder以外の多様なETLツールやiPaaSの接続もサポートしています。
以下のURLで各ツールの接続リファレンスを公開していますので、普段使っているツールから是非試してみてください。
http://www.cdata.com/jp/drivers/rest/
