Skip to content

EarthMoverERA5

GlobalERA5EarthMover

Import path: earth2studio.data.EarthMoverERA5

View source on GitHub

Documentation

Bases: _EarthMoverBase

Earthmover ERA5 0.25 degree reanalysis data source.

Parameters:

  • repo (str, default: None ) –

    Arraylake repository name as org/repo. When omitted, derives the repo from EARTHMOVER_ORGANIZATION as <org>/era5-subscription, by default None.

  • branch (str, default: DEFAULT_BRANCH ) –

    Repository branch to read, by default "main".

  • client (AsyncClient, default: None ) –

    Pre-authenticated Arraylake async client. When omitted, this data source uses the API key stored in EARTHMOVER_API_KEY, by default None.

  • cache (bool, default: True ) –

    Retained for API compatibility; Arraylake reads lazily via Icechunk, by default True.

  • verbose (bool, default: True ) –

    Print progress, by default True.

Warning

This is a remote data source and can download a large amount of data for large requests.

Note

Configure Earthmover access before using this data source:

  • Set the EARTHMOVER_API_KEY environment variable to an Earthmover / Arraylake API key, unless passing a pre-authenticated client.
  • Pass repo="org/repo" to open a specific Arraylake repository.
  • If repo is omitted, set the EARTHMOVER_ORGANIZATION environment variable. The default repository is <EARTHMOVER_ORGANIZATION>/era5-subscription.

The data source opens the single/spatial and pressure/spatial groups from the ERA5 Marketplace repository. Arraylake-backed Earthmover sources require Python 3.12 or newer.

For a walkthrough of subscribing to a Marketplace listing, authenticating, fetching data and writing output back to Arraylake, see the blog post Access Earthmover Marketplace Data with Earth2Studio.

Additional information on the data repository can be referenced here:

__call__ 

__call__(
    time: datetime | list[datetime] | TimeArray,
    variable: str | list[str] | VariableArray,
) -> DataArray

Retrieve ERA5 data for times and variables.

Parameters:

  • time (datetime | list[datetime] | TimeArray) –

    Analysis timestamps (UTC).

  • variable (str | list[str] | VariableArray) –

    Earth2Studio variable id(s).

Returns:

  • DataArray –

    Data array with dimensions [time, variable, lat, lon].

fetch async 

fetch(
    time: datetime | list[datetime] | TimeArray,
    variable: str | list[str] | VariableArray,
) -> DataArray

Retrieve ERA5 data for times and variables asynchronously.

Parameters:

  • time (datetime | list[datetime] | TimeArray) –

    Analysis timestamps (UTC).

  • variable (str | list[str] | VariableArray) –

    Earth2Studio variable id(s).

Returns:

  • DataArray –

    Data array with dimensions [time, variable, lat, lon].

available 

available(time: datetime | datetime64) -> bool

Synchronous wrapper for _available.