Interfaces

erddapy/core/interfaces.py

@@ -0,0 +1,52 @@
+"""
+Interface between URL responses and third-party libraries.
+
+This module takes an URL or the bytes response of a request and converts it to Pandas,
+XArray, Iris, etc. objects.
+"""
+
+import iris
+import pandas as pd
+import xarray as xr
+from netCDF4 import Dataset as ncDataset
+
+from erddapy.core.netcdf import _nc_dataset, _tempnc
+from erddapy.core.url import urlopen
+
+
+def to_pandas(url: str, requests_kwargs=dict(), **kw) -> pd.DataFrame:
+    """Convert a URL to Pandas DataFrame."""
+    data = urlopen(url, **requests_kwargs)
+    try:
+        return pd.read_csv(data, **kw)
+    except Exception:
+        print("Couldn't process response into Pandas DataFrame.")
+        raise
+
+
+def to_ncCF(url: str, **kw) -> ncDataset:
+    """Convert a URL to a netCDF4 Dataset."""
+    auth = kw.pop("auth", None)
+    return _nc_dataset(url, auth=auth, **kw)
+
+
+def to_xarray(url: str, response="opendap", **kw) -> xr.Dataset:
+    """Convert a URL to an xarray dataset."""
+    auth = kw.pop("auth", None)
+    if response == "opendap":
+        return xr.open_dataset(url, **kw)
+    else:
+        nc = _nc_dataset(url, auth=auth, **kw)
+        return xr.open_dataset(xr.backends.NetCDF4DataStore(nc), **kw)
+
+
+def to_iris(url: str, **kw):
+    """Convert a URL to an iris CubeList."""
+    data = urlopen(url, **kw)
+    with _tempnc(data) as tmp:
+        cubes = iris.load_raw(tmp, **kw)
+        try:
+            cubes.realise_data()
+        except ValueError:
+            _ = [cube.data for cube in cubes]
+        return cubes

erddapy/erddapy.py

@@ -10,7 +10,7 @@
     _griddap_check_variables,
     _griddap_get_constraints,
 )
-from erddapy.core.netcdf import _nc_dataset, _tempnc
+from erddapy.core.interfaces import to_iris, to_ncCF, to_pandas, to_xarray
 from erddapy.core.url import (
     _check_substrings,
     _distinct,
@@ -344,50 +344,37 @@ def to_pandas(self, **kw):
         """
         response = kw.pop("response", "csvp")
         url = self.get_download_url(response=response, **kw)
-        data = urlopen(url, auth=self.auth, **self.requests_kwargs)
-        return pd.read_csv(data, **kw)
+        return to_pandas(url, **kw)
 
     def to_ncCF(self, **kw):
         """Load the data request into a Climate and Forecast compliant netCDF4-python object."""
         if self.protocol == "griddap":
             return ValueError("Cannot use ncCF with griddap.")
         url = self.get_download_url(response="ncCF", **kw)
-        nc = _nc_dataset(url, auth=self.auth, **self.requests_kwargs)
-        return nc
+        return to_ncCF(url, **kw)
 
     def to_xarray(self, **kw):
         """Load the data request into a xarray.Dataset.
 
         Accepts any `xr.open_dataset` keyword arguments.
         """
-        import xarray as xr
-
         if self.response == "opendap":
-            url = self.get_download_url()
-            return xr.open_dataset(url, **kw)
+            response = "opendap"
+        elif self.protocol == "griddap":
+            response = "nc"
         else:
-            response = "nc" if self.protocol == "griddap" else "ncCF"
-            url = self.get_download_url(response=response)
-            nc = _nc_dataset(url, auth=self.auth, **self.requests_kwargs)
-            return xr.open_dataset(xr.backends.NetCDF4DataStore(nc), **kw)
+            response = "ncCF"
+        url = self.get_download_url(response=response)
+        return to_xarray(url, response=response, auth=self.auth, **kw)
 
     def to_iris(self, **kw):
         """Load the data request into an iris.CubeList.
 
         Accepts any `iris.load_raw` keyword arguments.
         """
-        import iris
-
         response = "nc" if self.protocol == "griddap" else "ncCF"
         url = self.get_download_url(response=response, **kw)
-        data = urlopen(url, auth=self.auth, **self.requests_kwargs)
-        with _tempnc(data) as tmp:
-            cubes = iris.load_raw(tmp, **kw)
-            try:
-                cubes.realise_data()
-            except ValueError:
-                _ = [cube.data for cube in cubes]
-            return cubes
+        return to_iris(url, **kw)
 
     @functools.lru_cache(maxsize=None)
     def _get_variables(self, dataset_id: OptionalStr = None) -> Dict:

tests/test_erddapy.py

@@ -103,13 +103,13 @@ def test_erddap_requests_kwargs():
     slowwly_url = f"https://flash-the-slow-api.herokuapp.com/delay/{slowwly_milliseconds}/url/{base_url}"
 
     connection = ERDDAP(slowwly_url)
-    connection.dataset_id = "M01_sbe37_all"
+    connection.dataset_id = "raw_asset_inventory"
     connection.protocol = "tabledap"
 
     connection.requests_kwargs["timeout"] = timeout_seconds
 
     with pytest.raises(httpx.ReadTimeout):
-        connection.to_xarray()
+        connection.to_pandas(requests_kwargs=connection.requests_kwargs)
 
 
 @pytest.mark.web