【发布时间】:2020-10-12 04:24:39
【问题描述】:
我正在尝试使用 Dataflow 将存储在 GCS 存储桶中的 CSV 文件读入数据帧。作业因错误而失败:
raise_with_traceback raise exc.with_traceback(traceback) File "apache_beam/runners/common.py", line 1213, in apache_beam.runners.common.DoFnRunner.process File "apache_beam/runners/common.py", line 570, in apache_beam.runners.common.SimpleInvoker.invoke_process File "/home/curate_try_final.py", line 71, in <lambda> File "/home/curate_try_final.py", line 66, in convert_to_parquet File "/usr/local/lib/python3.7/site-packages/pandas/io/parsers.py", line 685, in parser_f return _read(filepath_or_buffer, kwds) File "/usr/local/lib/python3.7/site-packages/pandas/io/parsers.py", line 440, in _read filepath_or_buffer, encoding, compression File "/usr/local/lib/python3.7/site-packages/pandas/io/common.py", line 213, in get_filepath_or_buffer from pandas.io import gcs File "/usr/local/lib/python3.7/site-packages/pandas/io/gcs.py", line 5, in <module> "gcsfs", extra="The gcsfs library is required to handle GCS files" File "/usr/local/lib/python3.7/site-packages/pandas/compat/_optional.py", line 93, in import_optional_dependency raise ImportError(message.format(name=name, extra=extra)) from None ImportError: Missing optional dependency 'gcsfs'. The gcsfs library is required to handle GCS files Use pip or conda to install gcsfs. [while running 'ConvertToParquet']
即使使用安装后也显示相同的错误
sudo pip3 install gcsfs
有人可以帮忙吗?
【问题讨论】:
-
你在用jupyter notebook吗?
-
你在哪里运行代码?
-
我在 Google Cloud Shell 中运行此代码。
标签: python pandas google-cloud-platform google-cloud-dataflow