zyra.connectors.backends package

HTTP connector backend.

Provides functional helpers to fetch and list resources over HTTP(S), as well as convenience utilities for GRIB workflows (.idx parsing and byte-range downloads) and Content-Length probing.

Functions are intentionally small and dependency-light so they can be used by the CLI, pipelines, or higher-level wrappers without imposing heavy imports.

zyra.connectors.backends.http.download_byteranges(url: str, byte_ranges: Iterable[str], *, max_workers: int = 10, timeout: int = 60) → bytes

Download multiple byte ranges and concatenate in the input order.

zyra.connectors.backends.http.fetch_bytes(url: str, *, timeout: int = 60) → bytes

Return the raw response body for a GET request.

Parameters - url: HTTP(S) URL to fetch. - timeout: request timeout in seconds.

zyra.connectors.backends.http.fetch_json(url: str, *, timeout: int = 60)

Return the parsed JSON body for a GET request.

zyra.connectors.backends.http.fetch_text(url: str, *, timeout: int = 60) → str

Return the response body as text for a GET request.

zyra.connectors.backends.http.get_idx_lines(url: str, *, timeout: int = 60, max_retries: int = 3) → list[str]

Fetch and parse the GRIB .idx file for a URL.

zyra.connectors.backends.http.get_size(url: str, *, timeout: int = 60) → int | None

Return Content-Length for a URL via HTTP HEAD when provided.

zyra.connectors.backends.http.list_files(url: str, pattern: str | None = None, *, timeout: int = 60) → list[str]

Best-effort directory listing by scraping anchor tags on index pages.

Returns absolute URLs; optionally filters them via regex pattern.

zyra.connectors.backends.http.post_bytes(url: str, data: bytes, *, timeout: int = 60, content_type: str | None = None) → int

Backward-compat wrapper for post_data.

zyra.connectors.backends.http.post_data(url: str, data: bytes, *, timeout: int = 60, content_type: str | None = None) → int

POST raw bytes to a URL and return the HTTP status code.

FTP connector backend.

Thin functional wrappers around the FTPManager to support simple byte fetches and uploads, directory listing with regex/date filtering, sync-to-local flows, and advanced GRIB workflows (.idx handling, ranged downloads).

The URL parser supports anonymous and credentialed forms, e.g.: ftp://host/path, ftp://user@host/path, ftp://user:pass@host/path.

class zyra.connectors.backends.ftp.FTPManager

Bases: object

Placeholder for tests to patch.

The backend functions will attempt to delegate to this manager if present. Tests patch this attribute with a mock class exposing expected methods.

zyra.connectors.backends.ftp.delete(url_or_path: str) → bool

Delete a remote FTP path (file).

zyra.connectors.backends.ftp.download_byteranges(url_or_path: str, byte_ranges: Iterable[str], *, max_workers: int = 10, timeout: int = 30) → bytes

Download multiple ranges via FTP REST and concatenate in the input order.

zyra.connectors.backends.ftp.exists(url_or_path: str) → bool

Return True if the remote path exists on the FTP server.

zyra.connectors.backends.ftp.fetch_bytes(url_or_path: str) → bytes

Fetch a remote file as bytes from an FTP server.

zyra.connectors.backends.ftp.get_chunks(url_or_path: str, chunk_size: int = 524288000) → list[str]

Compute contiguous chunk ranges for an FTP file.

zyra.connectors.backends.ftp.get_idx_lines(url_or_path: str, *, write_to: str | None = None, timeout: int = 30, max_retries: int = 3) → list[str] | None

Fetch and parse the GRIB .idx for a remote path via FTP.

zyra.connectors.backends.ftp.get_size(url_or_path: str) → int | None

Return remote file size in bytes via FTP SIZE.

zyra.connectors.backends.ftp.list_files(url_or_dir: str, pattern: str | None = None, *, since: str | None = None, until: str | None = None, date_format: str | None = None) → list[str] | None

