How to Connect DataBricks and MongoDB Atlas using Python API?

Lekshmyho 27 Apr, 2021 • 6 min read
This article was published as a part of the Data Science Blogathon.

What is DataBricks?

Databricks is a cloud-based analyzing tool that can be used for analyzing and processing massive amounts of big data. Databricks is a product of Microsoft cloud that used Apache Spark for computation purposes. It allows users to combine their data, ELT processes, and machine learning in an efficient manner. Databricks worked on a parallel distributed system, which means the workload is automatically split across various processors as a result it offers high scalability and sharding. Thus indirectly effects in reduced processing time and cost. 


  1. Databricks can be used to process massive, unstructured data in real-time
  2. Facilitates disseminating of collected big data throughout distributed clusters
  3. Had provision to collect and store raw data from IoT devices, machines, files, etc.
  4. Integrates Apache Spark
  5. Facilitates solution to run on and scale to a large number of machines and systems
  6. Collected big data can be easily analyzed and processed to build models
  7. Supports Real-time Batch Processing
  8. Consolidates, Cleanses, and Normalizes data from multiple disparate sources.
  9. Helps save storage capacity and improves query performance
  10. Supports SQL-based analytics functions like Time series, pattern matching, etc.

This Spark-based environment is very easy to use. It gives provisions to use the most commonly used programming languages like Python, R, and SQL. These languages are later converted through APIs to interact with Spark. As a result data processing and computation become an easy task.

Its computing power can be again increased by connecting it with an external database like MongoDB. In this way, we can process the massive amount of data in a short span of time.


What are MongoDB and MongoDB Atlas?


MongoDB is an open-source document database built on a horizontal scale-out architecture.It was founded in 2007 by Dwight Merriman, Eliot Horowitz, and Kevin Ryan, who co-founded MongoDB in NYC. Instead of storing data in tables of rows or columns like SQL databases, each row in a MongoDB database is a document described in JSON  formatting language.

Features of MongoDB

  1. MongoDB is an open-source document database
  2. Data objects are stored as separate documents inside a collection.
  3. Each MongoDB instance can have multiple databases and each database can have multiple collections.
  4. Provides high performance, high availability, and automatic scaling.
  5. Replication and high availability
  6. Auto-Sharding
  7. Server-side JavaScript execution
  8. GridFS is used for storing and retrieving files.
  9. High Availability
  10. MongoDB can control changes in the structure of documents with the help of schema validation.
  11.  Using MongoDB we can create Binary JSON format (BSON) files this will increase efficiency.
  12.  Data stored in BSON can be easily searched and indexed, which tremendously increases the performance.

MongoDB Atlas

MongoDB Atlas is a specialized version of MongoDb that provides easy cluster formation and easy deployments. MongoDb provides a way to store millions of data efficiently.•MongoDB belongs to the NoSQL databases category, while MongoDb Atlas can be primarily classified as hosting that provides an easy way to deploy the cluster. This provides strong authentication and encryption features that ensure data protection.

Features of MongoDB Atlas

  1. MongoDB Atlas is a fully managed cloud database for modern applications.
  2.  MongoDB Atlas can be primarily classified under “MongoDB Hosting”
  3. MongoDB Atlas offers many features when compared with local MongoDB
  4.  MongoDB Atlas Atlas comes with MongoDB Atlas Search built-in, making it easy to build fast, relevant, full-text search capabilities on top of MongoDB data.
  5. No infrastructure on the client-side.
  6. Easy to  use
  7. Easy to scale up and down.
  8. .It has strong authentication and encryption features that make sure that developers
  9. Drivers are available so deployment is easy
  10. GIves options to upload data in JASON and CSV Format

How to connect MongoDB Atlas with Databricks?

In order to connect databricks with MongoDB, one can make use of some packages available from maven. Some tutorials are already available for connecting Databricks with Mongodb through scala driver. But none of them give a clear picture of connecting MongoDB Atlas and Databricks through Python API.

connect databricks and MongoDB Atlas 1

source: google

Let’s have a look at the prerequisites required for establishing a connection between MongoDB Atlas with Databricks.


