摘要
“十四五”期间,疾控面临着汇集各业务条线的数据以形成动态实时的电子疾病档案的任务。针对现阶段疾控信息化工作的现状,文章基于Flink构建了一个电子疾病档案的实时数据处理模型,使用消息中间件实现各个业务条线数据的发布与订阅。数据在Flink集群中实现了按主题目录的分流,检查与转换等操作,最终持久化写入HBase数据库,形成以个人信息为基础的各类业务数据的关联。实验与应用结果表明,该模型具有良好的数据处理能力,有效而可靠的实现了电子疾病档案的数据汇集。
During“the 14th Five-Year Plan”period,CDC is faced with the task of collecting data from various business lines to form dynamic and real-time electronic diseases records.On the basic of the existing work foundation of CDC informatization,a real-time processing model for electronic diseases records is designed and implemented based on Flink,the message-oriented middleware is used to implement publication and subscription of data which come from various business lines,Flink Cluster is used to split data stream,check and convert data by subject catalog,HBase is used to store data which associated with various businesses based on personal information.Experimental and application results show that,the model has good data processing ability,effectively and reliably realizes the data collection of electronic disease records.
作者
刘潇
季英凯
Liu Xiao;Ji Yingkai(Department of Public Health Information,Jiangsu Center for Disease Control and Prevention,Nanjing 210009,China)
出处
《无线互联科技》
2023年第16期52-56,66,共6页
Wireless Internet Technology
关键词
电子疾病档案
数据汇集
消息中间件
Flink
electronic diseases records
data collection
message-oriented middleware
Flink
