|
|
@@ -17,12 +17,12 @@ func Task() {
|
|
|
FileCoalCoastal()
|
|
|
FileCoalInland()
|
|
|
refreshData := task.NewTask("refreshData", "0 0,30 16-23 * * *", RefreshData)
|
|
|
- refreshEic := task.NewTask("refreshData", "0 0 2,6 * * *", RefreshEic)
|
|
|
- refreshCoal := task.NewTask("refreshData", "0 0,30 16-23 * * *", RefreshCoal)
|
|
|
+ refreshEic := task.NewTask("RefreshEic", "0 0 2,6 * * *", RefreshEic)
|
|
|
+ refreshCoal := task.NewTask("RefreshCoal", "0 0,30 16-23 * * *", RefreshCoal)
|
|
|
refreshVisitors := task.NewTask("RefreshChangesVisitorsCovid", "0 30 2-22/10 * * *", RefreshChangesVisitorsCovid)
|
|
|
syncEiaSteoData := task.NewTask("SyncEiaSteoData", "0 0 22 * * *", SyncEiaSteoData)
|
|
|
- syncYearComTrade := task.NewTask("SyncEiaSteoData", "0 0 3 1 1 *", SyncYearComTrade) // 每年一月一号同步
|
|
|
- syncYearMonthComTrade := task.NewTask("SyncEiaSteoData", "0 0 3 1 * *", SyncYearMonthComTrade) // 每月1号同步
|
|
|
+ syncYearComTrade := task.NewTask("SyncYearComTrade", "0 0 3 1 1 *", SyncYearComTrade) // 每年一月一号同步
|
|
|
+ syncYearMonthComTrade := task.NewTask("SyncYearMonthComTrade", "0 0 3 1 * *", SyncYearMonthComTrade) // 每月1号同步
|
|
|
|
|
|
// 统计局-分月季年爬
|
|
|
//refreshNationalMonthA := task.NewTask("RefreshNationalMonthDbA", "0 15 2 10 * *", national_data.RefreshNationalMonthDbA)
|
|
|
@@ -35,7 +35,7 @@ func Task() {
|
|
|
task.AddTask("欧洲天然气爬取", refreshEic)
|
|
|
task.AddTask("中国煤炭网爬取", refreshCoal)
|
|
|
task.AddTask("谷歌出行指数爬取", refreshVisitors)
|
|
|
- task.AddTask("eia steo报告", syncEiaSteoData) //每天22点爬一次
|
|
|
+ task.AddTask("eia steo报告", syncEiaSteoData) //每天22点爬一次
|
|
|
task.AddTask("UN年度数据", syncYearComTrade) //每年一月一号的3点同步
|
|
|
task.AddTask("UN月度数据", syncYearMonthComTrade) //每月1号的3点同步
|
|
|
|
ziwen