Salesforce バッチソース プラグインを使用して BigQuery で見込み顧客データを分析する

Salesforce バッチソース プラグインを使用して BigQuery で見込み顧客データを分析する

Cloud Data Fusion で Salesforce バッチソース プラグインを使用して、BigQuery で見込み顧客データを分析する方法を学びます。

---

このタスクの手順をガイドに沿って Google Cloud コンソールで直接行う場合は、「ガイドを表示」をクリックしてください。

ガイドを表示

---

シナリオ

マーケティング マネージャーが、新しい製品を促進するためにターゲットを絞りこんだメール マーケティング キャンペーンを計画しているとします。Salesforce Sales Cloud に見込み顧客のリストがあります。ターゲット キャンペーンを作成する前にターゲット オーディエンスに対する理解を深めるために、Cloud Data Fusion の Salesforce バッチソース プラグインを使用して特定の見込み顧客データを抽出します。

準備

1. Sign in to your Google Cloud account. If you're new to Google Cloud, create an account to evaluate how our products perform in real-world scenarios. New customers also get $300 in free credits to run, test, and deploy workloads.

2. In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

   Note: If you don't plan to keep the resources that you create in this procedure, create a project instead of selecting an existing project. After you finish these steps, you can delete the project, removing all resources associated with the project.

   Go to project selector

3. Make sure that billing is enabled for your Google Cloud project.

4. In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

   Note: If you don't plan to keep the resources that you create in this procedure, create a project instead of selecting an existing project. After you finish these steps, you can delete the project, removing all resources associated with the project.

   Go to project selector

5. Make sure that billing is enabled for your Google Cloud project.

6. Enable the Cloud Data Fusion, BigQuery, Cloud Storage, and Dataproc APIs.

   Enable the APIs

7. Cloud Data Fusion インスタンスを作成します。
8. Cloud Data Fusion 用の alesforce Connected App を作成して、Salesforce API への接続を構成します。

権限を管理

必要なカスタムロールと権限を作成して割り当てます。

カスタムロールを作成して権限を追加する

1. Google Cloud コンソールの [ロール] ページに移動します。

   [ロール] に移動

2. [ ロールを作成] をクリックします。

3. [Title] 項目に「Custom Role-Tutorial」と入力します。

4. [ 権限を追加] をクリックします。

5. [権限を追加] ウィンドウで次の権限を選択し、[追加] をクリックします。

   • bigquery.datasets.create
   • bigquery.jobs.create
   • storage.buckets.create

6. [作成] をクリックします。

デフォルトの Compute Engine サービス アカウントにカスタムロールを割り当てる

1. Cloud Data Fusion の [インスタンス] ページに移動します。

   [インスタンス] に移動

2. インスタンスの名前をクリックします。

3. デフォルトの Compute Engine サービス アカウントをメモします。この情報はインスタンスの詳細ページに含まれます。

   Cloud Data Fusion のデフォルトの Compute Engine サービス アカウント名の形式は [e-mail] です。

4. [IAM] ページに移動します。

   [IAM] に移動

5. [フィルタ] バーに、デフォルトの Compute Engine サービス アカウントの名前を入力します。

6. デフォルトの Compute Engine サービス アカウントで、[ 編集] をクリックします。

7. [ 別のロールを追加] をクリックします。

8. [ロールを選択] フィールドで、[カスタムロール チュートリアル] を選択します。

9. [保存] をクリックします。

Cloud Data Fusion Salesforce バッチソース プラグインを構成する

1. Cloud Data Fusion の [インスタンス] ページに移動します。

   [インスタンス] に移動

2. インスタンスの [インスタンスを表示] をクリックします。Cloud Data Fusion ウェブ インターフェースが開きます。

3. [Studio] ページに移動します。

4. [Hub] をクリックします。

5. 検索バーに「Salesforce」と入力します。

6. [Salesforce プラグイン] をクリックしてから [Deploy] をクリックします。

7. [Salesforce plugins deploy] ウィンドウで、[Finish] をクリックします

   デプロイが完了すると、成功したことを示すダイアログが表示されます。

8. そのダイアログで、[Create a pipeline] をクリックします。

   Cloud Data Fusion Studio のページが表示されます。

9. データ パイプラインのタイプとして [データ パイプライン - バッチ] を選択します。

10. [ソース] メニューで、[Salesforce] をクリックします。

11. [Salesforce] ノードに移動して、[Salesforce] をクリックします。Salesforce プラグインのプロパティ ページが開きます。

12. [Reference name] に、ソースの名前を入力します。例: Leads_generated

13. [Connection] セクションで、[Use connection] の切り替えをオンにします。

14. [Browse connections] をクリックします。[Browse connections] ウィンドウが開きます。

15. [Add connection] をクリックし、[Salesforce] を選択します。

16. [Create a Salesforce connection] ウィンドウで [Configuration] タブをクリックし、次の操作を行います。

    1. [Name] フィールドに、接続を識別する名前を入力します（例: Salesforce_connection）。

    2. [Credentials] セクションに、Salesforce アカウントの次の詳細を入力します。

       • ユーザー名
       • パスワード
       • コンシューマ キー
       • コンシューマ シークレット
       • セキュリティ トークン

    3. [接続をテスト] をクリックします。入力した詳細が正しい場合、テストが成功し、「正常に接続しました」というメッセージが表示されます。

    4. [作成] をクリックします。

    5. [Salesforce_connection] を選択して、Salesforce プラグインのプロパティ ページに戻ります。

