在我们使用 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
提交
取消