数据流命令不执行

Question

我试图创建一个数据流管道，但我得到这个错误在我的powershell控制台

Traceback (most recent call last):
File "load_pole_emploi.py", line 107, in <module>
run()
File "load_pole_emploi.py", line 92, in run
gcs_bucket_name + file_pattern)
File "E:UtilisateursSI084342venvgcplibsite-packagesapache_beamiotextio.py", line 675, in __init__
escapechar=escapechar)
File "E:UtilisateursSI084342venvgcplibsite-packagesapache_beamiotextio.py", line 132, in __init__
validate=validate)
File "E:UtilisateursSI084342venvgcplibsite-packagesapache_beamiofilebasedsource.py", line 124, in __init__
self._validate()
File "E:UtilisateursSI084342venvgcplibsite-packagesapache_beamoptionsvalue_provider.py", line 193, in _f
return fnc(self, *args, **kwargs)
File "E:UtilisateursSI084342venvgcplibsite-packagesapache_beamiofilebasedsource.py", line 185, in _validate
match_result = FileSystems.match([pattern], limits=[1])[0]
File "E:UtilisateursSI084342venvgcplibsite-packagesapache_beamiofilesystems.py", line 203, in match
filesystem = FileSystems.get_filesystem(patterns[0])
File "E:UtilisateursSI084342venvgcplibsite-packagesapache_beamiofilesystems.py", line 106, in get_filesystem
'e.g., pip install apache-beam[gcp]. Path specified: %s' % path)
ValueError: Unable to get filesystem from specified path, please use the correct path or ensure the required dependency is installed, e.g., pip install apache-beam[gcp]. Path specified: gs://bck-fr-fichiers-manuel-dev/de_par_categorie_et_code_rome/file.csv

我已经重新安装了apache beam[gcp]，但问题仍然存在

任何帮助，谢谢

Answer 1

谢谢，这与缺少apache beam测试和文档有关