操作说明
定时发布场景,搭建步骤如下:
- 建立发布节点为增量导出模式
- 根据设置增加需要发布的SQL语句,每个SQL导出的结果,定义为增量那个导出的结果
- 设置计划任务,确定执行SQL语句的轮训时间,可以支持某个时间点,或者某个时间段来执行,最低粒度精确到秒级别。
操作步骤
建立发布客户端【支持实时模式,但是导出增量数据按照where条件导出规则】
定时发送,订阅客户端,实时发送数据类型,需要设置参数
data_migrate_mode=0 ##设置为1时,全量发布时使用迁移模式,不受刷新标志和增量状态的影响,默认为0
real_export_by_where=1 ##设置为1时,实时发布时采用定时导出的模式,默认0,为实时分析日志模式发布节点
发布管理-发布-定时管理
定时支持以下几种功能:
全量数据/定制SQL定时执行
状态获取方式 修改 exec_sql_before/exec_sql_after 定时调度前后涉及到字段
描述:根据某个状态允许查询,例如0,1位业务操作状态,2允许查询,3锁定状态,4同步数据完成状态- 在状态为2的时候,软件开始锁定
update dbo.RStb01 set status=3 where status=2; #此部分为锁定,将2状态全部锁定为3状态
- 开始同步数据状态
* 注 此部分为为select 导出部分
- 将中间状态修改为完成状态
update dbo.RStb01 set status=4 where status=3; #此部分为锁定,将3状态全部标记为已经完成状态
- 在状态为2的时候,软件开始锁定
字段递增方式
- 数字递增【程序在运行的过程中,按照某个数字字段,从小开始递增,每次执行的时候,根据数字字段获取范围内数据,并且根据插叙最大值作为下一次查询的最小值】
1、设置需要查询的SQL语句
SQL中#ZCBUS_MIN#,#ZCBUS_MAX#代表规则中对应的最大值和最小值
2、设置SQL中查询最小值
3、设置SQL中设计某个值最大值查询 - 时间递增【程序在运行的过程中,按照某个时间字段,从小开始递增,每次执行的时候,根据数字字段获取范围内数据,并且根据插叙最大值作为下一次查询的最小值】
1、设置需要查询的SQL语句
SQL中#ZCBUS_MIN#,#ZCBUS_MAX#代表规则中对应的最大值和最小值
2、设置SQL中查询最小值
3、设置SQL中设计某个值最大值查询****
- 数字递增【程序在运行的过程中,按照某个数字字段,从小开始递增,每次执行的时候,根据数字字段获取范围内数据,并且根据插叙最大值作为下一次查询的最小值】
文档更新时间: 2022-04-19 03:30 作者:阿力