4.3 流数据摄入