Salesforce バッチソース プラグインからデータを抽出する

1. Salesforce プラグイン プロパティ ページの [SOQL query] セクションに、次のクエリを入力します。

   Select LastName,FirstName,Company,Email,Phone,LeadSource,Industry,OwnerId,CreatedDate,LastModifiedDate,LastActivityDate from Lead where Status like '%Open%'
   

   このクエリは、キャンペーンの実施に必要な見込み顧客の詳細を sObject Lead から取得します。

   重要: 先ほど抽出したフィールド内の限定公開データの処理については、組織のポリシーに従ってください。Cloud Data Fusion パイプラインで非公開データを秘匿化する方法については、機密データの秘匿化をご覧ください。

2. オブジェクト スキーマの有効性を確認するには、[Get schema] をクリックします。

3. キャンペーン実行の特定の日時のレコードをフィルタするには、次のフィールドを使用します。

   • 最終更新が指定日より後
   • 最終更新日が指定日の前
   • 期間
   • オフセット

Wrangler プラグインを使用してデータを変換する

Cloud Data Fusion で Wrangler プラグインを使用して、データのクリーニングと拡充を行います。

1. [Studio] ページに戻ります。

2. [Transform] メニューで、[Wrangler] をクリックします。

3. Wrangler を Salesforce バッチソース プラグインに接続します。

4. Wrangler プラグインに移動し、[Wrangler] をクリックします。Wrangler プラグインのプロパティ ページが開きます。

5. [Input schema] が入力済みであることを確認します。

6. [Wrangle] をクリックします。

7. [Connections] ペインで、有効な接続を選択します。

8. 変換する sObject を選択します（例: Lead）。

9. 必要なディレクティブを使用してデータを変換します。

   keep :LastName,:FirstName,:Company,:Phone,:Email,:LeadSource,:OwnerId,
   :CreatedDate,:LastModifiedDate,:LastActivityDatemerge :FirstName :LastName :Name ' '
   fill-null-or-empty :Email 'no email found'
   mask-number :Phone ########xxxxxxxx
   format-date :LastActivityDate yyyy-MM-dd HH:mm:ss
   drop :LastName,:FirstName
   

   

BigQuery へのデータの読み込み

1. [Studio] ページに戻ります。

2. [Sink] メニューで、[BigQuery] をクリックします。

3. [BigQuery] ノードに移動して、[BigQuery] をクリックします。BigQuery プラグインのプロパティ ページが開きます。

4. [Basic] セクションの [Reference name] フィールドに、このシンクを識別する名前を入力します。例: Leads_generated

5. [Dataset] フィールドに、テーブルが属するデータセットを入力します。例: Salesforce_Leads

6. [Table] フィールドに、抽出したレコードを保存するテーブルを入力します。例: Incoming_Open_Leads

7. プラグインを検証するには、[Validate] をクリックします。

パイプラインのデプロイ、スケジューリング、実行

1. パイプラインをデプロイするには、[Deploy] をクリックします。

2. スケジューラを使用して適切な更新スケジュールを設定する手順は次のとおりです。

   1. [スケジュール] をクリックします。

   2. 次の詳細情報を入力します。

      • Pipeline run repeats
      • 繰り返しの間隔
      • 目安
      • Max concurrent runs
      • Compute profiles

   3. [Save and start schedule] をクリックします。

   注: デフォルトでは、データ拡張の完全な更新は 24 時間に 1 回行われます。設定における hourly スケジュール頻度は、Salesforce バッチソース プラグインが Salesforce Sales Cloud から増分データを検索する頻度を表します。

   

3. パイプラインを実行するには、[Run] をクリックします。

データの抽出と取り込みを確認する

1. Google Cloud コンソールで [BigQuery] ページに移動します。

   [BigQuery] に移動

2. データセット Salesforce_Leads とテーブル名 Incoming_Open_Leads を検索して、抽出されたレコードを表示します。

3. クエリを実行するには、[Query] をクリックします。

見込み顧客データを分析してオーディエンスに対する理解を深め、カスタマイズされた大規模なキャンペーンを配信します。

クリーンアップ

このページで使用したリソースについて、Google Cloud アカウントに課金されないようにするには、次の操作を行います。

Cloud Data Fusion インスタンスを削除する

手順に従って Cloud Data Fusion インスタンスを削除します。

プロジェクトの削除

課金をなくす最も簡単な方法は、チュートリアル用に作成したプロジェクトを削除することです。

プロジェクトを削除するには:

注意: プロジェクトを削除すると、次のような影響があります。

• プロジェクト内のすべてのものが削除されます。このドキュメントのタスクで既存のプロジェクトを使用した場合、それを削除すると、そのプロジェクトで行った他の作業もすべて削除されます。
• カスタム プロジェクト ID が失われます。このプロジェクトを作成したときに、将来使用するカスタム プロジェクト ID を作成した可能性があります。そのプロジェクト ID を使用した URL（たとえば、appspot.com）を保持するには、プロジェクト全体ではなくプロジェクト内の選択したリソースだけを削除します。

複数のアーキテクチャ、チュートリアル、クイックスタートを実施する予定がある場合は、プロジェクトを再利用すると、プロジェクトの割り当て上限を超えないようにすることができます。

1. In the Google Cloud console, go to the Manage resources page.

   Go to Manage resources

2. In the project list, select the project that you want to delete, and then click Delete.
3. In the dialog, type the project ID, and then click Shut down to delete the project.

次のステップ

• Cloud Data Fusion のプラグインを確認する。