全部文档
文档中心流程流程编辑控件

控件

流程组件的控件是实现数据处理及其它应用的基本要素,各类功能控件持续开发中。

.. csv-table:: 控件清单 :header: 序号, 控件名称, 英文名称, 功能类型, 支持入参, 支持输入,支持输出, 描述 :widths: auto

1, 读取表, Table Input, 抽取类, Y, N, Y, 从数据表中获取数据生产消息 2, 合并联接, Merge Join, 处理类, N, Y, Y, 将两个数据记录通过关联列联接成一个记录 3, 分组聚合, Group By, 处理类, N, Y, Y, 按照指定列聚合数据,聚合前确保数据已指定列排序 4, 添加常量列, Add Constants, 处理类, N, Y, Y, 在数据列中新增值为常量的列 5, 字段选择, Select Field, 处理类,N, Y, Y, 在数据列中选择指定列生成新数据 6, 数据排序, Sort Rows, 处理类,N, Y, Y, 基于字段值将数据排序 7, 数据去重, Unique Rows, 处理类,N, Y, Y, 按指定列去除数据重复行 8, 公式, Formula, 处理类,N, Y, Y, 编写方程式计算列值 9, 写入表, Table Output, 存储类, N, Y, N, 将消息内的数据写入数据表中 10, 更新表, Update Table, 存储类, N, Y, N, 关联数据集,并指定条件更新库表数据 11, Python, Python Script, 综合类, Y, N, Y, Python 组件提供支持 12, Http, HTTP Client, 综合类, Y, N, N, 提供 POST/GET 13, RESTClient, REST Client, 综合类,Y, Y, Y, REST客户端 14, 发送邮件, Send Email, 综合类, Y, N, N, 通过平台或自定义邮件服务器发送指定内容的邮件 15, 判断, Conditions, 逻辑类, N, N, N, 仅对前置节点执行状态(成功/失败)进行逻辑分支处理 16, 读取JSON, Json Input, 抽取类, N, Y, Y, 读取JSON结构化内容并输出数据行 17, 读取数据表, DTEDatadoRead, 抽取类, Y, N, Y, 从平台表元素中读取数据 18, 写入数据表, DTEDatadoWrite, 存储类, Y, Y, N, 将数据写入平台表元素 19, 清除数据表, DTEDatadoDelete, 存储类, Y, Y, N, 依照条件删除平台表元素的数据 20, 更新数据表, DTEDatadoUpdate, 存储类, Y, Y, N, 依照条件更新平台表元素的数据 21, 清除表, TableClear, 存储类, Y, Y, N, 依照条件删除数据库表的数据

各控件拖入画布生成节点后,可编辑相应动作页配置。

画布中的节点,点击悬浮的 设置 按钮,将弹出 动作 属性配置框,包含 基本信息执行信息基本信息所有节点配置都固定如下:

  • 基本信息

    • 编码:默认值由系统生成,用户可在初始化时修改自定义编码。该编码作为 elementName,在流程元素中需保持唯一,只支持字母、数字、下划线,必填,其它限制参照元素名称规则。

    • 名称:各语言的名称即描述,优先显示在对应节点(控件)内,可空。

    • 类型:显示节点的对应类型,固定值,不可编辑。

    • 超时时间:节点在限定时间内执行,超时将停止后续节点的执行。

下面介绍每个控件的 执行信息

读取表控件是从指数据库中的表将数据读取出来并写入消息队列,当前支持 Mysql 数据库,后续迭代将会支持 Clickhouse 数据库。

  • 执行信息

    • 数据源:从数据源列表选择一个数据源,必选。

    • SELECT:Query SQL 中,SELECT 关键字后列举的字段名,支持别名,建议不使用 * 号,必填。

    • FROM:Query SQL 中,FROM 关键字跟随的表名称,如有 JOIN 相关的表名,可一并按照 SQL 格式填入,必填。

    • WHERE:Query SQL 中,WHERE 关键字后的查询条件部分,选填。

    • GROUP BY:Query SQL 中的聚合部分填入,如无留空,选填。

    • ORDER BY:Query SQL 中排序部分填入,如无留空,选填。

    • SQL 预览:将上述 SQL 片段拼成完整的 SQL 以供预览。

    • 数据预览:将完整 SQL 执行查询,展示 10 条数据,不支持应用流程参数预览。

    • 应用流程参数:SQL 语句中部分名称使用参数值替代时,需要选择启用。


