from pyflink.datastream import StreamExecutionEnvironment from pyflink.datastream.functions import MapFunction, RuntimeContext, KeyedProcessFunction
import re import redis # 创建 StreamExecutionEnvironment 对象 env StreamExecutionEnvironment.get_executi…