How to import json file to mongodb using pyspark (or python)?(如何使用pyspark(或python)将json文件导入到MongoDB?)
本文介绍了如何使用pyspark(或python)将json文件导入到MongoDB?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我尝试在与MongoDB连接pysppark后,使用pyspark将文件中的json导入到MongoDB中,
我使用的是ubuntu,我的文件在(file:/home/user/Downloads/newd/hale.json)我是这样写的(‘home/user/downloads/newd/hale.json’))
import json
from pymongo import MongoClient
client = MongoClient('localhost', 27017)
with open('home/user/Downloads/newdb/hale.json') as f:
file = json.load(f)
JSON
您可以使用集合的方法INSERT_ONE或INSERT_MANY,如果它是在加载Python字典(最初是推荐答案对象)或Python字典(最初是JSON对象)的列表(最初是数组)之后加载JSON文件,则通过加载JSON文件来确定。
#in case of array of dictionaries
client['your_database']['your_collection'].insert_many(file)
#in case of dictionary
client['your_database']['your_collection'].insert_one(file)
这篇关于如何使用pyspark(或python)将json文件导入到MongoDB?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
沃梦达教程
本文标题为:如何使用pyspark(或python)将json文件导入到MongoDB?
基础教程推荐
猜你喜欢
- 使用Python匹配Stata加权xtil命令的确定方法? 2022-01-01
- 症状类型错误:无法确定关系的真值 2022-01-01
- 使用 Google App Engine (Python) 将文件上传到 Google Cloud Storage 2022-01-01
- 哪些 Python 包提供独立的事件系统? 2022-01-01
- Python 的 List 是如何实现的? 2022-01-01
- 使 Python 脚本在 Windows 上运行而不指定“.py";延期 2022-01-01
- 如何在Python中绘制多元函数? 2022-01-01
- 将 YAML 文件转换为 python dict 2022-01-01
- 合并具有多索引的两个数据帧 2022-01-01
- 如何在 Python 中检测文件是否为二进制(非文本)文 2022-01-01