xarray_beam.open_zarr(store, **kwargs)

Returns a lazily indexable xarray.Dataset and chunks from a Zarr store.

Only Zarr stores with the consistent chunking between non-indexed variables (i.e., those for which the Dataset.chunks property is valid) can be opened.

  • store (Union[str, Mapping[str, bytes]]) – Xarray compatible Zarr store to open.

  • **kwargs (Any) – passed on to xarray.open_zarr. The “chunks” keyword argument is not supported.


(dataset, chunks) pair, consisting of a Dataset with the contents of the Zarr store and a mapping from dimensions to integer chunk sizes.

Return type:

Tuple[Dataset, Mapping[str, int]]