自動將 Salesforce 商機資料匯入 BigQuery

準備環境

確認 Salesforce 使用者設定

本教學課程假設您已擁有 Salesforce 開發人員帳戶，並具備必要的使用者設定和權限組合。請確認您的帳戶已啟用變更資料擷取 (CDC)。如要瞭解如何建立新帳戶，請參閱「設定整合使用者」。

設定 BigQuery 資料集和資料表

在本教學課程中，您必須設定 BigQuery 資料集，並建立兩個資料表來儲存 Salesforce 商機詳細資料和 ServiceNow 帳戶資訊。

設定 BigQuery 資料集

如要設定 BigQuery 資料集，請按照下列步驟操作：

1. 前往 Google Cloud 控制台的「BigQuery」BigQuery頁面。

   前往 BigQuery

2. 按一下「Explorer」面板，然後選取您在本教學課程中使用的專案。
3. 展開 more_vert (動作)，然後選取「建立資料集」。
4. 在「Create dataset」頁面中設定下列詳細資料：
   1. 資料集 ID：輸入 Demo_order_dataset。
   2. 「位置類型」>「區域」：選擇 us-central1 (lowa) 區域。
5. 點選「建立資料集」。

新的 Demo_order_dataset 資料集現在應該會顯示在「Explorer」面板的專案中。

設定 BigQuery 資料表

如要建立 BigQuery 資料表，請按照下列步驟操作：

1. 在「Explorer」面板中，按一下並開啟已建立的 Demo_order_dataset 資料集。
2. 請按照下列步驟建立空白的「Orders」資料表，用於儲存 Salesforce 商機詳細資料：
   1. 按一下 add_box「建立資料表」。
   2. 在「Destination」(目的地) 部分，輸入 Orders 做為資料表名稱。
   3. 在「Schema」(結構定義) 區段中，按一下「Edit as text」(以文字形式編輯)，然後貼上以下的 JSON 結構定義：

      [
        {
          "name": "order_number",
          "type": "STRING",
          "mode": "NULLABLE",
          "description": "Salesforce order number"
        },
        {
          "name": "order_status",
          "type": "STRING",
          "mode": "NULLABLE",
          "description": "Sale order status"
        },
        {
          "name": "tracking_number",
          "type": "INTEGER",
          "mode": "NULLABLE",
          "description": "Salesforce tracking number"
        }
      ]

   4. 點選「建立資料表」。
3. 請按照下列步驟建立空白的「Accounts」資料表，用於儲存 Salesforce 帳戶詳細資料：
   1. 按一下 add_box「建立資料表」。
   2. 在「Destination」(目的地) 部分，輸入 Accounts 做為資料表名稱。
   3. 在「Schema」(結構定義) 區段中，按一下「Edit as text」(以文字形式編輯)，然後貼上以下的 JSON 結構定義：

      [
        {
          "name": "account_id",
          "type": "STRING",
          "mode": "NULLABLE",
          "description": "Account ID for the opportunity"
        },
        {
          "name": "name",
          "type": "STRING",
          "mode": "NULLABLE",
          "description": "Account name for the opportunity"
        }
      ]

   4. 點選「建立資料表」。

   新的 Orders 和 Accounts 資料表現在應該會顯示在「探索工具」面板中的 Demo_order_dataset 資料集中。

驗證 ServiceNow 執行個體

本教學課程使用 ServiceNow 免費的個人開發人員執行個體 (PDI)。您可以使用現有的 ServiceNow 執行個體，也可以建立新的執行個體。確認執行個體是否處於有效狀態，並記下其執行個體網址。如要進一步瞭解 PDI，請參閱 ServiceNow PDI 說明文件。

設定連線

在本教學課程中，您必須在 Integration Connectors 中設定下列連線：

Salesforce 連線

在 Integration Connectors 中設定 Salesforce 連線。如要瞭解如何設定 Salesforce 連接器，請參閱「Salesforce 連接器」。

BigQuery 連線

在整合連接器中設定 BigQuery 連線，即可取得、更新及驗證 Demo_order_dataset 資料集中的訂單和帳戶詳細資料。如要瞭解如何設定 BigQuery 連接器，請參閱「BigQuery 連接器」一文。

