关键词: 流处理；排放预警；重型柴油车；Flink

Abstract: In order to monitor the pollutant emission indicators of heavy-duty diesel vehicles in real time and quickly screen vehicles with excessive emissions, the Apache open-source big data framework with Flink as the core computing engine is used to achieve real-time processing of the data sent back by the heavy-duty vehicle emission on-board terminal and calculate the vehicle pollutant emission level. Based on the calculation results, the information of vehicles with excessive emissions will be pushed to vehicle users, after-sales departments, and research and development departments. At the same time, according to the requirements of the demand department, the operating conditions, configuration information, fault code information of the vehicles exceeding the standard are collected and analyzed to quickly locate the causes of excessive emissions. This will effectively improve social and economic benefits.

Key words: Stream processing; Emission warning; Heavy duty diesel vehicles; Flink