added stream_to_mongo.py. not robust to timeouts etc