数据流实时接入 中间处理数据