操作说明

定时发布场景,搭建步骤如下:

  • 建立发布节点为增量导出模式
  • 根据设置增加需要发布的SQL语句,每个SQL导出的结果,定义为增量那个导出的结果
  • 设置计划任务,确定执行SQL语句的轮训时间,可以支持某个时间点,或者某个时间段来执行,最低粒度精确到秒级别。
操作步骤
  1. 建立发布客户端【支持实时模式,但是导出增量数据按照where条件导出规则】
    定时发送,订阅客户端,实时发送数据类型,需要设置参数
    data_migrate_mode=0 ##设置为1时,全量发布时使用迁移模式,不受刷新标志和增量状态的影响,默认为0
    real_export_by_where=1 ##设置为1时,实时发布时采用定时导出的模式,默认0,为实时分析日志模式

  2. 发布节点
    发布管理-发布-定时管理

定时支持以下几种功能:
  • 全量数据/定制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状态全部标记为已经完成状态
  • 字段递增方式

    • 数字递增【程序在运行的过程中,按照某个数字字段,从小开始递增,每次执行的时候,根据数字字段获取范围内数据,并且根据插叙最大值作为下一次查询的最小值】
      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   作者:阿力