ServiceNow 連線

使用執行個體網址在整合連接器中設定 ServiceNow 連線，即可在 ServiceNow 中建立及擷取帳戶詳細資料。如要瞭解如何設定 ServiceNow 連接器，請參閱「ServiceNow 連接器」一文。

建立整合

如要建立新的整合，請按照下列步驟操作：

1. 前往 Google Cloud 控制台的「Application Integration」頁面。

   前往「應用程式整合」

2. 按一下左側導覽選單中的「整合」，開啟「整合」頁面。
3. 按一下 add_box「建立整合」，然後在「建立整合」頁面中提供下列詳細資料：
   1. 整合名稱：輸入 opportunity-to-order-integration。
   2. 說明：輸入 Demo integration created for tutorial。
   3. 區域：從支援的區域清單中選取「us-central1」。
   4. 按一下「建立」開啟整合編輯器。

設定整合觸發條件

成功建立整合後，您可以新增及設定整合觸發事件，針對特定事件叫用整合。

在本教學課程中，我們會使用 Salesforce 觸發條件，針對在 Salesforce 例項中建立的每個新商機叫用整合。如要在 opportunity-to-order-integration 整合中新增及設定 Salesforce 觸發條件，請按照下列步驟操作：

1. 在整合服務編輯器中，按一下「觸發條件」，即可顯示可用的觸發條件清單。
2. 在整合服務編輯器中，按一下並放置 Salesforce 觸發條件元素。
3. 選取設計工具畫布上的「Salesforce trigger」元素，開啟 Salesforce 觸發條件設定窗格。
4. 在「觸發條件輸入」下方設定下列欄位：
   1. 事件類型：從下拉式清單中選取「Change Data Capture (CDC)」。
   2. Salesforce 例項設定：在下拉式清單中點選「+ 新增 Salesforce 例項設定」選項。

      在「Add Salesforce instance configuration」對話方塊中，執行下列操作：

      • Salesforce 執行個體連線名稱：輸入 Salesforce 執行個體的連線名稱。例如：test。
      • Salesforce 網域：輸入 Salesforce 網域名稱。您可以前往 Salesforce 帳戶 > 查看個人資料頁面查看這項資訊。
      • 驗證設定檔：選取驗證設定檔。如果沒有驗證設定檔，請建立新的設定檔。詳情請參閱「建立新的驗證設定檔」。
      • 按一下「新增」。
   3. Salesforce 管道設定：按一下下拉式清單中的「+ 新增 Salesforce 管道設定」選項。

      在「Add Salesforce channel」對話方塊中，執行下列操作：

      • Salesforce 物件名稱：輸入 Opportunity。
      • 按一下「新增」。
   4. 作業：從下拉式清單中選取「建立」

   系統會自動儲存屬性變更。

將觸發事件酬載對應至 Salesforce 連接器

當整合作業使用 Salesforce 觸發條件叫用時，您可以擷取商機 ID 並對應至 Salesforce 連接器，以便擷取商機的其他詳細資料。

連結至 Salesforce 帳戶

請按照下列步驟新增及設定 Connectors 工作，以便透過 Salesforce 連線擷取商機詳細資料：

1. 在整合服務編輯器中，按一下「Tasks」，即可顯示可用任務清單。
2. 在整合服務編輯器中，按一下並放置「Connectors」元素。
3. 在設計工具中選取「Connectors」任務元素，即可查看「Connectors」任務設定窗格。
4. 按一下 edit ，然後將「Connectors」標籤重新命名為 Fetch Salesforce Data。
5. 按一下「設定連接器」。
6. 在「連接器工作編輯器」頁面中執行下列操作：
   1. 在「選取連線」下方，選擇 us-central1 區域。
   2. 從可用連線清單中選取 Salesforce 連線。
   3. 點選「下一步」。
   4. 在「Type」下方，選擇「Entities」。
   5. 在「設定實體/動作」下方，從可用實體清單中選取「Opportunity」，然後選取「Get」做為「Operation」。
   6. 按一下「完成」，完成連線設定並關閉窗格。

