登录
首页 >  Golang >  Go问答

go couchbase (gocb) 错误 - 不明确的超时或明确的超时

来源:stackoverflow

时间:2024-04-10 12:12:35 422浏览 收藏

亲爱的编程学习爱好者,如果你点开了这篇文章,说明你对《go couchbase (gocb) 错误 - 不明确的超时或明确的超时》很感兴趣。本篇文章就来给大家详细解析一下,主要介绍一下,希望所有认真读完的童鞋们,都有实质性的提高。

问题内容

我刚刚开始使用 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"}

...当我运行上面的代码时。

或者 如果我在 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":""}

注意:我更改了 usernamepasswordserver/connstrbucketid 仅用于示例目的。

我在这里缺少什么?


正确答案


感谢 @vsr 的回答。
所有其他响应都有帮助,但直到我执行该建议并在连接后添加 cluster.bucket("mybucket") 后才起作用。

缺少的一件事是输入“bucket”名称。见下文...

除了 @vsr 帮助和答案之外,我刚刚在网站上的文档中找到了有关此内容的内容。
[https://docs.couchbase.com/go-sdk/current/howtos/n1ql-queries-with-sdk.html](couchbase 文档) 在刚刚开始的 golang 示例中,它在代码注释中提到“对于服务器版本 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") 行即可完成这项工作。
该服务器很旧,并且是缺乏资源的开发服务器,因此我也增加了超时,因为我知道它会很慢。我通过将集群选项(代码中命名的 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 的新手,查询没有使用索引字段。我查找了该存储桶的索引字段并将其添加到查询中,这样时间就减少了一半以上。

编辑: 在 n1ql 中使用 use keys 语句似乎非常快,比任何查询都快。我调整了代码,因此 qrystr 查询字符串如下所示...

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

今天关于《go couchbase (gocb) 错误 - 不明确的超时或明确的超时》的内容介绍就到此结束,如果有什么疑问或者建议,可以在golang学习网公众号下多多回复交流;文中若有不正之处,也希望回复留言以告知!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>