python - from apache_beam.io import fileioはエラーを返します：fileioをインポートできません

Question

私はcsvファイルをApacheのビームアプリケーションのリストに読み込みます。リストの各要素はタプルまたはリストです問題）、私はCSV

1,2,3 
4,5,6 

は、私が試した

[(1,2,3) , (4,5,6)] 

または

[ [1,2,3], [4,5,6] ] 

になっているだろうように、 How to convert csv into a dictionary in apache beam dataflow の指示に従うが、私は

from beam_utils.sources import CsvFileSource 

を使用しようとすると、私は私が直接

from apache_beam.io import fileio 

をインポートしようと

from beam_utils.sources import CsvFileSource 
Traceback (most recent call last): 
    File "<stdin>", line 1, in <module> 
    File "/usr/local/lib/python2.7/site-packages/beam_utils/sources.py", line 9, in <module> 
    from apache_beam.io import fileio 
ImportError: cannot import name fileio 

は、私は私ができるが、同じ問題をゲット両方を使用する

import apache_beam.io 
import beam_utils 

問題なし。問題がどういうものか、誰かが良いアイデアを得たか、これをどうやって別の方法でやり遂げることができるのかを知っていますか？

私はほんの数分前に、これと同じ問題に遭遇したあまりにもよく

Answer 1

を作品別の方法で目的の形式にcsvfileを回すことができる場合、私は現在、とても

with beam.Pipeline(options = pipeline_options) as p: 
     csvfile = p | ReadFromText(known_args.input) 

を持っています。問題は、fileioが明らかにapache_beam（少なくとも私にとってはそうではありません）になっていないことです。それはfilesystemに置き換えられているようです。

ない優れたソリューションが、beam_utilsからsources.pyに私は "ファイルシステム" と "FILEIO" のすべてのインスタンスを置き換え

ので

from apache_beam.io import fileio 

が

from apache_beam.io import filesystem