broker_utils.avro_schemas

The avro_schemas.load module loads and returns Avro schemas.

REGISTERED_SCHEMAS = [

“elasticc.v0_9.alert.avsc”, “elasticc.v0_9.brokerClassification.avsc”,

]

broker.broker_utils.broker_utils.avro_schemas.load.all()[source]

Load all schemas in SCHEMAS and return as a dictionary.