为了账号安全,请及时绑定邮箱和手机立即绑定

Couchbase gocb 批量操作提供部分为空的结果

Couchbase gocb 批量操作提供部分为空的结果

Go
qq_笑_17 2023-05-15 10:06:32
在我们使用 gocb 的 go 代码中,我们正在查询一个返回 32k id 的视图。然后我们执行批量查询(参见下面的代码),如CouchBase 博客文章中所述。但是,我们只能得到部分结果。我们可以看到ruleset, _ := items[i].(*gocb.GetOp).Value.(*RuleSet)只返回前 2048 个 id 的值。然后 ids 2049 - 11322 不包含值等等。我们的结果看起来像这样:Line 1 Key: 12345678901234567890123456789012, Value: map[0.0.0.0/0:map[jsona:valueofjsona]]...Line 2018 Key: 12345678901234567890123456712345, Value: map[0.0.0.0/0:map[jsona:valueofjsona]]Line 2019 Key: 12345678901234567890123456712345, Value: map[]...Line 11323 Key: 12345678901234567890123456712347, Value: map[jsonb:valueofjsonb]](以上几行是简化的,键与实际数据不匹配,值也不匹配。)很大一部分请求的数据实际上并没有返回:CB# grep '\[\]' result.out |wc -l27042CB# wc -l result.out31988 rdmp.outbucket.do在完成所有查询处理之前是否返回?我们查看了 API 代码,但找不到解释。知道如何解决这个问题吗?type RuleSet struct {    Rules map[string]interface{} "json:\"rules,\""}func DiffViaBulkQuery() {  var items []gocb.BulkOp  var row interface{}  var cnt int = 0  bucket := cbase.MyBucket()// [...]// add 600k entries to itemsget in a loop like // itemsGet = append(itemsGet, &gocb.GetOp{Key: key + "_" + strconv.Itoa(i), Value: &Doc{}})// Perform the bulk operation to Get all documents  err = bucket.Do(itemsGet)  if err != nil {    fmt.Println("ERRROR PERFORMING BULK GET:", err)  }// Print the output  for i := 0; i < len(itemsGet); i++ {    fmt.Println(itemsGet[i].(*gocb.GetOp).Key, itemsGet[i].(*gocb.GetOp).Value.(*Doc).Item)  }提前致谢, Torsten
查看完整描述

目前暂无任何回答

  • 0 回答
  • 0 关注
  • 125 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信