跟SaveUikey关系不大,应该是max没有区分7/30的hash key造成写入es被统一对待了

This commit is contained in:
zhangkun9038@dingtalk.com 2025-01-15 01:13:40 +08:00
parent 9b5771b301
commit 3643ea51ca

22
main.go
View File

@ -258,57 +258,57 @@ func main() {
// 全员5m // 全员5m
go func() { go func() {
logrus.Info("LoopAllCoinsList - 5m") logrus.Info("LoopAllCoinsList - 5m")
LoopAllCoinsList(360, "5m", 50) LoopAllCoinsList(360, "5m", 20)
}() }()
// 全员15m candle // 全员15m candle
go func() { go func() {
logrus.Info("LoopAllCoinsList - 15m") logrus.Info("LoopAllCoinsList - 15m")
LoopAllCoinsList(720, "15m", 100) LoopAllCoinsList(720, "15m", 30)
}() }()
// 全员30m candle // 全员30m candle
go func() { go func() {
logrus.Info("LoopAllCoinsList - 30m") logrus.Info("LoopAllCoinsList - 30m")
LoopAllCoinsList(1200, "30m", 150) LoopAllCoinsList(1200, "30m", 50)
}() }()
// 全员1H candle // 全员1H candle
go func() { go func() {
logrus.Info("LoopAllCoinsList - 1H") logrus.Info("LoopAllCoinsList - 1H")
LoopAllCoinsList(1800, "1H", 200) LoopAllCoinsList(1800, "1H", 60)
}() }()
// 全员2H candle // 全员2H candle
go func() { go func() {
logrus.Info("LoopAllCoinsList - 2H") logrus.Info("LoopAllCoinsList - 2H")
LoopAllCoinsList(2400, "2H", 250) LoopAllCoinsList(2400, "2H", 80)
}() }()
// 全员4小时candle // 全员4小时candle
go func() { go func() {
logrus.Info("LoopAllCoinsList - 4H") logrus.Info("LoopAllCoinsList - 4H")
LoopAllCoinsList(3000, "4H", 300) LoopAllCoinsList(3000, "4H", 100)
}() }()
// 全员6小时candle // 全员6小时candle
go func() { go func() {
logrus.Info("LoopAllCoinsList - 6H") logrus.Info("LoopAllCoinsList - 6H")
LoopAllCoinsList(3600, "6H", 350) LoopAllCoinsList(3600, "6H", 120)
}() }()
// 全员12小时candle // 全员12小时candle
go func() { go func() {
logrus.Info("LoopAllCoinsList - 12H") logrus.Info("LoopAllCoinsList - 12H")
LoopAllCoinsList(4200, "12H", 400) LoopAllCoinsList(4200, "12H", 160)
}() }()
// 全员1Day candle & maX // 全员1Day candle & maX
go func() { go func() {
logrus.Info("LoopAllCoinsList - 1D") logrus.Info("LoopAllCoinsList - 1D")
LoopAllCoinsList(4800, "1D", 500) LoopAllCoinsList(4800, "1D", 180)
}() }()
// 全员2Day candle & maX // 全员2Day candle & maX
go func() { go func() {
logrus.Info("LoopAllCoinsList - 2D") logrus.Info("LoopAllCoinsList - 2D")
LoopAllCoinsList(6000, "2D", 600) LoopAllCoinsList(6000, "2D", 220)
}() }()
// 全员5Day candle & maX // 全员5Day candle & maX
go func() { go func() {
logrus.Info("LoopAllCoinsList - 5D") logrus.Info("LoopAllCoinsList - 5D")
LoopAllCoinsList(7200, "5D", 700) LoopAllCoinsList(7200, "5D", 240)
}() }()
go func() { go func() {
LoopSaveCandle(&cr) LoopSaveCandle(&cr)