擷取並對應商機 ID

資料對應工作會用來對應及擷取 Salesforce 觸發條件和 Salesforce 連接器之間的商機詳細資料。

如要在整合中新增及設定資料對應項目，請按照下列步驟操作：

1. 在整合服務編輯器中，按一下「Tasks」，即可顯示可用任務清單。
2. 在整合服務編輯器中按一下並放置「Data Mapping」(資料對應) 元素。
3. 在設計工具中選取「Data Mapping」元素，即可查看任務設定窗格。
4. 按一下 edit ，然後將「資料對應」工作重新命名為 Map to opportunity ID。
5. 按一下「Open Data Mapping Editor」。

   資料對應編輯器可讓您使用可用的轉換函式，將輸入變數對應至所需的輸出變數。接著，輸出內容可做為任何其他整合作業或觸發事件的變數。如要進一步瞭解對應變數，請參閱「新增對應」。

6. 將觸發條件 —SalesforceTriggerCdcRecordID— 輸出變數對應至自動產生的連接器 —entityId(Fetch Salesforce Data)— 輸入變數。

   對應完成後，請關閉窗格。系統會自動儲存所有變更。

7. 從 Salesforce 觸發條件新增邊緣連線，連結至「對應至商機 ID」任務。
8. 從「對應至商機 ID」工作新增邊緣連線至「擷取 Salesforce 資料」連接器。

在 BigQuery 資料表中驗證 Salesforce 帳戶

從 Salesforce 連接器擷取所有商機詳細資料後，請擷取並對應與商機相關聯的帳戶 ID，並驗證該帳戶 ID 是否存在於 BigQuery 資料表中。

連結至 BigQuery 資料表

請按照下列步驟設定連接器工作，以便透過 BigQuery 連線讀取 BigQuery Accounts 資料表：

1. 在整合服務編輯器中，按一下「Tasks」，即可顯示可用任務清單。
2. 在整合服務編輯器中，按一下並放置「Connectors」元素。
3. 按一下設計工具中的「Connectors」任務元素，即可查看「Connectors」任務設定窗格。
4. 按一下 edit ，然後將「Connectors」重新命名為 Check account in BigQuery。
5. 按一下「設定連接器」。
6. 在「連接器工作編輯器」頁面中執行下列操作：
   1. 在「選取連線」下方，選擇 us-central1 區域。
   2. 從可用連線清單中選取 BigQuery 連線。
   3. 點選「下一步」。
   4. 在「Type」下方，選擇「Entities」。
   5. 在「設定實體/動作」下方，從可用實體清單中選取「帳戶」，然後選取「清單」做為「操作」。
   6. 按一下「完成」，完成連線設定並關閉窗格。
7. 從擷取 Salesforce 資料連接器新增邊緣連線至 在 BigQuery 中檢查帳戶連接器。

擷取及驗證 Salesforce 帳戶 ID

如要擷取、對應及驗證商機的帳戶 ID，請按照下列步驟操作：

1. 在整合服務編輯器中，按一下「Tasks」，即可顯示可用任務清單。
2. 在整合服務編輯器中按一下並放置「Data Mapping」(資料對應) 元素。
3. 在設計工具中，按一下「Data Mapping」(資料對應) 元素，即可查看任務設定窗格。
4. 按一下 edit ，然後將「資料對應」工作重新命名為 Check account。
5. 按一下「Open Data Mapping Editor」。
6. 按一下「+ 新增變數」，然後建立下列輸出變數：

   輸出變數名稱	資料類型
   sf_account_id	STRING
   sf_account_name	STRING
   account_exists	BOOLEAN

7. 請在 Salesforce 連接器酬載變數和本機變數之間建立下列對應：

   輸入	輸出
   connectorOutputPayload ( Fetch Salesforce Data) .GET_PROPERTY("AccountId")	sf_account_id
   connectorOutputPayload ( Fetch Salesforce Data) .GET_PROPERTY("Name")	sf_account_name
   connectorOutputPayload (Check account in BigQuery) .FILTER(~obj1 -> ~obj1 .GET_PROPERTY("account_id") .TO_STRING() .EQUALS(sf_account_id) ) .SIZE() .EQUALS("1")	account_exists

   對應完成後，請關閉窗格。系統會自動儲存所有變更。

