rhg_compute_tools.io_tools package

Submodules

rhg_compute_tools.io_tools.readers module

rhg_compute_tools.io_tools.readers.get_fs(fp) → fsspec.spec.AbstractFileSystem[source]
rhg_compute_tools.io_tools.readers.load_netcdf(blob, fsspec_kwargs=None, *args, retries=5, **kwargs) → xarray.core.dataset.Dataset[source]

Read a geotiff or raster file from a local or gs:// location

rhg_compute_tools.io_tools.readers.read_csv(blob, **fsspec_kwargs) → pandas.core.frame.DataFrame[source]

Read a csv file from a local or gs:// location

rhg_compute_tools.io_tools.readers.read_csvv_response(fp) → xarray.core.dataset.Dataset[source]
rhg_compute_tools.io_tools.readers.read_dataframe(blob, **fsspec_kwargs) → pandas.core.frame.DataFrame[source]

Read a CSV or parquet file from a local or gs:// location

rhg_compute_tools.io_tools.readers.read_dataset(fp, engine=None, **kwargs) → xarray.core.dataset.Dataset[source]
rhg_compute_tools.io_tools.readers.read_netcdf(blob, fsspec_kwargs=None, *args, retries=5, **kwargs) → xarray.core.dataset.Dataset[source]

Read a geotiff or raster file from a local or gs:// location. Very similar to load_netcdf, but without the load.

rhg_compute_tools.io_tools.readers.read_parquet(blob, **fsspec_kwargs) → pandas.core.frame.DataFrame[source]

Read a parquet file from a local or gs:// location

rhg_compute_tools.io_tools.readers.read_rasterio(blob, fsspec_kwargs=None, *args, retries=5, **kwargs) → xarray.core.dataarray.DataArray[source]

Read a NETCDF file from a local or gs:// location

rhg_compute_tools.io_tools.readers.read_shapefile(fp)[source]
rhg_compute_tools.io_tools.readers.read_zarr(fp, fs=None, mapper_kwargs=None, isel_dict: dict = None, load_data: bool = False, **kwargs) → xarray.core.dataset.Dataset[source]
rhg_compute_tools.io_tools.readers.report_if_not_found(fp)[source]

rhg_compute_tools.io_tools.writers module

rhg_compute_tools.io_tools.writers.document_dataset(ds: xarray.core.dataset.Dataset, repo_root: str = '.') → xarray.core.dataset.Dataset[source]
rhg_compute_tools.io_tools.writers.get_maximal_chunks_encoding(ds: xarray.core.dataset.Dataset, **var_chunks) → dict[source]
rhg_compute_tools.io_tools.writers.write_netcdf(out_ds: xarray.core.dataset.Dataset, out_fp: str, fs: Union[None, fsspec.registry.filesystem] = None) → None[source]
rhg_compute_tools.io_tools.writers.write_zarr(out_ds: xarray.core.dataset.Dataset, out_fp: str, fs: Union[None, fsspec.registry.filesystem] = None, set_maximal_chunks: bool = True, writer_kwargs: Optional[dict] = None, encoding_kwargs: Optional[dict] = None) → None[source]

Module contents