使用 Streaming 处理数据