读取JSON控件负责将符合JSON格式的数据解析提取成指定列信息数据,当前需配合接口插件或其他数据处理插件使用,衔接的数据集应当包含一个值为JSON数组格式的字符串字段,该字段是插件的处理核心。

  • 执行信息

    • 获取源字段:从前序输出字段列表选择一个数据源,必选。

    • 输出字段:编辑表格,填入需要从JSON内容中需要解析出来的key的字段名及格式。

      • 序号:行号。

      • 字段名称:需要从JSON数组种解析提取数据的字段名称,必填。

      • 路径:字段key在JSON中的路径位置,参考JSON path表达式。

      • 类型:字段预设的值类型,非强制转换,选填。

      • 去除空字符方式:提取字段去除值内的空字符处理方式,默认值不去除。


对指定平台表元素的数据查询,支持Mysql表元素和Clickhouse表元素,仅限单表查询。

  • 执行信息

    • 数据表类型:Mysql、Clickhouse(当前仅支持这2种),必选,默认值为Mysql。

    • 选择数据表:元素选择框,元素类型为数据表,单选。

    • 选择字段:自动加载选中的数据表的所有字段,选择后作为取数字段,可多选。

    • 查询条件:Query SQL 中,WHERE 关键字后的查询条件部分,选填。

    • 数据预览:根据已编辑的配置查询,展示 10 条数据,不支持应用流程参数预览。

    • 应用流程参数:查询条件中部分名称使用参数值替代时,需要选择启用。


合并联接组件是将两个数据记录通过关联列联接成一个记录,需要在这个控件之前联接两个可以输出数据的控件。

  • 执行信息

    • 主节点:下拉选择在此控件之前的节点数据,作为其中一个数据源。

    • 次节点:下拉选择在此控件之前的节点数据,作为另一个数据源。

    • 关联方式:下拉选择关联方式,关联方式分为 left joinright joininner joinfull join,使用方式,具体区别如下所示。

    • 关联条件列:选择主节点和次节点关联字段,关联条件为两列值相等。

分组聚合控件是按照指定列聚合数据,聚合前确保数据已指定列排序。

  • 执行信息

    • 构成分组的字段:输入构成分组的字段,至少填一个。

    • 聚合:输入聚合名称、聚合字段、下拉选择聚合类型。

      • 聚合名称:字段进行聚合后的字段重命名

      • 聚合字段:需要进行聚合的字段

      • 聚合类型:sumaveragemedianpercentileminmaxcount

添加常量列控件是在数据列中新增值为常量的列。

  • 执行信息

    • 添加字段:手工输入字段名称,下拉选择字段类型、格式、值、长度、精度、设为空串。

    • 手工点击新增数据可以新增更多数据行。

字段选择控件是在数据列中选择指定列生成新数据

  • 执行信息

    • 选择字段:手工输入字段名称、修改名称、长度、精度。

    • 手工点击新增数据可以新增更多数据行。

数据排序控件是基于字段值将数据排序。

  • 执行信息

    • 排序字段:编辑数据排序的规则。

      • 字段名称:排序的字段名称

      • 升序:是否按升序进行排序,是则升序,否则降序

      • 忽略大小写:排序是否忽略大小写因素

数据去重控件是按指定列去除数据重复行,去重前确保数据已按去重的字段进行了排序。

  • 执行信息

    • 比较字段:指定字段进行去重处理,结果仅保留所选择字段且去重后的数据,不输入任何字段时默认比较所有字段。

      • 字段名称:去重比较的字段

      • 忽略大小写:去重时是否忽略大小写因素

