首页 > 编程 > Python > 正文

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

2019-11-25 17:55:05
字体:
来源:转载
供稿:网友

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

发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表