Hi,
Not sure I understand fully your use case, but you can add/update document with
Write:
pipeline
.apply(...)
.apply(MongoDbIO.write()
.withUri("mongodb://localhost:27017")
.withDatabase("my-database")
.withCollection("my-collection")
.withNumSplits(30))
It’s using the Java SDK. Your question is specifically to Python ?
Regards
JB
> Le 31 mars 2020 à 11:32, Emilien HENON <emilien.he...@ext.adeo.com> a écrit :
>
> Hello,
>
> I would like to contact you concerning a question about the MongoDBIO
> connector. As part of our Dataflow / Apache Beam project, we need to create
> and update documents in our MongoDB database. However, the update operation
> seems impossible with the current connector (either we read or we create, but
> it seems impossible to modify/overwrite a document from an already existing
> ObjectId).
>
> We would have liked to know if it was really impossible to update or
> overwrite a document with this library (because according to the
> documentation, it seems possible on the Python side). If it is, is it a
> deliberate choice on your side? Or would it be possible to open an associated
> Jira to possibly contribute to an implementation?
>
> Regards,
> Emilien Henon