List FTP directory contents with optional regex and date filtering.

zyra.connectors.backends.ftp.parse_ftp_path(url_or_path: str) → tuple[str, str, str | None, str | None]

Return (host, remote_path, username, password) parsed from an FTP path.

zyra.connectors.backends.ftp.stat(url_or_path: str)

Return minimal metadata mapping for a remote path (e.g., size).

zyra.connectors.backends.ftp.sync_directory(url_or_dir: str, local_dir: str, *, pattern: str | None = None, since: str | None = None, until: str | None = None, date_format: str | None = None, clean_zero_bytes: bool = False) → None

Sync files from a remote FTP directory to a local directory.

Applies regex/date filters prior to download; optionally removes local zero-byte files before syncing and deletes local files that are no longer present on the server.

zyra.connectors.backends.ftp.upload_bytes(data: bytes, url_or_path: str) → bool

Upload bytes to a remote FTP path.

S3 connector backend.

Functional helpers for working with Amazon S3 using the existing S3Manager implementation under the hood. Exposes byte fetching, uploading, listing, and introspection utilities, plus GRIB-centric helpers for .idx and ranged downloads.

zyra.connectors.backends.s3.delete(url_or_bucket: str, key: str | None = None) → bool

Delete an object by URL or bucket+key.

zyra.connectors.backends.s3.download_byteranges(url_or_bucket: str, key: str | None, byte_ranges: Iterable[str], *, unsigned: bool = False, max_workers: int = 10, timeout: int = 30) → bytes

Download multiple byte ranges from an S3 object and concatenate in order.

zyra.connectors.backends.s3.exists(url_or_bucket: str, key: str | None = None) → bool

Return True if an S3 object exists.

zyra.connectors.backends.s3.fetch_bytes(url_or_bucket: str, key: str | None = None, *, unsigned: bool = False) → bytes

Fetch an object’s full bytes using ranged GET semantics.

Accepts either a single s3://bucket/key URL or bucket``+``key.

zyra.connectors.backends.s3.get_idx_lines(url_or_bucket: str, key: str | None = None, *, unsigned: bool = False, timeout: int = 30, max_retries: int = 3) → list[str]

Fetch and parse the GRIB .idx content for an S3 object.

Accepts either a full s3:// URL or (bucket, key).

zyra.connectors.backends.s3.get_size(url_or_bucket: str, key: str | None = None) → int | None

Return the size in bytes for an S3 object, or None if unknown.

zyra.connectors.backends.s3.list_files(prefix_or_url: str | None = None, *, pattern: str | None = None, since: str | None = None, until: str | None = None, date_format: str | None = None) → list[str]

List S3 keys with optional regex and date filtering.

Accepts either a full s3://bucket/prefix or bucket only (prefix may be None) and filters using regex pattern and/or filename-based date filtering via since/until with date_format.

zyra.connectors.backends.s3.parse_s3_url(url: str) → tuple[str, str]

zyra.connectors.backends.s3.stat(url_or_bucket: str, key: str | None = None)

Return a basic metadata mapping for an object (size/etag/last_modified).

zyra.connectors.backends.s3.upload_bytes(data: bytes, url_or_bucket: str, key: str | None = None) → bool

Upload bytes to an S3 object by writing to a temporary file first.

zyra.connectors.backends.vimeo.fetch_bytes(video_id: str) → bytes

zyra.connectors.backends.vimeo.update_description(video_uri: str, text: str) → str

Update the description metadata for a Vimeo video.

zyra.connectors.backends.vimeo.update_video(video_path: str, video_uri: str) → str

Replace an existing Vimeo video file and return the URI.

zyra.connectors.backends.vimeo.upload_path(video_path: str, *, name: str | None = None, description: str | None = None) → str

Upload a local video file to Vimeo using PyVimeo.

Returns the Vimeo video URI on success.