Avro to bigquery is a simple project to create a bigquery schema from an avro schema.
pip install avro-to-bigquery
With avro_schema.avsc:
{
"type": "record",
"name": "User",
"namespace": "example.avro",
"fields": [
{"name": "favorite_number", "type": "int", "doc": "Favorite number"}
]
}
>>> import json
>>> from pathlib import Path
>>> from avro_to_bigquery import convert_schema
>>> schema = json.loads(Path("avro_schema.avsc").read_text())
>>> print(convert_schema(schema))
(SchemaField('favorite_number', 'INTEGER', 'NULLABLE', 'Favorite number', (), ()),)
See the open issues for a list of proposed features (and known issues).
Contributions are what make the open source community such an amazing place to learn, inspire, and create. Any contributions you make are greatly appreciated. For detailed contributing guidelines, please see https://github.com/wayfair-incubator/avro-to-bigquery/blob/main/CONTRIBUTING.md
Distributed under the MIT
License. See LICENSE
for more information.
Project Link: https://github.com/wayfair-incubator/avro-to-bigquery/