我正在尝试使用适用于 Bigtable 的 Go SDK 向 Bigtable 表写入一行。我在表对象上使用 apply 方法。
当我尝试多次写入时收到以下错误:
rpc error: code = Canceled desc = grpc: the client connection is closing
以下是我的代码:
func Put(tableName string, columnFamilyName string, rowKey string, attrMap map[string]interface{}) error {
tbl := BigTableClient.Open(tableName)
mut := bigtable.NewMutation()
for key, val := range attrMap {
if utils.IsJSON(val.(string)) {
v, _ := json.Marshal(val)
mut.Set(columnFamilyName, key, bigtable.Now(), []byte(v))
} else {
v := val.(string)
mut.Set(columnFamilyName, key, bigtable.Now(), []byte(v))
}
}
err := tbl.Apply(BigTableContext, rowKey, mut)
if err != nil {
errMsg := "Error while writing to BT: " + err.Error()
logger.LogError(errMsg)
}
return err
}
谁能帮我理解这个问题?
最佳答案
关于go - 将行写入 Cloud Bigtable 时出现客户端错误,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56236306/