单一进程的流式数据计算执行调度任务并避免数据丢失的方法、系统及计算机设备

摘要

本发明公开了一种单一进程的流式数据计算中执行调度任务并避免数据丢失的方法、系统及计算机设备，采用微服务提供Restful接口供数据写入并注册至Eureka集群，Flink从Eureka获取写入服务地址并调用接口进行数据持久化。在此基础上增加服务异常捕捉及休眠重试方案，利用Flink的背压机制、Kafka的可重放特性以及Eureka的高可用机制解决了实时统计数据写入时数据丢失的问题。