到目前为止,我正在做类似这样的事情来读取 avsc 文件来获取架构
value_schema = avro.load('client.avsc')
我可以做些什么来使用主题名称从融合模式注册表中获取模式吗?
我找到了一种方法,但不知道如何使用它。
https://github.com/marcosschroh/python-schema-registry-client
最佳答案
from confluent_kafka.avro.cached_schema_registry_client import CachedSchemaRegistryClient
sr = CachedSchemaRegistryClient({
'url': 'http://localhost:8081',
'ssl.certificate.location': '/path/to/cert', # optional
'ssl.key.location': '/path/to/key' # optional
})
value_schema = sr.get_latest_schema("orders-value")[1]
key_schema= sr.get_latest_schema("orders-key")[1]
使用
SchemaRegistryClient
按主题名称获取模式
from schema_registry.client import SchemaRegistryClient
sr = SchemaRegistryClient('localhost:8081')
my_schema = sr.get_schema(subject='mySubject', version='latest')
通过 ID 获取架构
from schema_registry.client import SchemaRegistryClient
sr = SchemaRegistryClient('localhost:8081')
my_schema = sr.get_by_id(schema_id=1)
关于python - 如何以编程方式从 Python 中的融合模式注册表中获取模式,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60467878/