使用流内数据字段编辑公式进行数据计算,可生成新字段,也可以将生成的值覆盖原有字段。

  • 执行信息

    • 增加字段:编写公式进行计算,生成新字段或覆盖原有字段值。

      • 新增字段:计算产生的数据定义新字段名称

      • 方程表达式:利用公式库内的公式按照规则编写计算公式,公式可单用,也可组合使用,数据可用常量,也可使用流内的数据字段。

      • 类型:生成新值的数据类型。

      • 替换值字段:新值需要覆盖原有的字段名称,可为空,不为空时生效优先替换方式,为空时生效新增字段。

写入表 对应 读取表写入表 将消息中的数据存储到数据库的表中,当前支持 Mysql、Clickhouse 两类数据库。


  • 执行信息

    • 数据源:从左侧获取的数据源列表选择一个编辑完成的数据源,必选。

    • 目标模式:在不同类型的数据库中代表不同信息,Mysql/Clickhouse-数据库名称,SQLServer-Schema,Oracle-SID,必填。

    • 目标表:数据需要存入的数据表名称,必填。

    • 写入前清空表:数据写入前,是否需要将目标表的数据进行清空,使用TRUNCATE操作。

    • 表字段映射:对源数据的字段名与目标表的字段名进行一一匹配对应,必填。

      • 序号:行号。

      • 源字段:来源数据中的字段名称。

      • 目标字段:存储表中的字段名称。

      • 操作:删除行。

      • 新增数据:新增字段映射行。

使用流内数据集进行目标表的数据更新,仅限关联更新,关联值及更新值都只能使用流内的字段名称。

  • 执行信息

    • 数据源:从左侧获取的数据源列表选择一个编辑完成的数据源,必选。

    • 目标模式:在不同类型的数据库中代表不同信息,Mysql/Clickhouse-数据库名称,SQLServer-Schema,Oracle-SID,必填。

    • 目标表:数据需要存入的数据表名称,必填。

    • 用来查询值的条件字段:与流内数据集进行关联的条件。

      • 表字段:输入目标表的字段名称。

      • 比较符:关联条件的类型,包括=、<>、>=、>、<=、<、LIKE、BETWEEN、IS NULL、IS NOT NULL。

      • 关联表字段:关联流内数据集的字段名称。

    • 更新字段:对目标表数据进行更新,值更新条件仅支持等于。

      • 表字段:输入目标表的字段名称。

      • 关联表字段:关联流内数据集的字段名称。


对指定数据库表,按照删除条件进行数据删除。支持无依赖删除(不依赖于流程中的数据集)和依赖删除(依赖流程中前置节点提供的数据集进行关联删除)。

  • 执行信息

    • 数据源:从左侧获取的数据源列表选择一个编辑完成的数据源,必选。

    • 目标模式:在不同类型的数据库中代表不同信息,Mysql/Clickhouse-数据库名称,SQLServer-Schema,Oracle-SID,必填。

    • 目标表:数据需要存入的数据表名称,必填。

    • 关联删除:选择是否依赖前序数据集进行条件关联删除,默认不关联。

    • 删除条件:与流内数据集进行关联的条件。

      • 字段名称:目标表的字段名称。

      • 关联类型:关联条件类型,包括=、<>、>=、>、<=、<、LIKE、BETWEEN、IS NULL、IS NOT NULL。

      • 条件值:关联流内数据集的字段名称。

      • 条件值2:关联流内数据集的字段名称,仅限当关联类型为BETWEEN时有效。

      • 是否常量:条件值和条件值2两列的内容是否为常量。

      • 操作:删除行。

      • 新增数据:新增删除条件行。

    • 应用流程参数:查询条件中部分名称使用参数值替代时,需要选择启用。


将指定数据集写入平台表元素内,支持Mysql表元素和Clickhouse表元素。

  • 执行信息

    • 数据表类型:Mysql、Clickhouse(当前仅支持这2种),必选,默认值为Mysql。

    • 选择数据表:元素选择框,元素类型为数据表,单选。

    • 写入前清空:在数据写入目标元素前,将表元素的数据清空,当前不可用。

    • 表字段映射:写入数据集列与数据表元素字段的对应关系。

      • 序号:行号。

      • 源字段:来源数据中的字段名称。

      • 目标字段:存储表中的字段名称。

      • 操作:删除行。

      • 新增数据:新增字段映射行。


