Salesforce Data 360 ファイル共有のためのレイクハウスフェデレーション

このページでは、ファイル共有コネクタを使用して Salesforce Data 360 (旧 Data クラウド) のデータを読み取る方法について説明します。

どの Salesforce コネクタを使用すべきですか?

Databricks は Salesforce 用の複数のコネクタを提供しています。ゼロコピーコネクタには、Salesforce Data 360 ファイル共有コネクタと Salesforce Data 360 クエリフェデレーションコネクタの 2 つがあります。これらを使用すると、Salesforce Data 360 内のデータを移動せずにクエリできます。さまざまな Salesforce 製品からデータをコピーする Salesforce 取り込みコネクタもあります。

次の表は、Databricks の Salesforce コネクタ間の違いをまとめたものです。

コネクター	ユースケース	サポートされている Salesforce 製品
Salesforce Data 360 ファイル共有	レイクハウスフェデレーションで Salesforce Data 360 ファイル共有コネクタを使用すると、 Databricks Salesforce Data-as-a-Service (DaaS) APIs呼び出して、基盤となるクラウド オブジェクト ストレージの場所にあるデータを直接読み取ります。 クエリは、 JDBCプロトコルを使用せずにDatabricksコンピュート上で実行されます。 クエリ フェデレーションと比較して、ファイル共有は大量のデータをフェデレーションするのに最適です。複数のデータソースからのファイルの読み取りパフォーマンスが向上し、プッシュダウン機能も向上します。 Salesforce Data 360 ファイル共有については、レイクハウスフェデレーションを参照してください。	セールスフォース・データ360
Salesforce Data 360 クエリフェデレーション	レイクハウスフェデレーションで Salesforce Data 360 クエリ フェデレーション コネクタを使用すると、 Databricks JDBC使用してソース データに接続し、クエリを Salesforce にプッシュします。 「Salesforce Data 360 でフェデレーションクエリを実行する」を参照してください。	セールスフォース・データ360
Salesforce の取り込み	LakeFlow Connect の Salesforce インジェスト コネクタを使用すると、Salesforce Platform データからフルマネージド インジェスト パイプラインを作成できます。このコネクタは、CDPデータだけでなく、Data Intelligence PlatformのCRMデータも活用することで、価値を最大化します。「Salesforce からのデータの取り込み」を参照してください。	「Salesforce インジェスト コネクタはどの Salesforce 製品をサポートしていますか?」を参照してください。

始める前に

ワークスペースの要件：

• Unity Catalogのワークスペースが有効になっています。

コンピュートの要件：

• Databricksコンピュート リソースから、データが存在する Salesforce Data 360 APIおよび Salesforce Data 360 のパブリックS3バケットへのネットワーク接続。 レイクハウスフェデレーションのネットワークに関する推奨事項を参照してください。
• Databricks クラスタリングでは Databricks Runtime 16.3 以降と標準アクセス モードを使用する必要があります。
• SQLウェアハウスはProまたはServerlessである必要があります。

必要な権限：

• 接続を作成するには、メタストア管理者か、ワークスペースに接続されているUnity Catalogメタストアの CREATE CONNECTION 権限を持つユーザーである必要があります。
• フォーリンカタログを作成するには、メタストアに対する CREATE CATALOG 権限を持ち、接続の所有者であるか、接続に対する CREATE FOREIGN CATALOG 権限を持っている必要があります。

追加の権限要件は、以下の各タスクベースのセクションに記載しています。

接続とフォーリンカタログの作成

接続では、外部データベースシステムにアクセスするためのパスと認証情報を指定します。接続を作成するには、カタログエクスプローラーを使用するか、Databricksノートブックまたは Databricks SQLクエリーエディタで CREATE CONNECTION SQLコマンドを使用できます。

注記

Databricks REST API または Databricks CLI を使用して接続を作成することもできます。 POST /api/2.1/unity-catalog/connections および Unity Catalog コマンドを参照してください。

必要な権限： メタストア管理者またはCREATE CONNECTION権限を持つユーザー。

Catalog Explorer

1. Databricks ワークスペースで、 カタログ をクリックします。

