redis replace go redis

pull/455/head
Gordon 3 years ago committed by Xinwei Xiong(cubxxw-openim)
parent 40494f605b
commit f002044db1

@ -31,7 +31,7 @@ func (d *DataBases) NewSetMessageToCache(msgList []*pbChat.MsgDataToMQ, uid stri
} }
log2.NewDebug(operationID, "convert map is ", s) log2.NewDebug(operationID, "convert map is ", s)
fmt.Println("ts", s) fmt.Println("ts", s)
val, err := d.rdb.HSet(ctx, key, s).Result() val, err := d.rdb.HMSet(ctx, key, s).Result()
if err != nil { if err != nil {
log2.NewWarn(operationID, utils.GetSelfFuncName(), "redis failed", "args:", key, *msg, uid, s, val) log2.NewWarn(operationID, utils.GetSelfFuncName(), "redis failed", "args:", key, *msg, uid, s, val)
failedList = append(failedList, *msg) failedList = append(failedList, *msg)

Loading…
Cancel
Save