有個專案年前要做最后一次上線，專案中有用到 aliyun tablestore 的一個模塊我做了一次重構，
這個模塊的主要功能為從 Kafka 訂閱訊息，做一個的格式化處理之后存盤到 aliyun 的 TableStore，并且提供介面根據查詢引數從 aliyun tablestore 查詢相關的資料，重構后查詢介面的部分代碼如下：
func GetLimit(userID, deviceName string, messageID int64, limit int32) ([]*StoredMessage, error) {
request := &tablestore.GetRangeRequest{}
rangeRowQueryCriteria := &tablestore.RangeRowQueryCriteria{}
rangeRowQueryCriteria.TableName = tableName
startPK := new(tablestore.PrimaryKey)
startPK.AddPrimaryKeyColumn(primaryUserID, userID)
startPK.AddPrimaryKeyColumn(primaryDeviceName, deviceName)
startPK.AddPrimaryKeyColumn(primaryMessageID, messageID)
endPK := new(tablestore.PrimaryKey)
endPK.AddPrimaryKeyColumn(primaryUserID, userID)
endPK.AddPrimaryKeyColumn(primaryDeviceName, deviceName)
endPK.AddPrimaryKeyColumn(primaryMessageID, math.MinInt64)
rangeRowQueryCriteria.StartPrimaryKey = startPK
rangeRowQueryCriteria.EndPrimaryKey = endPK
rangeRowQueryCriteria.Direction = tablestore.BACKWARD
rangeRowQueryCriteria.MaxVersion = 1
rangeRowQueryCriteria.Limit = limit
request.RangeRowQueryCriteria = rangeRowQueryCriteria
response, err := client.GetRange(request)
if err != nil {
return nil, err
}
...
}
專案更新上線之后，查詢介面失效了，從日志系統沒有撈到錯誤日志，這么一想，可能是 panic 了，從 daoker 容器直接去撈日志，果然，發現了 panic 的資訊，（由于這個模塊的 panic 日志沒有通過 syslog 發送出去，所以日志系統查不到，萬惡的 panic）
好了，分析問題（panic 日志具體已經找不到了，我沒存下來），問題在 client.GetRange 這個方法上，根據原始碼進一步深入，會發現下面的代碼:
func NewPrimaryKeyColumn(name []byte, value interface{}, option PrimaryKeyOption) *PrimaryKeyColumnInner {
if option == NONE {
v := &PrimaryKeyColumnInner{}
v.Name = name
t := reflect.TypeOf(value)
switch t.Kind() {
case reflect.String:
v.Type = otsprotocol.PrimaryKeyType_STRING
case reflect.Int64:
v.Type = otsprotocol.PrimaryKeyType_INTEGER
case reflect.Slice:
v.Type = otsprotocol.PrimaryKeyType_BINARY
default:
panic(errInvalidInput)
}
v.Value = https://www.cnblogs.com/snowInPluto/p/value
return v
} else if option == AUTO_INCREMENT {
return NewPrimaryKeyColumnAuto_Increment(name)
} else if option == MIN {
return NewPrimaryKeyColumnINF_MIN(name)
} else {
return NewPrimaryKeyColumnINF_MAX(name)
}
}
所以它的 PrimaryKeyColumn 的值型別只能是 string, int64 或者 slice 其中一種，而我傳遞的 math.MinInt64 是 untyped int，就直接 panic 了，
解決方法簡單，轉一下就行了，int64(math.MinInt64)，
這個 sdk 的注釋真的不多，GetRange 的方法上也沒有注釋，真是讓人很容易用錯，最根本問題是，這種直接 panic 的代碼邏輯真的是害死人，所以啊 Don't use panic, use error!
使用的 aliyun tablestore go client sdk 版本為 v4.1.3，[email protected]
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/263184.html
標籤：Go