我正在使用 Redigo 從 Redis 檢索指標。雖然該包有一些內置的幫助程序來解析某些格式的響應中的數據，但我有一個我需要解析的格式，它沒有被涵蓋。該命令的結果是接口類型，包含一個長度不確定的數組，每個數組中包含一組數據。如果我將結果作為字符串打印出來，我會得到（添加換行符以提高可讀性）......[ [name cgroup1 consumers %!s(int64=2) pending %!s(int64=90) last-delivered-id 1582572156729-0] [name cgroup2 consumers %!s(int64=2) pending %!s(int64=110) last-delivered-id 1582572156729-0]]我將如何在 Go 中迭代這樣的響應并訪問數據。我發現了很多處理 JSON 和解組的示例，但沒有發現與上述類似的示例。使用的redis命令是...xinfo groups <stream name>Redis 中的數據，看起來是這樣的……1) 1) "name" 2) "cgroup1" 3) "consumers" 4) (integer) 2 5) "pending" 6) (integer) 90 7) "last-delivered-id" 8) "1582572156729-0"2) 1) "name" 2) "cgroup2" 3) "consumers" 4) (integer) 2 5) "pending" 6) (integer) 110 7) "last-delivered-id" 8) "1582572156729-0"如果我打印出它顯示的類型...[]interface {}另一個問題是如何提取嵌套更深的信息。例如XINFO STREAM <stream name>我可以使用 ScanStruct 從第一級獲取所有內容，但似乎無法獲取第一個條目下的信息。我的信息結構type Stream struct { Length int `redis:"length"` Groups int `redis:"groups"` LastID string `redis:"last-generated-id"`}如果我嘗試從下面添加第一個條目，我不確定要使用什么類型或如何獲取值 12[1] (1582572131616-0)示例 Redis 輸出127.0.0.1:6379> xinfo stream stream1 1) "length" 2) (integer) 1200 3) "radix-tree-keys" 4) (integer) 12 5) "radix-tree-nodes" 6) (integer) 30 7) "groups" 8) (integer) 2 9) "last-generated-id"10) "1582642828055-10"11) "first-entry"12) 1) "1582572131616-0" 2) 1) "payload" 2) "message:0"13) "last-entry"14) 1) "1582642828055-10" 2) 1) "payload" 2) "message:99"
1 回答
catspeake
TA貢獻1111條經驗 獲得超0個贊
使用redis.Values轉換interface{}為切片。使用redis.ScanStruct從名稱-值對的切片中設置結構字段。
type Group struct {
Name string `redis:"name"`
Consumers int `redis:"consumers"`
Pending int `redis:"pending"`
LastDeliveredID string `redis:"last-delivered-id"`
}
func scanGroups(resp interface{}, err error) ([]*Group, error) {
// Get slice from resp
groups, err := redis.Values(resp, err)
if err != nil {
return nil, err
}
var result []*Group
// For each group
for _, g := range groups {
// Get slice for group
v, err := redis.Values(g, nil)
if err != nil {
return nil, err
}
// Scan slice to struct
var group Group
err = redis.ScanStruct(v, &group)
if err != nil {
return nil, err
}
// Accumlate result
result = append(result, &group)
}
return result, nil
}
像這樣使用它：
groups, err := scanGroups(conn.Do("XINFO", "GROUPS", "mystream"))
- 1 回答
- 0 關注
- 250 瀏覽
添加回答
舉報
0/150
提交
取消