python 读取单所有json数据写入mongodb(单个)

Posted adolfmc

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了python 读取单所有json数据写入mongodb(单个)相关的知识,希望对你有一定的参考价值。

<--------------主函数------------------->

from pymongo import MongoClient
from bson.objectid import ObjectId
from read_json import read



def mongoclient():
client = MongoClient(‘127.0.0.1‘, 27017)
db = client.test
collection = db.test
# collection.insert({})
# for i in collection.find({"name":"乐清市东岸北段"}):
# print(i)
data = (‘coastlines.real.json‘)
find_Da = (‘track‘)
find_Id = (‘coastlineid‘)
find_Node = (‘nodes_index‘)

want_Data = read(data, find_Da) #传入json文件,根据关键字查询
want_Id = read(data, find_Id)
want_No = read(data, find_Node)
id = {‘_id‘: ObjectId(want_Id)}
id_print = collection.find_one(id)
print(id_print)

collection.update((id), {‘$set‘: {‘track‘: want_Data}}) #根据ObjectID修改track
collection.update((id), {‘$push‘: {‘nodeindex‘: want_No}}) #根据ObjectID添加nodeindex
collection.update((id), {‘$set‘: {‘nodeindex‘: want_No}}) #根据ObjectID修改nodeindex ,去除多余的[]


id_change = collection.find_one(id) #调出修改后的数据
print("修改后:")
print(id_change)




if __name__ ==‘__main__‘:
mongoclient()

<---------------读取文件代码----------------------->
import json

def read(data, find):
# 设置以utf-8解码模式读取文件,encoding参数必须设置,否则默认以gbk模式读取文件,当文件中包含中文时,会报错
f = open(data, encoding=‘utf-8‘)
setting = json.load(f)

# 注意多重结构的读取语法
# family = setting[‘BaseSettings‘][‘font‘]
style = setting[find]


# print(family)
return style

以上是关于python 读取单所有json数据写入mongodb(单个)的主要内容,如果未能解决你的问题,请参考以下文章

无法从使用 mongo spark 连接器读取的 spark DF 中显示/写入。

python 读取Json文件并插入Mongodb #mongo #python

mongo 取随机100条数据写入Excel

Python:如何从压缩的 json .gz 文件中读取并写入 json 文件

Python从数据库读取数据写入json格式文件

python写入json文件