‘’’
    要求:
    将数据集1的数据通过python插入到MongoDB数据库中
    1)数据库名字为: crawl_one;
    2)集合名字为: collection_one;
    3)数据文件为: movie_world.csv;
    ‘’’

    1. import pymongo, csv
    4. class MongoDate():
    5.     def __init__(self, name):
    6.         self.client = pymongo.MongoClient() # 若为本地mongo可以省略括号里的参数(host,port)
    7.         self.db = self.client['crawl_one'][name]
    9.     def read_data(self, filename):
    10.         with open(filename, encoding="utf-8") as f:
    11.             f_csv = csv.DictReader(f)   # 调用DictReader()方法,可以把csv直接转成为字典
    12.             for row in f_csv:
    13.                 self.add_one(row) # 调用add_one() 写入方法来将每行的数据写入mongo数据库中
    15.     def add_one(self, data):
    16.         result = self.db.insert_one(data)
    17.         print(result)
    20. if __name__ == '__main__':
    21.     md = MongoDate('collection_one')
    22.     md.read_data('movie_world.csv')

    附csv:
    a1.png
    mongo截个图
    a2.png