[MOD] consume raw stream to MongoDB