自動將 Salesforce 商機資料匯入 BigQuery

準備環境

確認 Salesforce 使用者設定

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

設定 BigQuery 資料集和資料表

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

設定 BigQuery 資料集

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

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

   前往 BigQuery

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

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

設定 BigQuery 資料表

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

1. 在「Explorer」面板中，按一下並開啟建立的 Demo_order_dataset 資料集。
2. 請按照下列步驟建立空白的「訂單」資料表，以儲存 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. 請執行下列步驟，建立空白的「帳戶」資料表，以儲存 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 資料表應該會顯示在「Explorer」(探索工具) 面板的 Demo_order_dataset 資料集中。

驗證 ServiceNow 執行個體

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

設定連線

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

Salesforce 連線

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

BigQuery 連線

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

ServiceNow 連線

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

建立整合

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

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

   前往「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 trigger」(Salesforce 觸發條件) 元素。
3. 在設計工具畫布上選取「Salesforce trigger」(Salesforce 觸發條件) 元素，開啟 Salesforce 觸發條件設定窗格。
4. 在「觸發條件輸入」下方設定下列欄位：
   1. 事件類型：從下拉式清單中選取「變更資料擷取 (CDC)」。
   2. Salesforce 執行個體設定：按一下下拉式清單中的「+ 新增 Salesforce 執行個體設定」選項。

      在「Add Salesforce instance configuration」(新增 Salesforce 執行個體設定) 對話方塊中，執行下列操作：

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

      在「Add Salesforce channel」(新增 Salesforce 管道) 對話方塊中，執行下列操作：

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

   系統會自動儲存您對資源所做的變更。

將觸發條件有效負載對應至 Salesforce 連接器

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

連結至 Salesforce 帳戶

請按照下列步驟新增及設定「連線器」工作，以便使用 Salesforce 連線擷取商機詳細資料：

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

擷取及對應商機 ID

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

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

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

   您可以使用資料對應編輯器，透過可用的轉換函式，將輸入變數對應至所需輸出變數。然後，輸出內容會以變數的形式提供給任何其他整合作業或觸發條件。如要進一步瞭解如何對應變數，請參閱「新增對應」一文。

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

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

7. 從「Salesforce」觸發程序新增邊緣連線至「對應至商機 ID」工作。
8. 從「Map to opportunity ID」(對應至商機 ID) 工作新增邊緣連線至「Fetch Salesforce Data」(擷取 Salesforce 資料) 連接器。

在 BigQuery 資料表中驗證 Salesforce 帳戶

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

連結至 BigQuery 資料表

請按照下列步驟設定「Connectors」(連結器) 工作，使用「BigQuery」(BigQuery) 連線讀取 BigQuery「Accounts」(帳戶) 資料表：

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

擷取並驗證 Salesforce 帳戶 ID

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

1. 在整合服務編輯器中，按一下「Tasks」(任務)，即可顯示可用任務清單。
2. 在整合服務編輯器中，按一下並放置「資料對應」元素。
3. 在設計工具中，按一下「資料對應」元素，即可查看任務設定窗格。
4. 按一下 edit ，將「資料對應」工作重新命名為 Check account。
5. 按一下「開啟資料對應編輯器」。
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. 按一下設計工具中的「連接器」任務元素，即可查看「連接器」任務設定窗格。
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. 按一下設計工具中的「連接器」任務元素，即可查看「連接器」任務設定窗格。
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. 在整合服務編輯器中，按一下並放置「資料對應」元素。
3. 在設計工具中，按一下「資料對應」元素，即可查看任務設定窗格。
4. 按一下 edit ，將「資料對應」工作重新命名為 Mapping for Account Creation。
5. 按一下「開啟資料對應編輯器」。
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. 從「Mapping for Account Creation」(帳戶建立對應) 工作新增邊緣連線至「Create account in BigQuery」(在 BigQuery 中建立帳戶) 連接器。
9. 從「Mapping for Account Creation」(帳戶建立對應) 工作，新增邊緣連線至「Create account in ServiceNow」(在 ServiceNow 中建立帳戶) 連接器。

在 BigQuery 中建立新訂單

請按照下列步驟產生訂單編號，並在 BigQuery 中新增該編號。

將訂單新增至 BigQuery

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

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

產生訂單並對應至 BigQuery

1. 在整合服務編輯器中，按一下「Tasks」(任務)，即可顯示可用任務清單。
2. 在整合服務編輯器中，按一下並放置「資料對應」元素。
3. 在設計工具中，按一下「資料對應」元素，即可查看任務設定窗格。
4. 按一下 edit ，將「資料對應」工作重新命名為 Mapping for Order Creation。
5. 按一下「開啟資料對應編輯器」。
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. 從「Create account in BigQuery」(在 BigQuery 中建立帳戶) 連接器新增邊緣連線至「Mapping for Order Creation」(訂單建立對應) 工作。
9. 從「Create account in ServiceNow」連接器新增邊緣連線至「Mapping for Order Creation」工作。
10. 從「Mapping for Order Creation」(訂單建立對應) 工作新增邊緣連線至「Create Order in BigQuery」(在 BigQuery 中建立訂單) 連接器。

更新 Salesforce 商機

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

設定 Salesforce 連接器

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

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

將訂單編號對應至 Salesforce

1. 在整合服務編輯器中，按一下「Tasks」(任務)，即可顯示可用任務清單。
2. 在整合服務編輯器中，按一下並放置「資料對應」元素。
3. 在設計工具中，按一下「資料對應」元素，即可查看任務設定窗格。
4. 按一下 edit ，將「資料對應」工作重新命名為 Mapping to update opportunity。
5. 按一下「開啟資料對應編輯器」。
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. 從「Create Order in BigQuery」連接器新增邊緣連線至「Mapping to update opportunity」工作。
8. 從「Mapping to update opportunity」(對應以更新商機) 工作到「Update Salesforce」(更新 Salesforce) 連接器，新增邊緣連線。

新增邊緣條件

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

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

1. 從「Check account」(檢查帳戶) 工作新增邊緣連線至「Mapping for Account Creation」(帳戶建立對應) 工作，並設定下列邊緣條件：

     $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 帳戶收取本教學課程所用資源的費用，請取消發布整合項目，並刪除在 Integration Connectors 中建立的連線。

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