[WIP] Add remote file io using fsspec. #33549
Conversation
alimcmaster1
added
the
IO Data
| import fsspec | ||
| scheme = parse_url(filepath_or_buffer).scheme | ||
| filesystem = fsspec.filesystem(scheme) | ||
| file_obj = filesystem.open(filepath_or_buffer, mode=mode or "rb") |
There was a problem hiding this comment.
Do we need to pass through the encoding? to .open() You will potentially also fix this if you do so: #26124 :)
There was a problem hiding this comment.
If using filesystem.open directly, I would for now always open binary and use the existing encoding within pandas.
| if is_s3_url(filepath_or_buffer): | ||
| from pandas.io import s3 | ||
| if is_fsspec_url(filepath_or_buffer): | ||
| import fsspec |
There was a problem hiding this comment.
this can be import_optional_dependency("fsspec"). Make sure we have a nice error message on the failure.
| return s3.get_filepath_or_buffer( | ||
| filepath_or_buffer, encoding=encoding, compression=compression, mode=mode | ||
| ) | ||
| # if is_s3_url(filepath_or_buffer): |
There was a problem hiding this comment.
You can delete all these.
|
|
||
| try: | ||
| from fsspec.registry import known_implementations | ||
| scheme = parse_url(url).scheme |
There was a problem hiding this comment.
Perhaps split_protocol, or even just "://" in url or "::" in url
| from pandas.io import s3 | ||
| if is_fsspec_url(filepath_or_buffer): | ||
| import fsspec | ||
| scheme = parse_url(filepath_or_buffer).scheme |
There was a problem hiding this comment.
These three lines can be done with fsspec.open, except for the garbage collection issue, which should take care of encoding and compression too.
| import fsspec | ||
| scheme = parse_url(filepath_or_buffer).scheme | ||
| filesystem = fsspec.filesystem(scheme) | ||
| file_obj = filesystem.open(filepath_or_buffer, mode=mode or "rb") |
There was a problem hiding this comment.
If using filesystem.open directly, I would for now always open binary and use the existing encoding within pandas.
|
@jrderuiter , is there any way in which I can help here? |
|
ping ? |
| @@ -158,6 +158,23 @@ def urlopen(*args, **kwargs): | |||
| return urllib.request.urlopen(*args, **kwargs) | |||
|
|
|||
|
|
|||
| def is_fsspec_url(url) -> bool: | |||
| fsspec filesystem. | ||
| """ | ||
|
|
||
| if not isinstance(url, str): |
|
Closing in favor of #34266. |
black pandasgit diff upstream/master -u -- "*.py" | flake8 --diff