回答此问题可获得 20 贡献值,回答如果被采纳可获得 50 分。
<p>我一直在跟踪<a href="https://beam.apache.org/get-started/quickstart-py/" rel="nofollow noreferrer">Dataflow Python Quickstart</a>,在运行wordcount示例管道时遇到一个错误:</p>
<blockquote>
<p>...
File "apache_beam/io/fileio.py", line 281, in glob
return gcsio.GcsIO().glob(path, limit)
AttributeError: 'NoneType' object has no attribute 'GcsIO'</p>
</blockquote>
<p>我试过用我自己的管道得到同样的结果。我不确定问题出在这里,因为我以为我完全遵循了教程,这个错误似乎与读/写转换有关</p>
<blockquote>
<p>Traceback (most recent call last): File
"/System/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/runpy.py",
line 162, in _run_module_as_main
"<strong>main</strong>", fname, loader, pkg_name) File "/System/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/runpy.py",
line 72, in _run_code
exec code in run_globals File "/Users/Alex/beam/sdks/python/apache_beam/examples/wordcount.py", line
116, in
run() File "/Users/Alex/beam/sdks/python/apache_beam/examples/wordcount.py", line
87, in run
lines = p | 'read' >> ReadFromText(known_args.input) File "apache_beam/io/textio.py", line 378, in <strong>init</strong>
skip_header_lines=skip_header_lines) File "apache_beam/io/textio.py", line 87, in <strong>init</strong>
validate=validate) File "apache_beam/io/filebasedsource.py", line 97, in <strong>init</strong>
self._validate() File "apache_beam/io/filebasedsource.py", line 171, in _validate
if len(fileio.ChannelFactory.glob(self._pattern, limit=1)) <= 0: File "apache_beam/io/fileio.py", line 281, in glob
return gcsio.GcsIO().glob(path, limit) AttributeError: 'NoneType' object has no attribute 'GcsIO'</p>
</blockquote>
<p>你知道我做错什么了吗?在</p>
<p>谢谢</p>