8. 從「在 BigQuery 中檢查帳戶」連接器新增邊緣連結至「檢查帳戶」工作。

建立新的 BigQuery 帳戶

在 BigQuery 中驗證 Salesforce 帳戶後，如果帳戶不存在，請按照下列步驟在 BigQuery 中建立新帳戶。您也可以使用相同的資訊在 ServiceNow 中建立帳戶。

將帳戶新增至 BigQuery

請按照下列步驟設定 Connectors 工作，在 BigQuery 的 Accounts 資料表中建立新實體：

1. 在整合服務編輯器中，按一下「Tasks」，即可顯示可用任務清單。
2. 在整合服務編輯器中，按一下並放置「Connectors」元素。
3. 按一下設計工具中的「Connectors」任務元素，即可查看「Connectors」任務設定窗格。
4. 按一下 edit ，然後將「Connectors」重新命名為 Create account in BigQuery。
5. 按一下「設定連接器」。
6. 在「連接器工作編輯器」頁面中執行下列操作：
   1. 在「選取連線」下方，選擇 us-central1 區域。
   2. 從可用連線清單中選取 BigQuery 連線。
   3. 點選「下一步」。
   4. 在「Type」下方，選擇「Entities」。
   5. 在「設定實體/動作」下方，從可用實體清單中選取「帳戶」，然後選取「建立」做為「操作」。
   6. 按一下「完成」，完成連線設定並關閉窗格。

建立新的 ServiceNow 帳戶

請按照下列步驟設定 Connectors 工作，以便在 ServiceNow 例項中新增帳戶：

1. 在整合服務編輯器中，按一下「Tasks」，即可顯示可用任務清單。
2. 在整合服務編輯器中，按一下並放置「Connectors」元素。
3. 按一下設計工具中的「Connectors」任務元素，即可查看「Connectors」任務設定窗格。
4. 按一下 edit ，然後將「Connectors」重新命名為 Create account in ServiceNow。
5. 按一下「設定連接器」。
6. 在「連接器工作編輯器」頁面中執行下列操作：
   1. 在「選取連線」下方，選擇 us-central1 區域。
   2. 從可用連線清單中選取 BigQuery 連線。
   3. 點選「下一步」。
   4. 在「Type」下方，選擇「Entities」。
   5. 在「設定實體/動作」下方，從可用實體清單中選取「system_user」，然後選取「建立」做為「操作」。
   6. 按一下「完成」，完成連線設定並關閉窗格。

轉換及對應帳戶詳細資料

如要轉換帳戶詳細資料並對應至 BigQuery 和 ServiceNow 連接器，請按照下列步驟操作：

1. 在整合服務編輯器中，按一下「Tasks」，即可顯示可用任務清單。
2. 在整合服務編輯器中按一下並放置「Data Mapping」(資料對應) 元素。
3. 在設計工具中，按一下「Data Mapping」(資料對應) 元素，即可查看任務設定窗格。
4. 按一下 edit ，然後將「資料對應」工作重新命名為 Mapping for Account Creation。
5. 按一下「Open Data Mapping Editor」。
6. 按一下「+ 新增變數」，然後建立下列輸入變數：

   輸入變數名稱	資料類型
   new_BQaccount	JSON
   new_SNaccount	JSON

7. 建立以下對應，將 Salesforce 帳戶 ID 和名稱對應至 BigQuery 資料表：

   輸入	輸出
   new_BQaccount .SET_PROPERTY( sf_account_id, "account_id" ) .SET_PROPERTY( sf_account_name, "name" )	connectorInputPayload (Create account in BigQuery)
   new_SNaccount .SET_PROPERTY( sf_account_id, "sys_id" ) .SET_PROPERTY( sf_account_name, "first_name" )	connectorInputPayload (Create account in ServiceNow)

   對應完成後，請關閉窗格。系統會自動儲存所有變更。

