Python - From Apache_beam.io Import Fileio Gives Error: Cannot Import Name Fileio

I want to read a csv file into a list in an apache beam application, where each element in the list is a tuple or list (don't really matter), so that I would have the csv 1,2,3 4,5

Solution 1:

Just ran into this same problem a few minutes ago. The issue is that fileio is apparently no longer in apache_beam (at least it wasn't for me). It appears to have been replaced by filesystem.

Not a great solution, but in sources.py from beam_utils I replaced all instances of "fileio" with "filesystem"

So

from apache_beam.ioimport fileio

becomes

from apache_beam.ioimport filesystem