使用 Golang 从 Azure Event Hub 中检索数据的方法

本篇文章向大家介绍《使用 Golang 从 Azure Event Hub 中检索数据的方法》，主要包括，具有一定的参考价值，需要的朋友可以参考一下。

我在 eventhub 中创建了架构，并且正在使用“github.com/Azure/azure-event-hubs-go/v3”包通过 Go 接收消息并向 eventhub 发送消息。

如何使用 Schema 序列化/反序列化正在发送或接收的数据？

解决方案

访问架构不依赖于正在使用哪个消息队列。

为了获取 avro 架构，我们可以使用标准 net/http 包，因为有返回架构的 api。

url 将采用以下格式：

如果 avro 主题和版本已知：

https://<schema_registry_url>/subjects/<subject_name>/versions/<version_number>

if the latest version schema is required `<version_number>` can be replaced with `latest`

如果架构 id 已知：

https://<schema_registry_url>/schemas/ids/<id>

今天关于《使用 Golang 从 Azure Event Hub 中检索数据的方法》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！