各製品の資料を入手。
詳細はこちら →製品をチェック
製品の詳細・30日間の無償トライアルはこちら
CData ConnectLightning Connect で Spark External オブジェクトと連携
CData Connect Server をつかって、Spark のデータ の仮想SQL Server として接続し、スマートデバイスやクラウドアプリケーションで利用。Connect Server と Salesforce Lightning Connect を使ってSpark オブジェクトを作成して、アプリケーションやダッシュボードでデータを使用。
加藤龍彦デジタルマーケティング
最終更新日:2022-11-25
こんにちは!ウェブ担当の加藤です。マーケ関連のデータ分析や整備もやっています。
CData Connect Server を使ってSalesforce コンソールやSalesforce Mobile App からSpark のデータ に接続することができます。 この記事では、CData Connect Server およびSalesforce Lightning Connect をつかって、Spark 外部オブジェクトを作成します。
CData Connect Server は、ピュアSQL のクラウドインターフェースをSpark に提供し、データを複製せずにSalesforce Lightning Connect からリアルタイムSpark のデータとの統合を手軽に実現します。Salesforce Lightning Connect はCData Connect Server をSQL Server データベースとして認識し、最適化されたデータ処理を使用してサポートされているすべてのSQL 操作(フィルタ、JOIN など)をSpark に直接プッシュして、サーバー側の処理を利用して、Spark のデータを素早く返します。
- Connect Server にログインし、[DATA MODEL]をクリックします。
- [Available Data Sources]から[Spark]を選択します。
-
必要な認証プロパティを入力し、Spark に接続します。
SparkSQL への接続
SparkSQL への接続を確立するには以下を指定します。
- Server:SparkSQL をホストするサーバーのホスト名またはIP アドレスに設定。
- Port:SparkSQL インスタンスへの接続用のポートに設定。
- TransportMode:SparkSQL サーバーとの通信に使用するトランスポートモード。有効な入力値は、BINARY およびHTTP です。デフォルトではBINARY が選択されます。
- AuthScheme:使用される認証スキーム。有効な入力値はPLAIN、LDAP、NOSASL、およびKERBEROS です。デフォルトではPLAIN が選択されます。
Databricks への接続
Databricks クラスターに接続するには、以下の説明に従ってプロパティを設定します。Note:必要な値は、「クラスター」に移動して目的のクラスターを選択し、 「Advanced Options」の下にある「JDBC/ODBC」タブを選択することで、Databricks インスタンスで見つけることができます。
- Server:Databricks クラスターのサーバーのホスト名に設定。
- Port:443
- TransportMode:HTTP
- HTTPPath:Databricks クラスターのHTTP パスに設定。
- UseSSL:True
- AuthScheme:PLAIN
- User:'token' に設定。
- Password:パーソナルアクセストークンに設定(値は、Databricks インスタンスの「ユーザー設定」ページに移動して「アクセストークン」タブを選択することで取得できます)。
- Create & Test をクリックします。
- Edit Spark Connection ページのPermissions タブに移動し、ユーザーベースのアクセス許可を更新します。
- USERS タブでAuthToken を取得します。
コネクションが構成されたら、Salesforce Lightning Connect からSpark に接続できるようになります。
Spark データ にOData データソースとして接続
次の手順で、Connect Server からのフィードに接続する設定を行います。
- セールスフォースにログインして、[設定]→[開発]→[外部データソース]をクリックします。
- [新規外部データソース]をクリックします。
- 以下のプロパティにデータを入力します。:
- 外部データソース: リストビューやレポートで使われるラベル名を入力。
- 名前: ユニークな識別子を入力。
- 種別: SQL Server を選択。
- 認証には、次のプロパティを設定します:
- 認証プロトコル: パスワード認証を選択します。OAuth 2.0 も選択可能です。
- Certificate: Enter or browse to the certificate to be used to encrypt and authenticate communications from Salesforce to your server.
- 管理者ユーザ名: Connect Server で設定したユーザー名を入力。
- 管理者パスワード: ユーザーのauth トークンを入力。

Spark データ と同期したオブジェクトの作成
外部データソース作成後、次の手順で Spark のデータを反映する外部オブジェクトを作成します。 Spark 外部オブジェクトとSpark テーブルの定義を同期する必要があります。
- 作成した外部データソースを選択します。
- [検証して同期]をクリックします。
- Spark テーブルをクリックして、外部オブジェクトとします。

Salesforce オブジェクトとして Spark データ にアクセス
Spark のデータ を外部データソースとして追加し、Spark テーブルをSpark 外部データソースとして同期すると、標準のSalesforce オブジェクトとして外部オブジェクトを使用することができます。
-
フィルターリストビュー付で新しいタブを作成する:
-
標準Salesforce オブジェクトと並べて Spark 外部オブジェクトをディスプレイできます: