fsspec_data.confluent

Classes

ConfluentSchemaDocument

Functions

fetch_confluent_schema(→ ConfluentSchemaDocument)

_parse_reference(→ tuple[str, str])

Module Contents

class fsspec_data.confluent.ConfluentSchemaDocument[source]
schema: str
schema_type: str
subject: str
version: str
schema_id: str | None
references: tuple[collections.abc.Mapping[str, Any], Ellipsis]
fsspec_data.confluent.fetch_confluent_schema(url: str, storage_options: collections.abc.Mapping[str, Any]) → ConfluentSchemaDocument[source]
fsspec_data.confluent._parse_reference(url: str) → tuple[str, str][source]