如何从接口中提取数据

小伙伴们有没有觉得学习Golang很有意思？有意思就对了！今天就给大家带来《如何从接口中提取数据》，以下内容将会涉及到，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

我正在使用 redigo 从 redis 检索指标。虽然该包有一些内置的帮助程序来解析某些格式的响应中的数据，但我有一个需要解析的格式，但未涵盖。

该命令的结果是interface类型，包含一个不确定长度的数组，每个数组中都有一组数据。如果我将结果打印为字符串，我会得到（为了可读性而添加换行符）...

[
      [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"`
}

如果我尝试从下面添加 first-entry，我不确定要使用什么类型或如何获取值 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"

解决方案

使用 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"))

到这里，我们也就讲完了《如何从接口中提取数据》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！