-
Type:
Bug
-
Status: Resolved
-
Priority:
P2
-
Resolution: Fixed
-
Affects Version/s: 2.25.0
-
Fix Version/s: 2.27.0
-
Component/s: io-py-mongodb
-
Environment:Google Cloud Dataflow
Cannot use the Python MongoDB connector with a managed Atlas instance. The current implementations makes use of splitVector which is a high-privilege function that cannot be assigned to any user in Atlas. Getting error:
pymongo.errors.OperationFailure: not authorized on properties to execute command
{ splitVector: "properties.properties", keyPattern: { _id: 1 },
...
BEAM-4567 addressed the same issue in Java connector.
Proposed solution for Python is to add bucket_auto option for the connector which would configure it to use @bucketAuto MongoDB aggregation instead of splitVector command:
pipeline | ReadFromMongoDB(uri='mongodb+srv://user:pwd@cluster0.mongodb.net', db='testdb', coll='input', bucket_auto=True)
- is related to
-
BEAM-4567 Can't use mongo connector with Atlas MongoDB
-
- Resolved
-
- links to