|
|
@@ -4,7 +4,6 @@ import (
|
|
|
"context"
|
|
|
"fmt"
|
|
|
"github.com/beego/beego/v2/task"
|
|
|
- "hongze/hongze_data_crawler/services/national_data"
|
|
|
)
|
|
|
|
|
|
func Task() {
|
|
|
@@ -16,11 +15,11 @@ func Task() {
|
|
|
syncEiaSteoData := task.NewTask("SyncEiaSteoData", "0 0 22 * * *", SyncEiaSteoData)
|
|
|
|
|
|
// 统计局-分月季年爬
|
|
|
- refreshNationalMonthA := task.NewTask("RefreshNationalMonthDbA", "0 15 2 10 * *", national_data.RefreshNationalMonthDbA)
|
|
|
+ //refreshNationalMonthA := task.NewTask("RefreshNationalMonthDbA", "0 15 2 10 * *", national_data.RefreshNationalMonthDbA)
|
|
|
//refreshNationalMonthB := task.NewTask("RefreshNationalMonthDbB", "0 15 2 16 * *", national_data.RefreshNationalMonthDbB)
|
|
|
- refreshNationalQuarter := task.NewTask("RefreshNationalQuarterDb", "0 25 1 15 * *", national_data.RefreshNationalQuarterDb)
|
|
|
- refreshNationalYearA := task.NewTask("RefreshNationalYearDbA", "0 45 1 20 * *", national_data.RefreshNationalYearDbA)
|
|
|
- refreshNationalYearB := task.NewTask("RefreshNationalYearDbB", "0 45 1 25 * *", national_data.RefreshNationalYearDbB)
|
|
|
+ //refreshNationalQuarter := task.NewTask("RefreshNationalQuarterDb", "0 25 1 15 * *", national_data.RefreshNationalQuarterDb)
|
|
|
+ //refreshNationalYearA := task.NewTask("RefreshNationalYearDbA", "0 45 1 20 * *", national_data.RefreshNationalYearDbA)
|
|
|
+ //refreshNationalYearB := task.NewTask("RefreshNationalYearDbB", "0 45 1 25 * *", national_data.RefreshNationalYearDbB)
|
|
|
|
|
|
task.AddTask("数据爬取", refreshData)
|
|
|
task.AddTask("欧洲天然气爬取", refreshEic)
|
|
|
@@ -28,11 +27,11 @@ func Task() {
|
|
|
task.AddTask("谷歌出行指数爬取", refreshVisitors)
|
|
|
task.AddTask("eia steo报告", syncEiaSteoData) //每天22点爬一次
|
|
|
|
|
|
- task.AddTask("统计局数据爬取-月度A", refreshNationalMonthA) // 每月10号2:15执行
|
|
|
+ //task.AddTask("统计局数据爬取-月度A", refreshNationalMonthA) // 每月10号2:15执行
|
|
|
//task.AddTask("统计局数据爬取-月度B", refreshNationalMonthB) // 每月16号2:15执行
|
|
|
- task.AddTask("统计局数据爬取-季度", refreshNationalQuarter) // 每月15号1:25执行
|
|
|
- task.AddTask("统计局数据爬取-年度A", refreshNationalYearA) // 每月20日1:45执行
|
|
|
- task.AddTask("统计局数据爬取-年度B", refreshNationalYearB) // 每月25日1:45执行
|
|
|
+ //task.AddTask("统计局数据爬取-季度", refreshNationalQuarter) // 每月15号1:25执行
|
|
|
+ //task.AddTask("统计局数据爬取-年度A", refreshNationalYearA) // 每月20日1:45执行
|
|
|
+ //task.AddTask("统计局数据爬取-年度B", refreshNationalYearB) // 每月25日1:45执行
|
|
|
|
|
|
task.StartTask()
|
|
|
//FileCoalJsm()
|