2. [カタログ]ウィンドウの上部にある [ 追加] アイコンをクリックし、メニューから [ 接続の追加] を選択します。

   または、 クイックアクセス ページから 外部データ > ボタンをクリックし、 接続 タブに移動して 接続を作成 をクリックします。

3. 接続のセットアップ ウィザードの 接続の基本 ページで、わかりやすい 接続名 を入力します。

4. Salesforce Data 360 ファイル共有 の 接続タイプ を選択します。

5. （オプション）コメントを追加します。

6. 接続の作成 をクリックします。

7. 認証 ページで、Salesforce Data 360 ファイル共有インスタンスの次のプロパティを入力します。

   • テナント固有のエンドポイント : たとえば、 https://mvsw0mbrmqzdcyj-m02t0mrsh1.pc-rnd.c360a.salesforce.com
   • コア テナント ID : たとえば、 core/falcontest8-core4sdb26/00DVF000001E16v2AC

8. カタログの基本 ページで、フォーリンカタログの名前を入力します。 フォーリンカタログは、外部データシステム内のデータベースをミラーリングするため、DatabricksとUnity Catalogを使用して、そのデータベース内のデータへのアクセスを管理できます。

9. （オプション）[ 接続をテスト ]をクリックして、動作することを確認します。

10. [ カタログを作成 ] をクリックします。

11. アクセス ページで、作成したカタログにユーザーがアクセスできるワークスペースを選択します。 すべてのワークスペースにアクセス権がある を選択するか、 ワークスペースに割り当て をクリックし、ワークスペースを選択して 割り当て をクリックします。

12. カタログ内のすべてのオブジェクトへのアクセスを管理できる 所有者 を変更します。テキスト ボックスにプリンシパルの入力を開始し、返された結果でプリンシパルをクリックします。

13. カタログに対する 権限を付与 します。[ 許可 ] をクリックします。

    ある。カタログ内のオブジェクトにアクセスできる プリンシパル を指定します。テキスト ボックスにプリンシパルの入力を開始し、返された結果でプリンシパルをクリックします。ある。各プリンシパルに付与する 権限プリセット を選択します。デフォルトでは、すべてのアカウントユーザーに BROWSE が付与されます。

    • ドロップダウンメニューから「 データ閲覧者 」を選択して、カタログ内のオブジェクトに対する read 権限を付与します。
    • ドロップダウンメニューから「 データエディタ 」を選択して、カタログ内のオブジェクトに対する read 権限と modify 権限を付与します。
    • 付与する権限を手動で選択します。

    a. [Grant] をクリックします。

14. 次へ をクリックします。

15. [メタデータ] ページで、タグのキーと値のペアを指定します。詳細については、「Unity Catalog セキュリティ保護可能なオブジェクトにタグを適用する」を参照してください。

16. （オプション）コメントを追加します。

17. 保存 をクリックします。

18. Account URLとConnection URLをメモします。これらの値は、Salesforce でデータ共有ターゲットを作成するために必要になります。

SQL

1. ノートブックまたはDatabricks SQLクエリーエディタで次のコマンドを実行します。

   SQL

   CREATE CONNECTION <connection-name> TYPE SALESFORCE_DATA_CLOUD_FILE_SHARING
   OPTIONS (
       tenant_specific_endpoint '<tenant_specific_endpoint>',
       core_tenant_id '<core_tenant_id>'
   );

2. 新しく作成した接続の接続ページに移動し、 Account URL と Connection URLをメモします。これらの値は、Salesforce でデータ共有ターゲットを作成するために必要になります。

Salesforce でのデータ共有ターゲットの作成

前のステップで取得した Account URL と Connection URL を使用して、Salesforce でデータ共有ターゲットを作成します。

Salesforce ドキュメントの「 データ共有ターゲットの作成 (Databricks)」 を参照してください。

データ型マッピング

Salesforce Data 360 ファイル共有から Spark に読み取る場合、データ型は次のようにマップされます。

Salesforce Data 360 ファイル共有タイプ	Spark タイプ
Number	DecimalType(38, 18)
Boolean	BooleanType
Text	StringType
Date	DateType
日時型	TimestampType
Eメール (Text)	StringType
パーセント (数値)	DecimalType(38, 18)
電話(テキスト)	StringType
URL(テキスト)	StringType

制限

• コネクタは、シングルユーザー クラスタリングでは使用できません。