对指定数据表元素,按照关联条件进行数据更新。支持无依赖更新除(不依赖于流程中的数据集)和依赖更新依赖流程中前置节点提供的数据集进行关联更新)。

  • 执行信息

    • 数据表类型:Mysql、Clickhouse(当前仅支持这2种),必选,默认值为Mysql。

    • 选择数据表:元素选择框,元素类型为数据表,单选。

    • 更新:对目标数据表进行更新,以更新值赋值给数据表字段。

      • 数据表字段:数据表的字段名称。

      • 更新值:流内数据集的字段名称或常量值(包含流程参数值)。

      • 是否常量:更新值是否为常量,选择流内数据集字段时不为常量。

      • 操作:删除行。

      • 新增数据:新增更新行。

    • 是否关联:选择是否依赖前序数据集进行条件关联更新,默认不关联。

    • 更新条件:对目标数据表进行更新,编辑需要更新的过滤条件项。

      • 数据表字段:数据表的字段名称。

      • 关联类型:关联条件类型,包括=、<>、>=、>、<=、<、LIKE、BETWEEN、IS NULL、IS NOT NULL。

      • 条件值:关联流内数据集的字段名称。

      • 条件值2:关联流内数据集的字段名称,仅限当关联类型为BETWEEN时有效。

      • 是否常量:条件值和条件值2两列的内容是否为常量,选择流内数据集字段时不为常量。

      • 操作:删除行。

      • 新增数据:新增更新条件行。

    • 应用流程参数:查询条件中部分名称使用参数值替代时,需要选择启用。


对指定数据表元素,按照删除条件进行数据删除。支持无依赖删除(不依赖于流程中的数据集)和依赖删除(依赖流程中前置节点提供的数据集进行关联删除)。

  • 执行信息

    • 数据表类型:Mysql、Clickhouse(当前仅支持这2种),必选,默认值为Mysql。

    • 选择数据表:元素选择框,元素类型为数据表,单选。

    • 关联删除:选择是否依赖前序数据集进行条件关联删除,默认不关联。

    • 删除条件:与流内数据集进行关联的条件。

      • 数据表字段:数据表的字段名称。

      • 关联类型:关联条件类型,包括=、<>、>=、>、<=、<、LIKE、BETWEEN、IS NULL、IS NOT NULL。

      • 条件值:关联流内数据集的字段名称。

      • 条件值2:关联流内数据集的字段名称,仅限当关联类型为BETWEEN时有效。

      • 是否常量:条件值和条件值2两列的内容是否为常量。

      • 操作:删除行。

      • 新增数据:新增删除条件行。

    • 应用流程参数:查询条件中部分名称使用参数值替代时,需要选择启用。


Python 控件提供自定义 Python 元素的执行调度功能,集成 PythonWeb 服务调用 API。


  • 执行信息

    • 关联元素:控件绑定的 Python 元素,单击选择元素弹出元素选择窗,必选。

    • 路径:绑定 Python 元素的路径,初始化为绝对路径,流程元素在保存完生成流程的路径后,可自由切换相对路径或绝对路径。

    • 参数名称:传值 python 元素内的参数名称,参数将在 python 标准参数 d_para2 中(关于Python的标准参数请参考 Python组件),必填。

    • 描述:参数的含义说明,可空。

    • 赋值方式默认值流程参数 两种方式,必选。

    • 参数值:当赋值方式选择 默认值 时,需输入自定义值,运行流程过程中不可修改;赋值方式为 流程参数 时,选择绑定当前流程中设置完成的流程参数,并在执行中将该参数的实际值传入 python 元素中。

