Я пытаюсь записать строку в таблицу 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
}
Может кто-нибудь помочь мне разобраться в проблеме?