gocouchbase(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: %vn", rows)
for rows.Next() {
var intfc interface{}
err = rows.Row(&intfc)
if err != nil {
panic(err)
}
fmt.Printf("interface result: %vn", intfc)
}

couchbase服务器位于5.1上。

我要么得到。。。

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

当我运行上面的代码时
OR如果我在gocb.Connect(...之后放入以下行，我会得到之后的错误。

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

错误

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")之前，一切都不起作用。

缺少的一件事是；Bucket"；名称请参阅以下内容。。。

除了@vsr的帮助和回答，我刚刚在网站上的文档中发现了一些关于这方面的内容
[https://docs.couchbase.com/go-sdk/current/howtos/n1ql-queries-with-sdk.html](Couchbase文档(在刚开始的Golang示例中，它在代码的注释中提到"对于6.5或更高版本的服务器，您不需要在此处打开bucket"，然后在下一行打开bucket。好消息。

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: %vn", rows)
for rows.Next() {
var intfc interface{}
err = rows.Row(&intfc)
if err != nil {
panic(err)
}
fmt.Printf("interface result: %vn", intfc)
}

只是添加了cluster.Bucket("myBucket")行就实现了这一点
服务器很旧，是一个缺乏资源的开发服务器，所以我知道它会很慢，所以我也增加了超时时间。我通过将集群选项(代码中命名的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的新手，如果你不知道，查询没有使用索引字段。我查找了该bucket的索引字段，并将其添加到查询中，这将时间减少了一半以上。

编辑：在N1QL中使用USE KEYS语句似乎真的很快，比任何查询都快。我调整了代码，使qryStr查询字符串如下所示。。。

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