aerospike, golang -- 获取所有记录的所有 bin 名称答案

【问题标题】：aerospike, golang -- get all bin names for all recordsaerospike, golang -- 获取所有记录的所有 bin 名称
【发布时间】：2017-01-20 04:25:27
【问题描述】：

只是想检查一下，是否有办法获取每条记录的所有 bin 名称？

我知道我们可以使用以下代码获取binmap。但我想读取所有键并创建一个map[string]interface{}，然后将该映射转换为字节数组。

这是我获取所有 bin 的代码，将它们添加到数组中，将数组转换为字节数组：

package main

import (
    "bytes"
    "encoding/gob"
    "fmt"
    as "github.com/aerospike/aerospike-client-go"
    "strconv"
    "time"
)

var client *as.Client


func main() {
    stmt := as.NewStatement("txn", "user")
    stmt.Addfilter(as.NewEqualFilter("p", "param"))
    rs, err := GetAerospikeClient().Query(nil, stmt)
    if err == nil {

        //Conv to byte array
        var ret []interface{}
        for res := range rs.Results() {
            if res.Err != nil {
                // handle error here
                // if you want to exit, cancel the recordset to release the resources
                fmt.Println("Err------", res.Err)

            } else {
                // process record here
                fmt.Printf("Success------%#v\n", res.Record.Bins)
                ret = append(ret, res.Record.Bins)
            }
        }

        b, _ := GetBytes(ret)
        fmt.Println("Len of byte array ", len(b))



    }

}

func GetAerospikeClient() *as.Client {
    var err error
    port, _ := strconv.Atoi("3000")
    maxconn, _ := strconv.Atoi("10")
    host := "172.28.128.3"
    timeout, _ := strconv.Atoi("50")
    idletimeout, _ := strconv.Atoi("3600")
    clientPolicy := as.NewClientPolicy()
    clientPolicy.ConnectionQueueSize = maxconn
    clientPolicy.LimitConnectionsToQueueSize = true
    clientPolicy.Timeout = time.Duration(timeout) * time.Millisecond
    clientPolicy.IdleTimeout = time.Duration(idletimeout) * time.Second
    client, err = as.NewClientWithPolicy(clientPolicy, host, port)
    if err != nil {
        panic(err)
    }
    return client
}   

func GetBytes(key []interface{}) ([]byte, error) {
    var buf bytes.Buffer
    gob.Register(as.BinMap{})
    gob.Register([]interface{}{})
    enc := gob.NewEncoder(&buf)
    err := enc.Encode(key)
    if err != nil {
        panic(err)
        return nil, err
    }
    return buf.Bytes(), nil
}

谢谢

【问题讨论】：

现在添加了完整的主要功能......

标签： go aerospike

【解决方案1】：

如果您只想要命名空间的 bin 列表，则有一种更便宜的方法。您不需要进行非常昂贵的查询/扫描。一个问题是你不能每套得到它。有一个 info 命令 "bins/nsname"（将“nsname”替换为您想要的命名空间名称）来获取该命名空间中的所有 bin。

如果您不关心获取 binlist 的编程方式，您可以使用aerospike-tools 包提供的asinfo 工具获取它。您可以发出以下命令。输出是合理的，不言自明。（将“127.0.0.1”替换为节点的正确IP地址）

asinfo -v "bins/nsname" -h 127.0.0.1

如果您想以编程方式获取列表，您可以使用this example 中给出的RequestInfo() API 并发送上述命令。您应该编写解析器来提取所需的字段。

【讨论】：