基于Flink SQL引擎的工业生产数据实时处理方法、系统

摘要

本发明提供一种基于Flink SQL引擎的工业生产数据实时处理方法、系统，所述方法包括：Flink SQL任务配置；对接工业企业生产设备数据，在开源的Flink Table连接器中扩展RabbitMQ Source连接器；扩展额外的自定义函数；执行数据ETL流程，创建中间表；根据不同ETL流程处理，持久化到不同的数据库；设置任务提交运行模式。该方法解决了工业现场数据复杂繁琐的采集流程，通过RabbitMQ实时自动化采集，无需开发代码处理数据，提供了简单易学的SQL语句处理工业现场实时数据，对于工业企业非开发工作人员也易于上手操作，减少工作学习成本以及提高数据传输效率。