Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import csv
- import json
- import pymongo
- import sys
- host = "dbmongo01.decisyon.office"
- port = 27017
- database = "data_scrm"
- username = "scrm"
- password = "scrm"
- def pop_collection(cname, csvfile):
- conn = pymongo.Connection(host, port)
- db = conn[database]
- if db.authenticate(username, password):
- collection = db[cname]
- row = csvfile.next()
- for item in csvfile:
- docname = {}
- docname = {row[0] : item[0],
- row[1] : json.loads(item[1]),
- row[2] : item[2]
- }
- collection.insert(docname)
- conn.close()
- filename = open(sys.argv[1], 'r')
- collname = filename.name.split('\\')[-1:][0].split('.')[0]
- pop_collection(collname, csv.reader(filename, delimiter='\t'))
Add Comment
Please, Sign In to add comment