Merge pull request #23 from datarevenue-berlin/ah-windows-support

Add windows support

Author: kayibal

drfs/filesystems/util.py

@@ -25,7 +25,7 @@ def get_fs(path, opts=None, rtype="instance"):
     try:
         protocol = path.scheme
     except AttributeError:
-        protocol = urllib.parse.urlparse(str(path)).scheme
+        protocol = _get_protocol(path)
 
     try:
         cls = FILESYSTEMS[protocol]
@@ -44,6 +44,15 @@ def get_fs(path, opts=None, rtype="instance"):
     return cls(**opts_)
 
 
+def _get_protocol(path):
+    if "://" in str(path):
+        protocol = urllib.parse.urlparse(str(path)).scheme
+    else:
+        # most likely a windows path, basically if in doubt assume local
+        protocol = ""
+    return protocol
+
+
 def _fix_opts_abfs(cls, path, opts: dict):
     try:
         from drfs.filesystems.azure_blob import AzureBlobFileSystem, extract_abfs_parts

drfs/tests/test_filesystem.py

@@ -48,7 +48,8 @@ def _get_fs_tuples():
         ('user/some_file.txt', LocalFileSystem),
         ('file://user/some_file.txt', LocalFileSystem),
         ('/home/user/some_file.txt', LocalFileSystem),
-        ('memory:/home/directory/some_file.txt', MemoryFileSystem),
+        (r"C:\Users\alhoeng\drfs", LocalFileSystem),
+        ('memory://home/directory/some_file.txt', MemoryFileSystem),
     ]
     if S3FileSystem:
         res.append(

requirements.txt

@@ -1,2 +1,3 @@
 pytz
 urlpath==1.1.*
+fsspec==0.8.0

setup.py

@@ -6,7 +6,7 @@
 
 import versioneer
 
-with open('README.rst') as readme_file:
+with open('README.md') as readme_file:
     readme = readme_file.read()
 
 with open('HISTORY.rst') as history_file: