由于之前有接触过 GCP 和 Salesforce 集成相关的项目, 但是没有认真的了解过中间的实现细节, 那么今天这篇文章主要介绍如何在Google Cloud上创建一个Cloud Function并认证连接到Salesforce.
在本篇内容中, 我们的挑战主要包括:
- 创建一个 Google Cloud Function
- 使用Secret Manager在GCP中存储Salesforce凭证
- 使用Cloud Function与Salesforce进行认证,并创建 Salesforce 数据
开始前准备:
Tip: 为了可以使用 Google Cloud Function, 我们需要绑定一张自己的真实信用卡, 主要原因是Google为了校验操作的不是机器人, 过程不会扣任何费用.
简单的架构示意图:
步骤 1. Google Cloud Platform: 启用 Secret Manager
通过REST API访问Salesforce需要三部分;用户名,密码和Security Token. 在GCP内存储这类信息的最安全选择是 Secret Manager.它允许对这些凭证进行存储和版本控制, 以便安全使用. 下面介绍如何在Secret Manager里设置参数.
步骤:
- 在
google Console界面, 选择Security, - 在
Security选择卡中选择Secret Manager, 点击进入详情页
步骤 2. Google Cloud Platform: 创建 Salesforce 凭证
步骤:
- 在
Secret Manager, 点击CREATE SECRET
在 CREATE SECRET 页面:
- Name = SF_USER_PROD
- Secret Value =
YOUR@SALESFORCEUSERNAME.com - 点击
Create Secret按钮 - 对于
SF_PASS_PROD和SF_TOKEN_PROD重复上面这些相同的步骤.
步骤 3. Google Cloud Platform: 创建 Google Cloud Function (Python)
现在, Salesforce 凭证已经安全存储, 接下来我们将创建一个云函数(Cloud Function). Cloud Function是Serverless,可移植的代码解决方案, 在运行时被调用. 在创建的这个云函数中, 由于谷歌没有与Salesforce原生集成,我们必须调用一个名为Simple Salesforce的第三方Python REST API库. 这使得我们可以通过REST API使用简化的方法来验证, 创建, 更新和查询Salesforce数据.
步骤:
- 在
google Console界面, 选择Cloud Functions,
- 在
Cloud Functions界面, 点击CLOUD FUNCTION,
在 CLOUD FUNCTION 页面:
- Name =
salesforce-record-submission - Memory Allocated =
128 MiB - Trigger Type =
HTTP - Source Code >
Inline editor - Runtime =
Python 3.7 - 在 Main.py 编辑器中放以下内容.这是我们将从 HTTP Post 传入数据,进行 Salesforce 身份验证并将此服务中发布的数据作为新联系人提交到 Salesforce 的代码.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
from simple_salesforce import Salesforce, SalesforceLogin
from simple_salesforce import SFType
from google.cloud import secretmanager
import requests
import json
import os
def main(initial_request):
sftype_object = os.environ["sftype_object"]
try:
request_json = initial_request.get_json()
print("main - print: {}".format(request_json))
#retrieve salesforce session and instance reference
session_id, instance = sf_login()
record = SFType(sftype_object,session_id,instance)
#send payload to Salesforce API
record.create(request_json)
#parse response from Salesforce API
record_submit = record.describe()
print("main - record_submit: {}".format(record_submit))
return "Main Request Passed"
except Exception as error:
print('Main Error: ' + repr(error))
def sf_login():
# Create the Secret Manager client.
client = secretmanager.SecretManagerServiceClient()
# Organize the Secret Keys
sf_user_prod = "SF_USER_PROD"
sf_pass_prod = "SF_PASS_PROD"
sf_token_prod = "SF_TOKEN_PROD"
# Pass in the GCP Project ID
# This will be found on the Secret Manager > Secret > Secret Details
# projects/[gcp_project_id]/secrets/[secret]
project_id = os.environ["gcp_project_id"]
# Obtain the Secret Name Path
sf_user_prod_name = f"projects/{project_id}/secrets/{sf_user_prod}/versions/latest"
sf_pass_prod_name = f"projects/{project_id}/secrets/{sf_pass_prod}/versions/latest"
sf_token_prod_name = f"projects/{project_id}/secrets/{sf_token_prod}/versions/latest"
# Obtain the Latest Secret Version
sf_user_prod_response = client.access_secret_version(sf_user_prod_name)
sf_pass_prod_response = client.access_secret_version(sf_pass_prod_name)
sf_token_prod_response = client.access_secret_version(sf_token_prod_name)
# Parse the Secret Response & Decode Payload
sf_user_prod_secret = sf_user_prod_response.payload.data.decode('UTF-8')
sf_pass_prod_secret = sf_pass_prod_response.payload.data.decode('UTF-8')
sf_token_prod_secret = sf_token_prod_response.payload.data.decode('UTF-8')
# Assign Variables to Pass into Salesforce Login
sf_username = sf_user_prod_secret
sf_password = sf_pass_prod_secret
sf_token = sf_token_prod_secret
try:
# call salesforce Login
# return Session ID and Instance
session_id, instance = SalesforceLogin(
username = sf_username,
password = sf_password,
security_token = sf_token)
return session_id, instance
except Exception as error:
print('Login Error: ' + repr(error))
- 在 Requirements.txt 编辑器中放以下内容. 这将为Python添加对Requests, Simple Salesforce和Google Secret Manager的依赖关系的引用.
1
2
3
4
5
6
# Function dependencies, for example:
# package>=version
requests>=2.20.0
simple-salesforce>=0.74.2
google-cloud-logging==1.11.0
google-cloud-secret-manager==0.2.0
- 点击
Deploy等待部署结果.
设置运行时变量:
步骤 4. 测试
现在这个云功能已经创建完毕，现在可以测试创建一个新的联系人。在这个测试中，我们将模拟一个HTTP Post到这Cloud Function，使用包含联系人信息的标准JSON格式。
步骤:
- 选中刚才创建的Cloud Function:
-
在Function 页面, 点击
TESTINGtab
-
放入测试 JSON 数据, 点击
TESTING THE FUNCTION:
查看日志:
查看Salesforce List View:
