|
|
@@ -156,6 +156,7 @@ func RunWaitingCluster() {
|
|
|
infra.GlobalLogger.Infof("字符串 %v 转整数失败，错误信息为： %v", val, err)
|
|
|
continue
|
|
|
}
|
|
|
+ infra.GlobalLogger.Infof("初始化偏移量【%v】=【%v】", offsetKey, offset)
|
|
|
}
|
|
|
// 取出偏移量后将缓存中的加一，给下个任务使用。
|
|
|
_, err = infra.GlobalRedisClient.Incr(offsetKey).Result()
|
|
|
@@ -163,6 +164,7 @@ func RunWaitingCluster() {
|
|
|
infra.GlobalLogger.Infof("偏移量 %v 加一失败，错误信息为： %v", offsetKey, err)
|
|
|
continue
|
|
|
}
|
|
|
+ infra.GlobalLogger.Infof("偏移量【%v】加一", offsetKey)
|
|
|
|
|
|
// --------------- 发送 kafka 消息（获取偏移量和分区） ---------------
|
|
|
// 获取任务消息转json
|
|
|
@@ -183,6 +185,7 @@ func RunWaitingCluster() {
|
|
|
infra.GlobalLogger.Infof("发送任务消息 %v 失败，错误信息为： %v", msg, err)
|
|
|
continue
|
|
|
}
|
|
|
+ infra.GlobalLogger.Infof("发送任务消息成功，话题为【%v】，偏移量为【%v】。", topic, offset)
|
|
|
|
|
|
// 导入算法
|
|
|
_, s, err := util.Execute("docker", "import", algorithmTarPath, algorithmImageName)
|
