Couchbase集群的SearchQuery不适用于Go客户端的v2版本

Question

我要做的是对其中一个桶进行搜索。我用最小配置初始化了集群，还设置了FTS的分支，并将FTS添加到服务中。然后，我用最小选项连接到集群：

cluster, err = gocb.Connect(settings.CouchbaseConnectionString, gocb.ClusterOptions{
    Username: settings.CouchbaseUser,
    Password: settings.CouchbasePassword,
})

然后，我想按如下方式进行搜索(此时，查询并不重要)：

rows, err := cluster.SearchQuery("fts_index", query, nil)
if err != nil {
    log.Printf("View query error: %s\n", err)
    return 0
}

结果：

View query error: failed to get query provider: the cluster does not support cluster-level queries (only Couchbase Server 6.5 and later) and no bucket is open. If an older Couchbase Server version is used, at least one bucket needs to be opened...

这解释了实际问题是什么，但是当我在操作之前打开一个桶时，会抛出以下错误：

View query error: failed to get query provider: not connected to cluster...

我调试了代码，查询检查了GCCCP轮询，所以当桶没有打开集群的clusterClient设置为值的字段时，GCCCP支持可以读取它，但它告诉我不支持它，这会引发第一个错误。打开桶后，集群的clusterClient设置为零，因此引发第二个错误。

知道我该怎么做布道吗？

版本：

• 库奇基: 6.5.1
• gocb: 2.1.1

Answer 1

我找到了一个相关的问题，在这里，当代码正确地连接到集群的桶时，我必须等待。

解决方案：

bucket := cluster.Bucket("bucket")
bucket.WaitUntilReady(30*time.Second, &gocb.WaitUntilReadyOptions{DesiredState: gocb.ClusterStateOnline})
rows, err := cluster.SearchQuery("fts_index", query, nil)
// ...

重要的部分是WaitUntilReady。

Answer 2

看起来您需要像在https://docs.couchbase.com/go-sdk/current/hello-world/start-using-sdk.html上描述的那样先打开桶