flink流处理访问mysql

业务场景以下: java     概述:采集工厂设备的数据。mysql     flink链接emqtt消息队列, 流处理数据, 设备数据json内没有设备的machID, 须要从mysq根据gateMac获取对应的machID, 而且须要5分钟获取从mysql获取一次, 定时刷新,redis    若是flink项目只是在初始化的时候获取一次,那么平台新建一个设备, flink项目须要重启一次,
相关文章
相关标签/搜索