8. 從帳戶建立對應任務新增邊緣連結至 在 BigQuery 中建立帳戶連接器。
9. 從帳戶建立對應任務新增邊緣連線，連結至在 ServiceNow 中建立帳戶連接器。

在 BigQuery 中建立新訂單

請按照下列步驟產生訂單號碼，並將其新增至 BigQuery。

將訂單新增至 BigQuery

請按照下列步驟設定 Connectors 工作，在 BigQuery 的「Orders」資料表中建立新實體：

1. 在整合服務編輯器中，按一下「Tasks」，即可顯示可用任務清單。
2. 在整合服務編輯器中，按一下並放置「Connectors」元素。
3. 按一下設計工具中的「Connectors」任務元素，即可查看「Connectors」任務設定窗格。
4. 按一下 edit ，然後將「Connectors」重新命名為 Create order in BigQuery。
5. 按一下「設定連接器」。
6. 在「連接器工作編輯器」頁面中執行下列操作：
   1. 在「選取連線」下方，選擇 us-central1 區域。
   2. 從可用連線清單中選取 BigQuery 連線。
   3. 點選「下一步」。
   4. 在「Type」下方，選擇「Entities」。
   5. 在「設定實體/動作」下方，從可用實體清單中選取「訂單」，然後選取「建立」做為「操作」。
   6. 按一下「完成」，完成連線設定並關閉窗格。

產生訂單並對應至 BigQuery

1. 在整合服務編輯器中，按一下「Tasks」，即可顯示可用任務清單。
2. 在整合服務編輯器中按一下並放置「Data Mapping」(資料對應) 元素。
3. 在設計工具中，按一下「Data Mapping」(資料對應) 元素，即可查看任務設定窗格。
4. 按一下 edit ，然後將「資料對應」工作重新命名為 Mapping for Order Creation。
5. 按一下「Open Data Mapping Editor」。
6. 按一下「+ 新增變數」，然後建立下列變數：

   變數名稱	資料類型
   order_number	STRING

7. 建立下列對應項目，產生新訂單號碼，並將訂單詳細資料對應至 BigQuery 連接器：

   輸入	輸出
   GENERATE_UUID() .SPLIT("-") .GET("0")	new_order_number
   "{}" .TO_JSON() .SET_PROPERTY( connectorOutputPayload ( Fetch Salesforce Data) .GET_PROPERTY("DeliveryInstallationStatus__c") , "order_status" ) .SET_PROPERTY( connectorOutputPayload ( Fetch Salesforce Data) .GET_PROPERTY("TrackingNumber__c") , "tracking_number" ) .SET_PROPERTY( new_order_number , "order_number" )	connectorInputPayload (Create Order in BigQuery)

   對應完成後，請關閉窗格。系統會自動儲存所有變更。

8. 從「在 BigQuery 中建立帳戶」連接器新增邊緣連結，連結至「訂單建立作業的對應項目」工作。
9. 新增邊緣連線，從在 ServiceNow 中建立帳戶連接器連結至訂單建立對應工作。
10. 從訂單建立對應工作新增邊緣連線至「在 BigQuery 中建立訂單」連接器。

更新 Salesforce 商機

產生新訂單號碼後，請更新來源 Salesforce 商機

設定 Salesforce 連接器

請按照下列步驟設定 Connectors 工作，以更新現有的 Salesforce 商機：

1. 在整合服務編輯器中，按一下「Tasks」，即可顯示可用任務清單。
2. 在整合服務編輯器中，按一下並放置「Connectors」元素。
3. 按一下設計工具中的「Connectors」任務元素，即可查看「Connectors」任務設定窗格。
4. 按一下 edit ，然後將「Connectors」重新命名為 Update Salesforce。
5. 按一下「設定連接器」。
6. 在「連接器工作編輯器」頁面中執行下列操作：
   1. 在「選取連線」下方，選擇 us-central1 區域。
   2. 從可用連線清單中選取 Salesforce 連線。
   3. 點選「下一步」。
   4. 在「Type」下方，選擇「Entities」。
   5. 在「設定實體/動作」下方，從可用實體清單中選取「Opportunity」，然後選取「Update」做為「Operation」。
   6. 按一下「完成」，完成連線設定並關閉窗格。

