数据流启动方案介绍
变更记录
产品版本 | 更新内容 | 更新日期 |
V6.0.000 | 初始版本 | 2023年08月23日 |
V6.0.2 | 增加数据流调试功能 | 2023年10月30日 |
1 简介
1.1 功能介绍
数据流需要通过配置启动方案来触发的。目前支持了人工启动、定时启动、单据事件、MQ订阅和API触发这5种启动方式,由数据流中包含的事件模型决定。
1.2 应用场景
通过在启动方案中为数据流绑定连接器,实现数据流的实际执行。针对同一个数据流可以绑定不同的连接器,从而实现数据流执行层的复用。
1.3 系统路径
【集成服务云】→【数据流】→【运行管理】 →【启动方案】
1.4 关键字段/按钮说明
关键字段说明
字段名称 | 详细解释 |
数据流 | 此处展示的数据流将以启动事件中数据提供者上配置的数据模型作为过滤条件,只能选择第一个节点配置相同数据模型的数据流。 |
启动事件 | 由数据流中第一个节点的事件模型决定。 |
名称 | 启动方案名称,可编辑 |
编码 | 启动方案编码,填写名称后自动生成,可编辑 |
最大线程数 | 默认不启用多线程;如果指定,则最多启用指定数目的线程执行该数据流以减少总时长。 |
工作区大小 | 运行期内存中允许容纳的最大数据量,单位:数据行。该值建议取 最大线程数 * 批处理大小。当单行数据量较大时,该值应该设置得较小以降低系统OOM的风险。 |
日志级别 | 控制流程执行过程中日志输出的多少 |
单据状态 | 当前启动方案的状态,启用/禁用 |
当前版本号 | 此处显示最新修改的启动方案版本号。启动方案支持查看历史版本 |
关键按钮说明
按钮名称 | 详细解释 |
立即执行 | 支持通过立即执行触发启动,根据启动事件,有时需要输入必要的参数进行执行 |
数据流实例 | 启动方案执行结果 |
导入/导出方案 | 支持方案导入/导出 |
历史版本 | 支持查看历史版本 |
引用资源 | 查看当前启动方案所有依赖资源以及引用关系 |
2 主要操作
2.1 新增数据流启动方案
操作步骤
步骤1: 选择数据流
在数据流启动方案列表中点击“新增”按钮,进入启动方案表单页。选择数据流后,自动填入该数据流对应的启动事件;
步骤2: 填写必要的名称、编码和备注信息
步骤3: 设置启动方案的控制参数
最大线程数:默认不启用多线程;如果指定,则最多启用指定数目的线程执行该数据流以减少总时长。
工作区大小:运行期内存中允许容纳的最大数据量,单位:数据行。该值建议取 最大线程数 * 批处理大小。当单行数据量较大时,该值应该设置得较小以降低系统OOM的风险。
日志级别:控制流程执行过程中日志输出的多少
检查点(秒):指定运行时上下文环境定期保存到数据库的时间间隔。
失败重试次数:执行失败时的最大重试次数,不配置取默认值,默认最大重试次数为3,配置为0时则表示不需要重试。
重试间隔(分钟):输入分钟数,如果需要分别指定各次重试的延时,使用逗号分隔。例如:5,15,30
后台任务锁:
本地锁 : 应用于所有节点,控制各节点上该类任务的最大并发数
全局锁 : 应用于所有节点,控制全体节点上该类任务的最大并发数
失败时通知:启动方案执行失败时,发送通知,通知内容在“通知发送”组件中定义
完成时通知:启动方案执行成功时,发送通知,通知内容在“通知发送”组件中定义
步骤4:参数绑定
给参数列表中对应参数进行赋值,从而实现数据过滤。
注意:此处参数来源于数据流启动节点中数据查询组件的查询条件参数。
步骤5: 绑定连接器
在连接器绑定列表中,给数据流涉及的来源系统、目标系统等绑定实际的连接器。连接器简介
步骤6: 启用启动方案
保存启动方案后,需在列表页启用该启动方案,方可生效。
2.2 数据流调试
步骤1:选中想要调试的启动方案,在‘立即执行’的下拉按钮中点击‘节点调试’。
注:指令调试不推荐用户进行使用。
步骤2:在表达式求值中输入#vars,并点击按钮,可以在输出控制台打印该数据流使用的所有数据模型。
步骤3:点击左侧侧边栏,可以在对应数据流图的不同节点处打断点。点击‘继续执行’将运行到下个断点,此时可以在表达式求值中查看步骤2中打印的数据模型所存储的信息。
数据流启动方案介绍
本文2024-09-23 00:53:28发表“云苍穹知识”栏目。
本文链接:https://wenku.my7c.com/article/kingdee-cangqiong-142406.html