mongo.py

from sshtunnel import SSHTunnelForwarder
import pymongo

EC2 = "<IP>"
MONGO_DB = "test_database"
MONGO_COLLECTION = "post"

# define ssh tunnel
server = SSHTunnelForwarder(
    EC2,
    ssh_username="ec2-user",
    ssh_pkey='./MONGO_TUNNEL.pem',
    remote_bind_address=('127.0.0.1', 27017)
)


# start ssh tunnel
server.start()


connection = pymongo.MongoClient(
    'mongodb://<username>:<password>@127.0.0.1:27017/?ssl=true&ssl_ca_certs=./rds-combined-ca-bundle.pem&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false')
db = connection[MONGO_DB]
collection = db[MONGO_COLLECTION]

data = collection.insert_one({"text": "test"})

print(data)

# close ssh tunnel
server.stop()