简介
Table 组件是一个由腾讯云数据连接器提供存储的内置表结构组件，提供基于Table的增删改查等操作，仅用于操作 RecordSet。
一般情况前一个节点为 RecordSet Encoder，将数据封装成 RecordSet，通过 Table 组件实现数据的查询、插入、合并、删除、比对等。使用 Table 组件时选择合适的操作 > 配置连接 > 配置操作。
连接配置
选择通用存储中创建的表名，此表为操作的目标表。
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
表名 | string | 表名 | 是 | - |
操作说明
Table 组件包含插入、查询、合并、删除、比对操作。
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
过滤条件 | list | 查询过滤条件 | 是 | - |
输出字段 | list | 选择要输出的字段 | 是 | - |
分区数 | int | 分数数量 | 是 | - |
开启缓存 | bool | 对输出 RecordSet 是否缓存 | 是 | - |
查询界面如下：
输出
组件输出的 message 信息如下：
message 属性 | 值 |
payload | 执行成功后，payload 为查询到的数据集构成的 RecordSet；执行失败后，payload 为空 |
error | 执行成功后，error 为空；执行失败后，error 为 dict 类型，包含“Code”和“Description”元素：“Code”表示错误类型，“Description”表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
案例
1. 新建连接器或选择已创建的连接器。
2. 配置过滤条件、输出字段等信息。
3. 执行操作，输出结果如下：
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
忽略错误 | bool | 忽略插入错误 | 否 | true |
输入数据集 | RecordSet 类型 | 输入数据集，若未填写，默认为 message 的 payload | 是 | - |
字段校准 | list | 对输入数据集进行字段校准 | 否 | - |
字段映射 | enum | 字段映射，数据表字段和 RecordSet 类型数据字段的映射，插入数据表字段的值为 RecordSet 类型数据字段的值 | 是 | - |
默认插入界面如下：
说明
如果前一个节点输出 RecordSet，Table 将自动感知数据结构，并将来源字段与目标表字段根据同名映射自动进行映射。
在字段映射后方有 schema 维护按钮，可单击查看、管理输入的 schema 在 schema 维护面板中可进行手工维护 schema 的字段信息，当前一节点输出的 schema 发生了调整，可在 schema 手工刷新与前一节点输出的 schema 保持一致，同时将根据同步映射原则进行重新映射（将覆盖上次的映射）。
输出
组件输出的 message 信息如下：
message 属性 | 值 |
payload | 执行成功后，payload 为上一个组件的 payload；执行失败后，payload 为空 |
error | 执行成功后，error 为空；执行失败后，error 为 dict 类型，包含“Code”和“Description”元素：“Code”表示错误类型，“Description”表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
案例
1. 新建连接器或选择已创建的连接器。
2. 配置字段映射等信息。
3. 执行操作，如果成功，则输出 payload 为上一个组件的 payload。
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
只执行插入 | bool | 数据不存在时执行插入操作 | 是 | false |
只执行更新 | bool | 数据存在时执行更新操作 | 是 | false |
忽略错误 | bool | 忽略插入错误 | 否 | true |
输入数据集 | RecordSet类型 | 输入数据集，若未填写，默认为 message 的 payload | 是 | - |
字段校准 | list | 对输入数据集进行字段校准 | 否 | - |
过滤条件 | list | 合并的过滤条件 | 是 | - |
字段映射 | enum | 字段映射，数据表字段和 RecordSet 类型数据字段的映射，插入数据表字段的值为 RecordSet 类型数据字段的值 | 是 | - |
输出
组件输出的 message 信息如下：
message 属性 | 值 |
payload | 执行成功后，payload 为上一个组件的 payload；执行失败后，payload 为空 |
error | 执行成功后，error 为空；执行失败后，error 为 dict 类型，包含“Code”和“Description”元素：“Code”表示错误类型，“Description”表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
案例
1. 新建连接器或选择已创建的连接器。
2. 设置输入数据集，默认为return msg.payload。
3. 配置过滤条件，字段映射等信息。
4. 执行操作，如果成功，则输出 payload 为上一个组件的 payload。
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
输入数据集 | RecordSet 类型 | 输入数据集，若未填写，默认为 message 的 payload | 是 | - |
字段校准 | list | 对输入数据集进行字段校准 | 否 | - |
过滤条件 | list | 删除的过滤条件 | 是 | - |
输出
组件输出的 message 信息如下：
message 属性 | 值 |
payload | 执行成功后，payload 为上一个组件的 payload；执行失败后，payload 为空 |
error | 执行成功后，error 为空；执行失败后，error 为dict类型，包含“Code”和“Description”元素：“Code”表示错误类型，“Description”表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
案例
1. 新建连接器或选择已创建的连接器。
2. 配置删除逻辑等信息。
3. 执行操作，如果成功，则输出 payload 为上一个组件的payload。
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
输入数据集 | RecordSet 类型 | 输入数据集，若未填写，默认为 message 的 payload | 是 | - |
字段校准 | list | 对输入数据集进行字段校准 | 否 | - |
输入模式 | enum | 全量、增量 | 是 | - |
主键配置 | list | 计算时主键的映射关系 | 是 | - |
比对字段 | list | 计算时需要根据主健是否相等 | 是 | - |
开启缓存 | bool | 对输出 RecordSet 是否缓存 | 是 | - |
输出
组件输出的 message 信息如下：
message 属性 | 值 |
payload | 执行成功后，payload 为计算差值后生成的 RecordSet；执行失败后，payload 为空 |
error | 执行成功后，error 为空；执行失败后，error 为 dict 类型，包含“Code”和“Description”元素：“Code”表示错误类型，“Description”表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
输出 RecordSet 中 op_type 字段取值为 Add、Modify、Deleted，分别表示新增、修改、删除。
案例
1. 新建连接器或选择已创建的连接器。
2. 配置输入模式、主键配置、比对字段等信息。
3. 执行操作，输出如下：
