无法在 pyspark 中导入 s3fs

Question

当我尝试使用以下代码在 pyspark 中导入 s3fs 库时：

import s3fs

我收到以下错误：

遇到错误：无法从以下位置导入名称“maybe_sync” 'fsspec.asyn' (/usr/local/lib/python3.7/site-packages/fsspec/asyn.py) Traceback（最近一次通话最后一次）：文件 “/usr/local/lib/python3.7/site-packages/s3fs/init.py”，第 1 行，在 从 .core 导入 S3FileSystem，S3File 文件“/usr/local/lib/python3.7/site-packages/s3fs/core.py”，第 12 行，在 从 fsspec.asyn 导入 AsyncFileSystem、sync、sync_wrapper、maybe_sync ImportError：无法导入名称“maybe_sync” 'fsspec.asyn' (/usr/local/lib/python3.7/site-packages/fsspec/asyn.py)

fsspec 软件包已安装在我的笔记本中。而我其实已经用了很长时间了，突然发生了这种情况。 我试过谷歌搜索，但找不到这个特定的错误。 有没有人遇到过这个？如果是这样，你知道如何解决吗？

Answer 1

很高兴听到这不仅仅是我。看起来如果你 pip 安装版本 s3fs==0.5.1 和 fsspec==0.8.3，应该可以解决它。