摘要

“十四五”期间,疾控面临着汇集各业务条线的数据以形成动态实时的电子疾病档案的任务。针对现阶段疾控信息化工作的现状,文章基于Flink构建了一个电子疾病档案的实时数据处理模型,使用消息中间件实现各个业务条线数据的发布与订阅。数据在Flink集群中实现了按主题目录的分流,检查与转换等操作,最终持久化写入HBase数据库,形成以个人信息为基础的各类业务数据的关联。实验与应用结果表明,该模型具有良好的数据处理能力,有效而可靠的实现了电子疾病档案的数据汇集。

  • 单位
    江苏省疾病预防控制中心