图11.12描述了一个单一处理,即小批处理流图。各个处理连续运行,并与其他处理共同完成同一工作,如邮件收发后台程序。因此设置工作处理事件和微批处理状态值,然后继续。数据清洗、一致化、匹配、存在和发布等后台处理任务可能同时发生在数据管理者的环境中。实时CTF系统中的转换过程和代理键查找后台程序也有可能存在。每个后台程序都会连续地处理查找任务。所述的任务工作是指在给定处理中以最优方式处理的阶段,已记录的任务。任务处理事件的状态在处理中被设置,并且关系数据库处理的起始点是确定的。处理后,任务处理事件的状态会更新为成功或失败。在批处理结束时,批处理控制表会被更新,以确保所有任务都已成功执行。如果发生失败或大量任务处理事件状态失败,将执行回滚处理,将数据库恢复到微批处理执行之前的状态。回滚事件并不一定回滚错误信息或控制表中的状态值。关系型数据库提供了处理控制选项以支持这种约束。微批处理ETL应用于实时数据管理者,如图11.13所示,作为系列后台处理,从数据库表中读取数据,更新控制信息,分段传输数据,并进行数据一致化。