Open MothiPrakash opened 1 year ago
While trying to use csvio.Read, im getting the below error. _csv.Error: iterator should return strings, not bytes (did you open the file in text mode?). I used the code from http://mohaseeb.com/beam-nuggets/beam_nuggets.io.csvio.html#beam_nuggets.io.csvio.Read
PS: Im trying to read csv from storage and insert it to postgres using relational_db.write. Also let me know whether the data to relational_db.write should be a pcollection of dicts?
While trying to use csvio.Read, im getting the below error. _csv.Error: iterator should return strings, not bytes (did you open the file in text mode?). I used the code from http://mohaseeb.com/beam-nuggets/beam_nuggets.io.csvio.html#beam_nuggets.io.csvio.Read
PS: Im trying to read csv from storage and insert it to postgres using relational_db.write. Also let me know whether the data to relational_db.write should be a pcollection of dicts?