NEDAS.core.dataset module

class NEDAS.core.dataset.Dataset(context: Context | None = None, config_file: str | None = None, parse_args: bool = False, **kwargs)[source]

Bases: ABC

Dataset class (template for specific dataset sources)

variables: dict[Annotated[str, 'variable name'], VarDesc] = {}
obs_operator: dict[Annotated[str, 'variable name'], Callable] = {}
memory: dict = {}
dataset_name: str
property c: Context
parse_kwargs(kwargs: dict[str, Any]) dict[str, Any][source]

Parse the input kwargs to pinpoint a specific file/variable…

get_mstr(member)[source]
get_tstr(time)[source]
generate_obs_network(**kwargs) dict[str, ndarray][source]

Generate a random observing network for use in synthetic observation experiments.

Parameters:

**kwargs

read_obs(**kwargs) dict[str, ndarray][source]
abstractmethod read_obs_from_file(**kwargs) dict[str, ndarray][source]

Return observation sequence matching the given kwargs

read_obs_from_memory(**kwargs) dict[str, ndarray][source]
write_obs(seq: dict, **kwargs) None[source]
write_obs_to_file(seq: dict, **kwargs)[source]
write_obs_to_memory(seq: dict, **kwargs)[source]
save_memory(tag: str, time: datetime | None = None, path: str | None = None) None[source]
load_memory(tag: str, time: datetime | None = None, path: str | None = None) None[source]