python读取json文件并将数据插入到mongodb的方法
本文实例讲述了python读取json文件并将数据插入到mongodb的方法。分享给大家供大家参考。具体实现方法如下：
#coding=utf-8
importsunburnt
importurllib
frompymongoimportConnection
frombson.objectidimportObjectId
importlogging
fromdatetimeimportdatetime
importjson
fromtimeimportmktime
fromfeedparserimport_parse_dateasparse_date
importtime
importsys
importgetopt
importConfigParser
args=sys.argv[1:]
optlist,args=getopt.getopt(args,'c:')
cmd_opt={}
foroptinoptlist:
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.course
lecTable=db.lecture
try:
f=file("json1-14/14.json")
s=json.load(f)
courseData=s["results"]["course"]
lecDataArr=s["results"]["lecture"]
f.close
print"getfilecontentsuccessfully!"
#insertcourse
courseId=courseTable.save(courseData)
courseId=str(courseId)
print"courseId:"+courseId
print"leclength:"+str(len(lecDataArr))
#insertlecture
lecIdArr=[]
forlecDatainlecDataArr:
lecData["course_id"]=courseId
lecId=lecTable.save(lecData)
lecIdArr.append(str(lecId))
#updatecourse
courseTable.update({'_id':ObjectId(courseId)},
{"$set":{"lectures.lecture_id_list":lecIdArr}},
upsert=True,multi=True);
print'insertsuccessfully!'
exceptException,e:
printe
希望本文所述对大家的Python程序设计有所帮助。