请参阅 Application Integration 支持的连接器。
连接器任务
连接器任务可让您使用 Integration Connectors 中提供的开箱即用连接器快速安全地连接到集成中的 Google Cloud 服务和其他业务应用。
如需查看应用集成的所有受支持的连接器列表,请参阅连接器参考文档。须知事项
- 确保您已在 Google Cloud 项目中授予 Connectors Admin (
roles/connectors.admin
) IAM 角色。如需了解如何授予角色,请参阅管理访问权限。 - 了解 Integration Connectors 的一般概念。
- 如需使用连接器连接到 Google Cloud 服务和其他业务应用,请确保您已将用户管理的服务账号关联到集成。如果您的集成未配置用户管理的服务账号,则默认情况下使用默认服务账号 (
service-PROJECT_NUMBER@gcp-sa-integrations.iam.gserviceaccount.com
) 进行身份验证。 - 确保您的服务账号具有所需的 IAM 角色。如需了解如何向服务账号授予角色,请参阅管理对服务账号的访问权限。
添加连接器任务
如需在集成中添加连接器任务,请执行以下操作:
- 在 Google Cloud 控制台中,前往 Application Integration 页面。
- 在导航菜单中,点击集成。
系统会显示集成页面,其中列出了 Google Cloud 项目中可用的所有集成。
- 选择现有集成,或点击创建集成以创建新的集成。
要创建新的集成,请执行以下操作:
- 在创建集成窗格中输入名称和说明。
- 为集成选择一个区域。
- 为集成选择服务账号。您随时可以在集成工具栏的 集成摘要窗格中更改或更新集成的服务账号详细信息。
- 点击创建。
系统随即会在集成编辑器中打开该集成。
- 在集成编辑器导航栏中,点击任务以查看可用任务和连接器的列表。
- 如果您想配置新连接,请点击连接器元素,并将其放置到集成编辑器中。然后,点击配置连接器以配置连接。
- 如果您已有现有连接,请点击连接器标签页,查看最近创建的连接。您还可以通过在搜索字段中输入名称来搜索连接器、连接或任务。
- 点击配置的连接器元素,并将其放置到集成编辑器中。如需了解如何配置连接器任务,请参阅配置连接器任务。
配置连接器任务
如需配置连接器任务,请执行以下操作:
- 点击设计器上的连接器任务元素,以查看连接器任务配置窗格。
(可选)点击
以重命名任务。 - 点击配置连接器。
- 您可以选择相应区域中的现有连接,也可以创建新连接。如需配置现有连接,请在连接器任务编辑器页面中完成以下步骤。
下图展示了连接器任务编辑器页面的示例布局。
- 在选择连接部分中,选择连接所在的区域。
- 从所选区域的可用连接列表中选择一个现有连接。
- 点击下一步。
- 从类型列表中,选择实体或操作。
- 如果您选择实体,则设置实体/操作部分会显示连接的受支持实体列表。选择一个实体,然后选择要对该实体执行的操作。
- 如果您选择操作,则设置实体/操作列中会显示连接支持的操作列表。为连接选择操作。 支持的实体和操作取决于连接器类型。如需查看 Application Integration 支持的所有连接器的列表,请参阅连接器参考。如需查看某个连接器支持的操作和实体,请参阅具体的连接器文档。
如果连接器支持自定义 SQL 查询,您可以从动作列表中选择执行自定义查询选项。如需了解如何为连接器添加自定义 SQL 查询,请参阅动作:执行自定义 SQL 查询。
- 点击完成以完成连接配置并关闭窗格。
配置任务输入和输出变量
连接器任务配置窗格会显示根据配置连接器任务对话框中选择的“实体和操作”或“操作”自动生成的任务输入和任务输出变量。这些变量可配置,并且可作为当前任务的输入或作为当前集成中的后续任务或条件的输出进行访问。
如需配置任务输入或任务输出变量,请点击相应变量以打开配置变量窗格并执行以下步骤:
- 在默认值字段中输入变量值。
- (可选)选择用作集成的输入或用作集成的输出。
- 点击保存。
如需详细了解连接器任务的输入和输出参数,请参阅实体操作。
实体操作和动作
您可以对连接器的实体执行 CRUD(创建、读取、更新、删除)操作。其中每个实体操作都有一组不同的输入和输出参数。下表列出了各种实体操作的输入和输出参数。
操作名称 | 输入参数 | 输出参数 |
---|---|---|
列出 |
|
|
获取 | entityId | connectorOutputPayload |
创建 | connectorInputPayload | connectorOutputPayload |
更新 |
|
connectorOutputPayload |
删除 |
|
不适用 |
输入参数
下表介绍了各种实体操作的输入参数。
参数名称 | 数据类型 | 说明 |
---|---|---|
entityId | 字符串 | 您要访问的行的唯一标识符。 通常, 例如,如需从 MySQL 表中获取特定行, |
connectorInputPayload | JSON | 要在实体中添加或更新的实际数据。以下示例展示了要添加到表中的行数据的 JSON 代码段:{ "employee_first_name": "John", "employee_emailID": "test-05@test.com" } 在此示例中, |
filterClause | 字符串 | 根据条件限制操作结果。如需详细了解如何添加过滤条件子句,请参阅为操作添加过滤条件。 |
listEntitiesPageSize | 整数 |
指定页面中应返回的结果数。 页面是结果集中记录的逻辑分组。如果您希望结果集中包含大量记录,则页面的概念非常有用。如果结果集很大,则连接器任务可能会失败,因为连接器任务可以处理的数据大小存在限制。您可以通过将结果集细分为较小的数据块来避免此问题。 例如,如果您希望结果集中有 1000 条记录,则可以将 |
listEntitiesPageToken | 字符串 | 用于访问特定页面的页面标识符(令牌)。 您可以从 |
listEntitiesSortByColumns | 字符串数组 | 作为结果集排序依据的列名称。
|
输出参数
下表介绍了各种实体操作的输出参数。
参数名称 | 数据类型 | 说明 |
---|---|---|
connectorOutputPayload | JSON | 操作的输出(采用 JSON 格式)。 |
listEntitiesNextPageToken | 字符串 |
系统为页面生成的标识符。您可以将令牌视为可通过其访问结果集特定页面的指针。 如果您已通过设置 例如,假设您将 如果结果集中包含大量网页,您可以考虑使用
while Loop 任务
找到下一页并使用数据映射
自动将页面标记值分配给
|
实体操作的过滤条件子句
您可以使用可用作任务输入的过滤条件子句变量来限制连接器任务处理的记录。例如,对于删除操作,您可以添加过滤条件子句以删除具有特定 orderId
的记录。
过滤条件子句只能应用于以下实体操作:
- 列出
- 删除
- 更新
选择上述任何操作时,连接器任务的任务输入部分都会自动显示 Filter clause(过滤条件子句)字段。
添加过滤条件子句
如需添加过滤条件子句,请执行以下步骤:
- 点击设计器上的连接器任务元素,以查看连接器任务配置窗格。
- 展开任务输入部分,然后点击 filterClause(Connectors) 字符串变量。
随即会出现配置变量对话框。
- 在默认值字段中输入过滤条件子句(在子句语法后面)。
- 点击保存。
过滤条件子句语法和示例
过滤条件子句采用以下格式:
FIELD_NAME CONDITION FILTER_VALUE
示例
OwnerId = '0053t000007941XAAQ'
PoNumber < 2345
OrderNumber = 00110 AND StatusCode = 'Draft'
TotalAmount > 2500
ShippingPostalCode = 94043 OR ShippingPostalCode = 77002
在过滤条件子句中使用变量
您不能在过滤条件子句中直接使用集成变量。如果要使用集成变量,您必须先配置数据映射任务,以在集成变量和过滤条件子句之间创建映射。下表显示了集成变量与 filterClause(Connectors)
变量之间的映射示例:
输入 | 输出 |
---|---|
PRIMARY_KEY_ID = ' .CONCAT(INTEGRATION_VARIABLE) .CONCAT(') |
filterClause(Connectors) |
PRIMARY_KEY_ID = '
作为输入行中的值。
动作:执行自定义 SQL 查询
如需创建自定义查询,请按照下列步骤操作:
- 按照详细说明添加连接器任务。
- 配置连接器任务时,在要执行的动作类型中选择动作。
- 在动作列表中,选择执行自定义查询,然后点击完成。
- 展开任务输入部分,然后执行以下操作:
- 在在以下时间后超时字段中,输入查询执行前要等待的秒数。
默认值:
180
秒。 - 在最大行数字段中,输入要从数据库返回的最大行数。
默认值:
25
。 - 要更新自定义查询,请点击修改自定义脚本。系统随即会打开脚本编辑器对话框。
- 在脚本编辑器对话框中,输入 SQL 查询,然后点击保存。
您可以在 SQL 语句中使用问号 (?) 表示必须在查询参数列表中指定的单个参数。例如,以下 SQL 查询会从
Employees
表中选择与为LastName
列指定的值匹配的所有行:SELECT * FROM Employees where LastName=?
- 如果您在 SQL 查询中使用了问号,则必须点击 + 添加参数名称,针对每个问号添加参数。执行集成时,这些参数按顺序替换 SQL 查询中的问号 (?)。例如,如果您添加了三个问号 (?),那么必须按顺序添加三个参数。
如需添加查询参数,请执行以下操作:
- 从类型列表中,选择参数的数据类型。
- 在值字段中,输入参数的值。
- 要添加多个参数,请点击 + 添加查询参数。
- 在在以下时间后超时字段中,输入查询执行前要等待的秒数。
架构刷新
所有实体和动作都具有与之关联的架构。例如,动作架构将包含参数详细信息,例如:参数名称及其相应的数据类型。实体和操作的架构(元数据)由连接在运行时从后端提取。如果架构有任何更新,此类更新不会自动反映在现有连接中;您必须手动刷新架构。如需在现有连接器任务中查看更新后的架构,请按照以下步骤操作:- 在 Integration Connectors 中,打开连接的连接详情页面,然后点击刷新连接架构。
- 在应用集成中,您必须为同一连接重新配置现有连接器任务。
内嵌连接创建
您可以使用连接器任务直接在 Integration Connectors 中创建新连接。
须知事项
新建连接
如需从 Application Integration 创建新连接,请执行以下步骤:
- 点击设计器上的连接器任务元素,以查看连接器任务配置窗格。
- 点击配置连接器。
系统会显示连接器任务编辑器页面。
- 跳过区域字段。
- 点击连接,然后从下拉菜单中选择创建连接选项。
- 在创建连接窗格中完成以下步骤:
- 在位置步骤中,选择连接的位置。
- 点击区域,然后从下拉列表中选择一个位置。
- 点击下一步。
- 在连接详情步骤中,提供有关连接的详细信息:
- 连接器:从下拉列表中选择要创建的连接器的类型。如需了解受支持的连接器列表,请参阅所有 Integration Connectors。
- 连接器版本:从下拉列表中选择所选连接器类型的可用版本。
- 连接名称:输入连接实例的名称。
- (可选)输入连接实例的说明。
- (可选)选中启用 Cloud Logging 以存储连接实例的日志数据。
- 服务账号:选择具有所需角色的服务账号。
- (可选)点击高级设置以配置连接节点设置。
如需了解详情,请参阅 Integration Connectors 中的相应连接文档。
- (可选)点击 + 添加标签,以键值对的形式向连接添加标签。
- 点击下一步。
-
在身份验证步骤中,提供连接的身份验证详细信息。
- 在此步骤中填充的身份验证方法基于所创建的连接类型。
不同的连接类型使用不同的身份验证方法。如需了解详情,请参阅 Integration Connectors 中相应连接文档的配置身份验证部分。
- 点击下一步。
- 在此步骤中填充的身份验证方法基于所创建的连接类型。
- 查看:查看您的连接和身份验证详细信息。
- 点击创建。
- 在位置步骤中,选择连接的位置。
最佳做法
- 如需了解适用于连接器任务的用量限额,请参阅用量限额。
- 如需了解如何对失败的连接器任务进行问题排查,请参阅使用日志排查和跟踪连接器故障。
错误处理策略
任务的错误处理策略指定当任务因暂时性错误而失败时要执行的操作。如需了解如何使用错误处理策略,以及了解不同类型的错误处理策略,请参阅错误处理策略。
价格
Cloud Pub/Sub 触发器和 Salesforce 触发器不需要您创建连接器。不过,如果您使用连接器任务连接到 Pub/Sub 或 Salesforce,则需要为连接器使用付费。如需了解价格,请参阅 Application Integration 价格。
配额和限制
如需了解配额和限制,请参阅配额和限制。