How to do Apache Beam Transform with MongoDB in Python

Bilge Demirkaya
3 min readMay 4, 2021

Apache beam is the best way to automate the Reading-Transforming-Writing process to make a robust pipeline.

For my work project, I needed to do read data from a collection and write it to another collection with a transform. It is easy as there is an official MongoDB IO reader and writer module. You can check out the mongodbiomodule here.

--

--