![]() File "/opt/venv/lib/python3.6/site-packages/apache_beam/transforms/core.py", line 322, in split_and_size for part in self.split(element, restriction): File "/opt/venv/lib/python3.6/site-packages/apache_beam/io/iobase.py", line 1488, in split estimated_size = self._source.estimate_size() File "/opt/venv/lib/python3.6/site-packages/apache_beam/io/mongodbio.py", line 167, in estimate_size return mand('collstats', ll).get('size') : Required element collStats missing I found myself having an error with cosmos db in azure with beam.io.mongodbio: info( 'Fetching connection string from Cloud Storage, fields =) If the string contains a Cloud Storage url, the url is assumed to be theįirst line of a text file at that location. """Extract the MongoDB connection string given MongoDB url. transforms import PTransform, ParDo, DoFn, Createįrom apache_beam. Tested with google-cloud-dataflow package version 2.0.0įrom apache_beam.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |