一个python包，它提供了与合流模式注册表接口的功能。
primed-avro的Python项目详细描述
启动AVRO
版本号：0.0.4.0 作者：Matthijs van der Kroon
概述
一个python包，提供：
- 一个基本的合流模式注册客户机
- 融合兼容avro编码和解码
- 动态解码avro消息的高级kafkaconsumer
警告：不支持python2.7
安装/使用
要安装，请使用pip:
pip install primed_avro
或者克隆回购协议：
git clone https://gitlab.com/primedio/primed-avro python setup.py install
合并模式注册表客户端示例
fromprimed_avro.registryimportConfluentSchemaRegistryClientcsr=ConfluentSchemaRegistryClient(url="your_registry_url")schemaMeta=csr.get_schema(subject=topic)
示例avro en/解码
fromprimed_avro.encoderimportEncoderfromprimed_avro.decoderimportDecoderencoder=Encoder(schema=schemaMeta.schema).get()bytesvalue=encoder.encode(schemaMeta.id,record)decoder=Decoder(schema=schemaMeta.schema).get()record=decoder.decode(bytesvalue)
示例高级Kafkaavroconsumer
fromprimed_avro.consumerimportAvroConsumerc=AvroConsumer(topic="mytopic",bootstrap_servers="localhost:9092",registry_url="http://localhost:8081")formsginc.consume():print(type(msg),msg)
贡献
待定
欢迎加入QQ群-->： 979659372
