python 에서 csv 파일 에 데 이 터 를 MongoDB 데이터베이스 에 추가 합 니 다.

1630 단어 파 이 썬 파충류
csv 의 DictReader 함수 로 읽 기
#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time   : 2018/10/21 11:31
# @Author  : deli Guo
# @Site   : 
# @File   : csv    mongoDB.py
# @Software  : PyCharm

#   
from pymongo import MongoClient
import csv
#     MongoDB     
def connection():
    # 1:    MongoDB     
    conn=MongoClient("localhost")
    # 2:       (guazidata)。        
    db=conn.guazidata
    # 3:    
    set1=db.data
    # 4:         (      ,         ,     )
    #     remove
    set1.remove(None)
    #   remove      
    # set1.delete_many({})
    return set1
def insertToMongoDB(set1):
    #     guazi.csv
    with open('guazi.csv','r',encoding='utf-8')as csvfile:
        #   csv  DictReader             
        reader=csv.DictReader(csvfile)
        #     counts                   
        counts=0
        for each in reader:
            #                  。       (string)。
            each['index']=int(each['index'])
            each['  ']=float(each['  '])
            each['  ']=float(each['  '])
            each['    ']=int(each['    '])
            each['    ']=float(each['    '])
            each['  ']=float(each['  '])
            each['    ']=int(each['    '])
            set1.insert(each)
            counts+=1
            print('     '+str(counts)+'    ')
#      
def main():
    set1=connection()
    insertToMongoDB(set1)
#         main  。                             
if __name__=='__main__':
    main()




좋은 웹페이지 즐겨찾기