go couchbase (gocb)错误-歧义超时或无歧义超时

Question

我刚刚开始使用Go中的Couchbase，使用库gocb。

作为概念的证明，试图查询我的服务器以获得特定的ID并获得结果。下面是一个修改过的代码示例。

cOpts := gocb.ClusterOptions{
        Authenticator: gocb.PasswordAuthenticator{
            Username: "user",
            Password: "pw",
        },
    }

    cluster, err := gocb.Connect("couchbase://my.dev.server.net/", cOpts)
    if err != nil {
        panic(err)
    }

    qOpts := gocb.QueryOptions{}

    // create query
    queryStr := "SELECT * FROM myBucket WHERE id = '123456789'"

    rows, err := cluster.Query(queryStr, &qOpts)
    if err != nil {
        panic(err)
    }

    fmt.Printf("rows: %v\n", rows)

    for rows.Next() {
        var intfc interface{}
        err = rows.Row(&intfc)
        if err != nil {
            panic(err)
        }
        fmt.Printf("interface result: %v\n", intfc)

    }

couchbase服务器位于5.1上。

我要么得到..。

panic: ambiguous timeout | {"statement":"SELECT * FROM myBucketName WHERE id = '123456789'","client_context_id":"cdd52a06-c7a5-4d3d-8r26-99fg806d559e"}

...when我运行上述代码。

或如果在gocb.Connect(...之后插入以下行，就会得到后面的错误。

err = cluster.WaitUntilReady(25*time.Second, &gocb.WaitUntilReadyOptions{DesiredState: gocb.ClusterStateOnline})
if err != nil {
    panic(err)
}

...error...

panic: unambiguous timeout | {"InnerError":{"InnerError":{"InnerError":{},"Message":"unambiguous timeout"}},"OperationID":"WaitUntilReady","Opaque":"","TimeObserved":25000263891,"RetryReasons":["NOT_READY"],"RetryAttempts":105,"LastDispatchedTo":"","LastDispatchedFrom":"","LastConnectionID":""}  

注意:我在这里更改了Username、Password、Server/connStr、bucket和id。

我在这里错过了什么？

Answer 1

请将答案记在@vsr中。

所有其他的回复都有所帮助，但直到我做了这个建议，在连接之后添加了cluster.Bucket("mybucket")，才起作用。

少了一件事就是写上一个“桶”的名字。见下文..。

除了@vsr帮助和回答之外，我刚刚在文档中找到了一些关于这个的东西。

在刚开始的Golang示例中，https://docs.couchbase.com/go-sdk/current/howtos/n1ql-queries-with-sdk.html在代码注释中提到“对于服务器版本6.5或更高版本，您不需要在这里打开桶”，然后在下一行中打开一个桶。好消息。

    cOpts := gocb.ClusterOptions{
        Authenticator: gocb.PasswordAuthenticator{
            Username: "user",
            Password: "pw",
        },
    }

    cluster, err := gocb.Connect("couchbase://my.dev.server.net/", cOpts)
    if err != nil {
        panic(err)
    }

    bucketName := "myBucket"
    cluster.Bucket(bucketName)

    qOpts := gocb.QueryOptions{}

    // create query
    queryStr := "SELECT * FROM myBucket WHERE id = '123456789'"

    rows, err := cluster.Query(queryStr, &qOpts)
    if err != nil {
        panic(err)
    }

    fmt.Printf("rows: %v\n", rows)

    for rows.Next() {
        var intfc interface{}
        err = rows.Row(&intfc)
        if err != nil {
            panic(err)
        }
        fmt.Printf("interface result: %v\n", intfc)
    }

仅仅添加cluster.Bucket("myBucket")行就可以完成这一任务。

服务器是旧的，而且是一个缺乏资源的dev服务器，所以我还提高了超时时间，知道它会很慢。我将集群选项(代码中命名的cOpts)调整为以下.

    cOpts := gocb.ClusterOptions{
        Authenticator: gocb.PasswordAuthenticator{
            Username: "user",
            Password: "pw",
        },
        TimeoutsConfig: gocb.TimeoutsConfig{
            ConnectTimeout: 95 * time.Second,
            QueryTimeout:   95 * time.Second,
            SearchTimeout:  95 * time.Second,
        },
    }

这会将超时时间提高到95秒，我不需要那么多时间，但是服务器速度足够慢，在UI中为同一个查询花费了40秒，所以我只想确保。

我还调整了查询的超时。我不知道他们之间有什么区别，但我在下面作了调整。

    qOpts := gocb.QueryOptions{}
    qOpts.Readonly = true
    qOpts.ScanWait = 95 * time.Second
    qOpts.Timeout = 95 * time.Second

此外，我是couchbase的新手，如果您不能判断，查询没有使用索引字段。我查找了该桶的索引字段，并将其添加到查询中，这使时间减少了一半以上。

编辑:在USE KEYS中使用N1QL语句看起来非常快，比任何查询都快。我调整了代码以便qryStr查询字符串如下所示..。

queryStr := "SELECT * FROM myBucket USE KEYS ['123456789']"