英文:
Extracting Data From Kafka REST Proxy in Go
问题
我正在使用Kafka的REST代理实例来生产和消费消息。我正在使用API获取新消息，但是我无法将这些消息转换为Go语言中的结构模型。例如：
// 获取记录
req, err := http.NewRequest(http.MethodGet, fmt.Sprintf(FETCH_CONSUMER, URL, GROUP, CONSUMER), nil)
if err != nil {
panic(err)
}
req.Header.Add("Accept", CONTENT_TYPE)
respRecords, err := client.Do(req)
if err != nil {
panic(err)
}
defer respRecords.Body.Close()
fmt.Printf("Response %s\n", respRecords.Status)
fmt.Println(respRecords.Body)
recordsBodyResp := bufio.NewScanner(respRecords.Body)
for recordsBodyResp.Scan() {
fmt.Printf("<--Body %s\n", recordsBodyResp.Text())
}
返回的值的格式如下：
[{"topic":"backward","key":null,"value":{"AdoptionID":"abcd123","IPAddress":"8.8.8.8","Port":"80","Status":"requested"},"partition":0,"offset":7}]
由于它是一个对象数组，我想提取键"value"的值部分到一个结构体中。
这就是我卡住的地方。
英文:
I am using the REST proxy instance of Kafka for producing and consuming messages.Using the API to get new messages but I am not able to convert those messages to a struct model in Go. For example:
// Get recordsreq, err := http.NewRequest(http.MethodGet, fmt.Sprintf(FETCH_CONSUMER, URL, GROUP, CONSUMER), nil)if err != nil {panic(err)}req.Header.Add("Accept", CONTENT_TYPE)respRecords, err := client.Do(req)if err != nil {panic(err)}defer respRecords.Body.Close()fmt.Printf("Response %s\n", respRecords.Status)fmt.Println(respRecords.Body)recordsBodyResp := bufio.NewScanner(respRecords.Body)for recordsBodyResp.Scan() {fmt.Printf("<--Body %s\n", recordsBodyResp.Text())}
The value returned is in the following format:
[{"topic":"backward","key":null,"value":{"AdoptionID":"abcd123","IPAddress":"8.8.8.8","Port":"80","Status":"requested"},"partition":0,"offset":7}]
Since it's an array of objects, I want to extract the value portion of the key "value" into a struct.
That is where I am stuck.
答案1
得分: 2
你可以创建一个类似这样的结构体：
type AutoGenerated []struct {Topic string `json:"topic"`Key interface{} `json:"key"`Value Value `json:"value"`Partition int `json:"partition"`Offset int `json:"offset"`}type Value struct {AdoptionID string `json:"AdoptionID"`IPAddress string `json:"IPAddress"`Port string `json:"Port"`Status string `json:"Status"`}
然后在该结构体中进行解析。
参考这个示例代码：
package mainimport ("fmt""encoding/json")func main() {type Value struct {AdoptionID string `json:"AdoptionID"`IPAddress string `json:"IPAddress"`Port string `json:"Port"`Status string `json:"Status"`}type AutoGenerated []struct {Topic string `json:"topic"`Key interface{} `json:"key"`Value Value `json:"value"`Partition int `json:"partition"`Offset int `json:"offset"`}byt := []byte(`[{"topic":"backward","key":null,"value":{"AdoptionID":"abcd123","IPAddress":"8.8.8.8","Port":"80","Status":"requested"},"partition":0,"offset":7}]`)var dat AutoGeneratedif err := json.Unmarshal(byt, &dat); err != nil {panic(err)}fmt.Printf("%#v", dat)}
英文:
You can create a struct like:
type AutoGenerated []struct {Topic string `json:"topic"`Key interface{} `json:"key"`Value Value `json:"value"`Partition int `json:"partition"`Offset int `json:"offset"`}type Value struct {AdoptionID string `json:"AdoptionID"`IPAddress string `json:"IPAddress"`Port string `json:"Port"`Status string `json:"Status"`}
And Unmarshal in that struct.
See this sample code:
package mainimport ("fmt""encoding/json")func main() {type Value struct {AdoptionID string `json:"AdoptionID"`IPAddress string `json:"IPAddress"`Port string `json:"Port"`Status string `json:"Status"`}type AutoGenerated []struct {Topic string `json:"topic"`Key interface{} `json:"key"`Value Value `json:"value"`Partition int `json:"partition"`Offset int `json:"offset"`}byt := []byte(`[{"topic":"backward","key":null,"value":{"AdoptionID":"abcd123","IPAddress":"8.8.8.8","Port":"80","Status":"requested"},"partition":0,"offset":7}]`)var dat AutoGeneratedif err := json.Unmarshal(byt, &dat); err != nil {panic(err)}fmt.Printf("%#v", dat)}
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论