5. 任务运维
1) 查看任务状态
提交执行后,单击“执行详情”可以看到执行阶段进度以及详细信息,每一个步骤的执行详情还会提供外链,直接查看或者运维执行步骤。
l 节点依赖关系
StreamxCheckDone:本节点负责检查实时同步位点,当实时同步位点已经超过本次运行的业务时间时。本节点会运行成功。如果实时同步任务没有在运行,或者一直处于同步延迟中,本节点会一直检查 72 小时,超时后节点状态失败,阻塞下方节点执行,需要人工恢复实时同步后重跑 StreamxCheckDone 节点。
FullDataInitCheckDone:全量初始化结束后,会运行全量初始化标 done 节点,该节点负责在 MaxCompute 创建一个临时表,用于给全量数据初始化 CheckDone 节点检查全量初始化是否完成。
MergeIntoNode:当 StreamxCheckDone 和 FullDataInitCheckDone 都运行成功时,MergeIntoNode 开始合并上一业务日期的全量数据和新增的实时数据,产出新的全量天分区。
2) 增减数据源
分库分表至 MaxCompute 同步解决方案支持增加、减少同步的数据源。
修改同步任务,单击“批量编辑数据来源”,修改同步的数据源。
修改完成后提交执行同步解决方案,同步任务会找出新数据源所包含的新增子表,执行全量初始化。更新实时同步所同步的数据源。
3) 增减表
分库分表至 MaxCompute 同步解决方案支持增加、减少同步的逻辑表。
修改同步任务,操作“添加逻辑表”、“删除”即可实现增减表。
修改完成后提交执行同步解决方案,同步任务会全量初始化新表。更新实时同步所同步的逻辑表。
4) 附录
l 基础正则表达式
分库分表规则配置中,使用了 java 正则表达式,正则表达式的功能极其强大,以下
提供几个常用样例供参考。
附一些正则基础组成单元的样例。
正则表达式
作用