HTTP 控件用于大部分 HTTP 请求的实现,实现 GET 和 POST 方法,内容类型支持 json 和 form 表单提交。


  • 执行信息

    • 请求路径:请求的接口 URL,必填。

    • 请求方式GETPOST,必选。

    • 内容类型Content-Type:application/jsonapplication/x-www-form-urlencoded,必选。

    • 请求参数:长文本框填入 JSON 格式的文本内容,解析成对应参数,如需使用流程参数,以 $$参数名称 格式应用。Body 类型的内容不做拆分解析,配置中只保留一个完整的 BODY 类型的参数。多次解析会自动替换当前 参数名+类型 均相同的参数。

      • 类型:文本或参数在 Http 中请求参数类型,HeadersBody,或 Parameter

      • 解析:点击解析长文本框内容,解析前将做一次 JSON 格式校验,校验不通过时提示格式不符,通过后将内容自动填充到下方参数表单内。

    • 参数表单:请求所需的所有入参内容,包括HeadersBody,或 Parameter

      • 参数名称:请求参数名称,Body 参数只显示完整 Body 内容,参数名称显示为 Body。

      • 类型HeadersBody,或 Parameter

      • 赋值方式自定义流程参数,值根据选择框决定赋值方式,均必填。

在流程执行中向指定用户发送邮件,可使用平台系统邮箱推送,也可以自行配置邮件服务器指定发件邮箱进行发送,邮件主题和内容均可自定义,邮件内容支持HTML格式的文本。


  • 执行信息

    • 收件人:填入收件人邮箱,多个收件人时用英文符号’;’隔开。

    • 发送方式:邮件的发送方式,针对邮件服务器的选择,平台发送即选择平台已配置的邮件服务器进行邮件发送;自定义则是自行配置邮件服务器,用配置的服务器来完成邮件发送。

    • 邮件主题:发送邮件的标题内容,不填时标题默认显示’无主题’。

    • 邮件正文:邮件的正文内容,支持HTML文本格式,右下方按钮可以预览转义后的正文内容。

    • 应用流程参数:配置项中是否有应用流程参数来实现值动态获取的设置,如应用则执行时会将配置的流程参数(带$$标识的字符)进行值替换。

    • SMTP服务器:配置邮件服务器的地址。

    • 端口号:邮件服务器的端口号。

    • 用户名:邮件服务器的访问用户名。

    • 密码:邮件服务器访问密码。

    • 安全链接类型:邮件服务器的安全链接类型,不使用、SSL、TLS。

    • 发件邮箱:配置邮件发送人邮箱账号。

    • 抄送人:邮件的抄送人。

一个用REST模式的API工具,支持GET、POST请求,除URL外其它配置项需要从前序节点的数据中传值,并且可根据前序节点的数据行数,进行多次接口访问。


  • 执行信息

    • 请求路径:接口的URL,自行填写。

    • 请求方式:接口的请求方式,GET、POST。

    • Body字段:POST方式下的BODY内容,填入前序节点传值数据的字段名称。

    • 内容类型:POST方式下内容格式,FORM YRLENCODED、JSON、TEXT PLAN、XML。

    • Headers:请求Headers中的参数配置,填入参数名称,和前序节点传值数据的字段名称。

    • Parameters:POST方式下的参数配置,填入参数名称,和前序节点传值数据的字段名称。

    • 响应状态码:接口返回内容中的code部分,重定义code字段名称,后续节点可使用该名称获取code对应的值。

    • 响应正文字段名:接口返回内中的data部分,重定义data字段名称,后续节点可使用该名称获取data对应的内容。

判断控件作为流程中逻辑执行分支的节点,可根据多个前置节点的执行状态设定后续分支的执行。


  • 执行信息

    • 判断条件:选择前置节点以及执行状态,作为条件,多个节点可以组合多种条件。

      • 示例图中条件含义——两个前置节点 都执行成功 作为判断条件,如果满足条件,则执行连线为 的分支,否则,执行连线为 的分支。

      • 单击判断节点后置连线,弹出连线的条件属性。

回到顶部

咨询热线

400-821-9199

我们使用 ChatGPT,基于文档中心的内容以及对话上下文回答您的问题。

ctrl+Enter to send