python读取json文件并将数据插入到mongodb的方法

本文实例讲述了python/' target='_blank'>python读取json文件并将数据插入到mongodb的方法。分享给大家供大家参考。具体实现方法如下：

#coding=utf-8import sunburntimport urllibfrom pymongo import Connectionfrom bson.objectid import ObjectIdimport loggingfrom datetime import datetimeimport jsonfrom time import mktimefrom feedparser import _parse_date as parse_dateimport timeimport sysimport getoptimport ConfigParserargs = sys.argv[1:]optlist, args = getopt.getopt(args, 'c:')cmd_opt = {}for opt in optlist:  cmd_opt[opt[0]] = opt[1]conf_file = cmd_opt['-c']config = ConfigParser.ConfigParser()config.read(conf_file)hostname = config.get("mongodb", "hostname")port_num = int(config.get("mongodb", "port_num"))db_name = config.get("mongodb", "db")connection = Connection(hostname, port_num)db = connection[db_name]courseTable = db.courselecTable = db.lecturetry:  f = file("json1-14/14.json")  s = json.load(f)  courseData = s["results"]["course"]  lecDataArr = s["results"]["lecture"]  f.close  print "get file content successfully!"  #insert course  courseId = courseTable.save(courseData)  courseId = str(courseId)  print "courseId: "+courseId  print "lec length: "+str(len(lecDataArr))  #insert lecture  lecIdArr = []  for lecData in lecDataArr:    lecData["course_id"] = courseId    lecId = lecTable.save(lecData)    lecIdArr.append(str(lecId))  # update course  courseTable.update({'_id':ObjectId(courseId)},            {"$set":{"lectures.lecture_id_list":lecIdArr}},            upsert=True, multi=True);  print 'insert successfully!'except Exception, e:  print e

希望本文所述对大家的Python程序设计有所帮助。