将病人的关键就诊信息（姓名、疾病）利用Python技术从数据库中读取后对数据进行封装，将封装好的数据发送到kafka中创建的主题中，利用spark streaming实时处理流来消费kafka中的数据，统计每天医保审核的结果信息，然后将结果数据实时插入到mysql数据库中供接口调用，最终实现医疗报销数据的实时可视化展示（包含审核时间、审核状态等信息）。
系统通过对病人的就诊信息统计出符合报销条件与不符合报销条件以及不通过原因等，更直观的展现出报销信息。