def insert_data(conn): while not traffic_queue.empty(): conn.xadz.insert_one(traffic_queue.get())
这是写入函数,把处理好的数据放到了队列里面