From 56acb65a68fbe85e3ab8fc3b66e512eb4fcd8a30 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期一, 08 四月 2024 17:54:34 +0800
Subject: [PATCH] 修复数据推送的延时问题
---
main.go | 18 +++++++-----------
1 files changed, 7 insertions(+), 11 deletions(-)
diff --git a/main.go b/main.go
index 087099e..b2797d5 100644
--- a/main.go
+++ b/main.go
@@ -61,27 +61,23 @@
url := config.Options.ServerUrl
result, err1 := service.GetData()
if err1 != nil {
- logger.Warn(err1.Error())
- time.Sleep(1 * time.Second)
- retryCount += 1
- break
+ logger.Warn("鑾峰彇es鏁版嵁澶辫触,", err1.Error())
+ return
}
- id, errs2 := service.SendData(result, url)
+ id, err := service.SendData(result, url)
logger.Debug("鎺ㄩ�佺殑鏁版嵁 id: ", id)
- if errs2 == nil {
- //delStatus := service.DeleteData(id)
+ if err == nil {
markStatus := service.MarkData(id)
- fmt.Println(markStatus)
logger.Debug("璁板綍鎺ㄩ�佺姸鎬� markStatus: ", markStatus)
} else {
- logger.Debug("鎺ㄩ�佺殑鏁版嵁澶辫触 id: ", id)
- time.Sleep(1 * time.Second)
+ logger.Debugf("鎺ㄩ�佺殑鏁版嵁澶辫触 id: %s, err:%s", id, err.Error())
+ time.Sleep(5 * time.Second)
retryCount += 1
}
break
} else {
- logger.Debug("鏈嶅姟绔繛鎺ュけ璐�,5绉掑悗灏濊瘯閲嶆柊杩炴帴銆傘�傘��")
+ logger.Debug("鏈嶅姟绔繛鎺ュけ璐�, 5绉掑悗灏濊瘯閲嶆柊杩炴帴銆傘�傘��")
time.Sleep(5 * time.Second)
}
}
--
Gitblit v1.8.0