How to import json file to mongodb using pyspark or python

Question

I'm try to import json in the file to mongodb using pyspark after connection pyspark with mongodb, I'm using Ubuntu, my file in (file:///home/user/Downloads/newdb/hale.json) I write it like this ('home/user/Downloads/newdb/hale.json'),

I want to try using this code but in JSON

df = spark.read.csv(path = '/home/ahmad/Downloads/newdb/hale.csv', header=True, inferSchema=True)

??

Answer 1

You can use the same format as in your question but replace csv with json. 

df = spark.read.json(path = '/home/ahmad/Downloads/newdb/hale.json', header=True, inferSchema=True)

Hope this helps!

To know more about Pyspark, it's recommended that you join PySpark online course.

Thanks.

Comments

Thank you, I did this code but doesn't work :(

---

Hey @Ahmed. Can you share the error that you got?