例如:
FROM apache/airflow:2.1.0
RUN pip install pymongo
例如:
from pymongo import MongoClient
client = MongoClient('mongodb://localhost:27017/')
db = client['test_database']
collection = db['test_collection']
document = {'key': 'value'}
result = collection.insert_one(document)
print(result.inserted_id)