將訂單號碼對應至 Salesforce

1. 在整合服務編輯器中，按一下「Tasks」，即可顯示可用任務清單。
2. 在整合服務編輯器中按一下並放置「Data Mapping」(資料對應) 元素。
3. 按一下設計工具中的「Data Mapping」(資料對應) 元素，即可查看任務設定窗格。
4. 按一下 edit ，然後將「資料對應」工作重新命名為 Mapping to update opportunity。
5. 按一下「Open Data Mapping Editor」。
6. 建立下列對應項目，以便更新 Salesforce 商機：

   輸入	輸出
   "{}" .TO_JSON() .SET_PROPERTY( new_order_number , "OrderNumber__c" )	connectorInputPayload (Update Salesforce)
   entityId ( Fetch Salesforce Data)	entityId (Update Salesforce )
   "'" .CONCAT(entityId ( Fetch Salesforce Data)) .CONCAT("'")	filterClause (Update Salesforce )

   對應完成後，請關閉窗格。系統會自動儲存所有變更。

7. 從「在 BigQuery 中建立訂單」連接器新增邊緣連結，連結至「更新商機的對應」工作。
8. 從更新商機的對應工作新增邊緣連線至「更新 Salesforce」連接器。

新增邊緣條件

邊緣條件可讓您指定整合項目必須符合哪些條件，才能將控制權傳遞至透過邊緣連結的任務。您已新增及設定必要的任務，現在可以新增邊緣條件來定義整合作業的流程。

以下邊緣條件會根據帳戶資訊的驗證結果，控制整合作業的流程：

1. 使用下列邊緣條件，從「檢查帳戶」工作新增邊緣連結至「建立帳戶的對應項目」工作：

     $account_exists$ = False

2. 使用下列邊緣條件，從「Check account」作業新增另一個邊緣連結至「Mapping for Order Creation」作業：

     $account_exists$ = True

整合流程範例

下圖顯示透過本教學課程建立的整合項目範例版面配置。

發布及測試整合項目

如要發布整合項目，請在整合服務編輯器工具列中按一下「發布」。

成功發布整合後，您可以查看及檢查已發布的整合項目的執行記錄。如要查看記錄，請按一下「查看這項整合的執行記錄」。系統隨即會顯示「執行記錄」頁面。

測試案例 1：確認是否已為新帳戶 ID 建立訂單

登入 Salesforce 執行個體並建立新的商機，測試整合。您必須在新帳戶或 BigQuery 表格中不存在的帳戶中建立商機。

如要驗證整合是否成功，請按照下列步驟操作：

1. 前往「BigQuery」BigQuery頁面。

   前往 BigQuery

   • 開啟「帳戶」資料表，確認是否已插入新的商機帳戶 ID。
   • 開啟「Orders」資料表，確認是否已插入新的訂單詳細資料。
2. 前往您的 ServiceNow 執行個體。
   • 確認是否有新帳戶新增至含有相同 Salesforce 商機帳戶 ID 的例項。
3. 開啟 Salesforce。
   • 確認商機是否已更新為新的訂單號碼。

測試案例 2：檢查 BigQuery 中是否已為現有帳戶 ID 建立訂單號

登入 Salesforce 執行個體並建立新的商機，測試整合。您必須在 BigQuery 表格中現有的帳戶中建立商機。

如要驗證整合是否成功，請按照下列步驟操作：

1. 前往「BigQuery」BigQuery頁面。

   前往 BigQuery

   • 開啟「帳戶」資料表，確認系統沒有插入新的帳戶 ID。
   • 開啟「Orders」資料表，確認是否已插入新的訂單詳細資料。
2. 開啟 Salesforce。
   • 確認商機是否已更新為新的訂單號碼。

清除所用資源

如要避免系統向您的 Google Cloud 帳戶收取本教學課程所用資源的費用，請取消發布整合，並刪除在整合連接器中建立的連結。

• 如要取消發布這項整合，請在整合服務編輯器的工具列中按一下「取消發布」。詳情請參閱刪除整合。
• 如要瞭解如何刪除連線，請參閱「管理連接器」。