You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
28 lines
563 B
28 lines
563 B
package scheduler
|
|
|
|
import (
|
|
"LAPP_ETL/infra/config"
|
|
"LAPP_ETL/infra/logger"
|
|
model "LAPP_ETL/models/etl"
|
|
svr "LAPP_ETL/services/etl"
|
|
"fmt"
|
|
)
|
|
|
|
func ETLLoad() {
|
|
if config.AppConfig.UseETCD {
|
|
if !CheckService() {
|
|
fmt.Println("service is stop")
|
|
return
|
|
}
|
|
}
|
|
log, _ := logger.NewLogger(-1, "Scheduler")
|
|
taskService := svr.NewTaskHeadService()
|
|
taskLi, err := taskService.SelectWithDetail(model.STAGE_LOAD_DATA)
|
|
if err != nil {
|
|
log.Error("ETLLoad get task failed, error:", err)
|
|
return
|
|
}
|
|
for _, task := range taskLi {
|
|
go LoadTrigger(&task)
|
|
}
|
|
}
|