asyn python rest客户端与模式注册中心合流服务器交互以管理avro模式

async-python-schema-registry-client的Python项目详细描述


#异步python rest客户端架构注册表

[![生成状态](https://travis-ci.org/marcosschroh/async-python-schema-registry-client.svg?branch=master)](https://travis-ci.com/marcosschroh/async-python-schema-registry-client.svg?分支=主) [![github许可证](https://img.shields.io/github/license/marcosschroh/async-python-schema-registry-client.svg)](https://github.com/marcosschroh/async-python-schema-registry-client/blob/master/LICENSE) [![codecov](https://codecov.io/gh/marcosschroh/async-python-schema-registry-client/branch/master/graph/badge.svg)](https://codecov.io/gh/marcosschroh/async-python-schema-registry-client) [![python版本](https://img.shields.io/badge/python-3.6%20%7C%203.7-blue.svg)](https://img.shields.io/badge/python-3.6%20%7C%203.7-blue.svg

异步python rest客户机与[schema registry](https://docs.confluent.io/current/schema-registry/index.html)合流服务器交互以管理[avro schemas](https://docs.oracle.com/database/nosql-12.1.3.1/GettingStartedGuide/avroschemas.html)资源。

##要求

python 3.6+,fastavro>;=0.22.3,请求异步>;=0.4.1,aiofiles>;=0.4.0

##安装

` pip install async-python-schema-registry-client `

##客户机API、序列化程序、Faust集成和架构服务器描述

文档:[https://marcosschroh.github.io/async-python-schema-registry-client.io](https://marcosschroh.github.io/async-python-schema-registry-client

##什么时候用这个图书馆?

通常,我们有这样的情景:

啊![合流架构](docs/img/confluent_architecture.png)

因此,我们的生产者/消费者每次从kafka主题发送/接收消息时都必须序列化/反序列化消息。在这张图片中,我们可以想象一个faust应用程序接收消息(用avro模式编码),我们想要对它们进行反序列化,因此我们可以要求模式服务器为我们这样做。在这种情况下,消息序列化程序是完美的。

另外,可能是我们希望应用程序只管理avro模式(注册、更新兼容性、删除旧模式等)的用例,因此schemaregistryclient是完美的。

##运行测试

测试使用docker compose在模式服务器上运行,因此您需要 dockerdocker compose已安装。

`bash ./scripts/test.sh `

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
添加组件后,java JTable为空   java将json发送到php并插入mysql,但返回null   java Spring引导JNDI CommonJ资源   从不同PC创建和合并后的Java servlet问题   java如何在使用findelements时从xpath获取文本   java使用spring boot使用gmail smtp发送电子邮件   java在不使用pojo、bean或getter和setter的情况下获取Json标题的Json数组   Java中的OpenFile对话框将null作为响应   JavaBuilder模式。扩展接口   java中无需替换的数据结构选取   java如何评价Encog中的预测神经网络   java如何在安卓中使用实际的HttpURLConnection进行单元测试?   java使用XML配置禁用WebSocket中的CSRF保护   java如何通过hibernate从多表查询中获取数据?   mysql如何在java中获取更新的行Id   java AEM/CQ组件单一组件/有限组件   java FFmpeg Javacv延迟问题   显示整数数组的java不起作用