本文实例讲述了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程序设计有所帮助。