zyra.cli module

Zyra CLI entrypoint and command wiring.

Organizes commands into groups that mirror the 8-stage pipeline hierarchy:

  • import (alias: acquire/ingest): ingress from HTTP/S3/FTP/Vimeo backends

  • process (alias: transform): GRIB/NetCDF decoding, extraction, format conversion, and metadata helpers

  • simulate: simulation under uncertainty (skeleton)

  • decide (alias: optimize): decision/optimization (skeleton)

  • visualize (alias: render): static and animated rendering

  • narrate: AI-driven storytelling/reporting (skeleton)

  • verify: evaluation and metrics (skeleton)

  • export (alias: disseminate; legacy: decimate): egress (local, S3, FTP, HTTP POST, Vimeo)

  • run: run a config-driven pipeline (YAML/JSON)

Internal helpers support streaming bytes via stdin/stdout, GRIB .idx subsetting, and S3 URL parsing.

zyra.cli.cmd_convert_format(args: Namespace) → int[source]

Convert decoded data to a requested format.

Notes on NetCDF pass-through: - When the input stream is already NetCDF and the requested format is also

NetCDF, and no variable selection (”–var”) is provided, this command performs a byte-for-byte pass-through without decoding. This skips any validation of dataset contents.

  • If users expect validation or modification (e.g., selecting a variable or transforming coordinates), they must request a variable extraction or a conversion that decodes the data (e.g., specify β€œβ€“var” or convert to another format).

zyra.cli.cmd_decode_grib2(args: Namespace) → int[source]
zyra.cli.cmd_extract_variable(args: Namespace) → int[source]
zyra.cli.main(argv: list[str] | None = None) → int[source]