Create Databricks Cluster and Add the Connector as a Library

  1. Create a Databricks cluster.
  2. Navigate to the cluster detail page and select the Libraries tab.
  3. Click the Install New button.
  4. Select Maven as the Library Source.

Enter the MongoDB Connector for Spark package value into the Coordinates field based on your Databricks Runtime version:

connect databricks and MongoDB Atlas step 1

Eg: For Databricks Runtime 7.6 (includes Apache Spark 3.0.1, Scala 2.12)

Select org.mongodb.spark:mongo-spark-connector_2.12:3.0.1 or

connect databricks and MongoDB Atlas 2

       Give extra care to search in packages and find the package that supports your spark and scala version.


Install Spark XML

 Install Spark xl from libraries and restart the cluster.

connect databricks and MongoDB Atlas XML



Note down the cluster IP address

We can take IP address by launching Web Terminal from Apps tab in databricks – Cluster.

Type ifconfig -a in the shell to get the  IP address.

connect databricks and MongoDB Atlas ip

Text Description automatically generated connect databricks and MongoDB Atlas


1.Prepare a MongoDB Atlas Instance

1.Create an account in MongoDB Atlas Instance by giving a username and password.

2. Create an Atlas free tier cluster. Click on Connect button.

Prepare a MongoDB Atlas Instancestep 4

3. Open MongoDB Compass and connect to database through string (don’t forget to replace password in the string with your password).

MongoDB Compass


Graphical user interface, text, application Description automatically generated

4.Open MongoDB Compass. Create a New database to save your data by clicking on the CREATE DATABASE  button.

MongoDB Compassted4

5.Import your document as a collection by clicking on the Import Data Button.

Import Data Button

NOTE: To explore and manipulate your MongoDB data easily, install MongoDB Compass by clicking on I do not have MongoDB Compass button. Copy the connection string to connect to the MongoDB Atlas cluster from MongoDB Compass.

String looks like this



2. Connect MongoDB Atlas with DataBricks

     1.Connection with databricks

Enable Databricks clusters to connect to the cluster by adding the external IP addresses for the Databricks cluster nodes to the whitelist in Atlas.

MongoDB Atlas with DataBricks 1

For that take network access on MongoDB and add the Databrick cluster IP address there.

  2. Configure Databricks Cluster with MongoDB Connection URI

  1. Get the MongoDB connection URI. In the MongoDB Atlas UI, click the cluster you have created.
  2. Click the Connect button.
  3. Click Connect Your Application.


  1. Select Python in the Driver dropdown according to your Databrick-MongoDB connector configuration(make ensure your scala and spark version are the same)

Select Python in the Driver

  1. Copy the generated connection string. It should look like mongodb+srv://<user>:<password>
  2. Replace password and Firstdata base name with your password and database name.


3. Configuration in DataBricks

       METHOD 1

  1. In the cluster detail page for your Databricks cluster, select the Configuration tab.
  2. Click the Edit button.
  3. Under Advanced Options, select the Spark configuration tab and update the Spark Config using the connection string you copied in the previous step: Follow the below format in the config tab



            Through python notebook, read the file 

      METHOD 2(More preferable)

      Configure settings directly in python notebook through the below code

from pyspark.sql import SparkSession
database = "cloud" your database name
collection = "millionsongs"your collection name
connectionString= copy your connection string here  ('mongodb+srv://user:<password><database>?retryWrites=true&w=majority')
spark = SparkSession
    .config('spark.mongodb.input.uri', connectionString)
    .config('spark.jars.packages', 'org.mongodb.spark:mongo-spark-connector_2.12:3.0.1')
# Reading from MongoDB
df =
.option("uri", connectionString)
.option("database", database)
.option("collection", collection)

The media are shown in this article on ‘How to connect databricks and MongoDB Atlas’ are not owned by Analytics Vidhya and is used at the Author’s discretion. 

Lekshmyho 27 Apr 2021

Frequently Asked Questions

Lorem ipsum dolor sit amet, consectetur adipiscing elit,

Responses From Readers