hydromodpy.data.adapters.csv_to_parquet#

Convert user-facing CSV files into the internal Parquet pivot format.

Two CSV flavours are supported:

  • Timeseries CSVs (<variable>_custom_<id>_<start>_<end>_<freq>.csv) with columns datetime,value.

  • Locations CSVs (<variable>_custom_LOC.csv) with columns id,x,y,crs,unit.

Validation is strict but emits all errors at once via TimeSeriesValidationError rather than stopping at the first one.

Functions

convert_locations_csv_to_geoparquet(src, dest)

Convert a locations CSV into an OGC GeoParquet 1.1 vector table.

convert_timeseries_csv_to_parquet(src, dest)

Convert a validated timeseries CSV into a Parquet file.

infer_station_id_from_filename(path)

Derive a station identifier from a chronicle filename.

iter_chronicle_files(data_dir, prefix)

Yield custom chronicle CSV paths in data_dir (flat).

read_locations_csv(path)

Read and validate a locations CSV.

read_timeseries_csv(path)

Read and validate a timeseries CSV.

Classes

LocationsArtifact(stations, crs, unit, ...)

In-memory representation of a validated locations CSV.

TimeSeriesArtifact(station_id, records, ...)

In-memory representation of a validated timeseries CSV.

Exceptions

TimeSeriesValidationError(path, errors)

Raised when a CSV file fails validation.