|
|
@@ -29,7 +29,8 @@ func Task() {
|
|
|
refreshUsdaFms := task.NewTask("RefreshUsdaFms", "0 0 16,19 * * 1,5", DownloadUsdaFmsDataTask) //每周一五下午16点，19点
|
|
|
refreshData := task.NewTask("refreshData", "0 0,30 16-18 * * *", RefreshData)
|
|
|
refreshEic := task.NewTask("RefreshEic", "0 0 2,6 * * *", RefreshEic)
|
|
|
- refreshCoal := task.NewTask("RefreshCoal", "0 0,30 16-23 * * *", RefreshCoal)
|
|
|
+ // 已经使用另外的任务去监听中国煤炭网邮件附件
|
|
|
+ // refreshCoal := task.NewTask("RefreshCoal", "0 0,30 16-23 * * *", RefreshCoal)
|
|
|
refreshMeeting := task.NewTask("RefreshMeeting", "0 15 7-19/2 * * *", RefreshMeetingProbabilities)
|
|
|
// refreshVisitors := task.NewTask("RefreshChangesVisitorsCovid", "0 30 2-22/10 * * *", RefreshChangesVisitorsCovid)
|
|
|
syncEiaSteoData := task.NewTask("SyncEiaSteoData", "0 0 22 * * *", SyncEiaSteoData)
|
|
|
@@ -48,7 +49,7 @@ func Task() {
|
|
|
task.AddTask("美国农业部出口销售数据爬取", refreshUsdaFms)
|
|
|
task.AddTask("数据爬取", refreshData)
|
|
|
task.AddTask("欧洲天然气爬取", refreshEic)
|
|
|
- task.AddTask("中国煤炭网爬取", refreshCoal)
|
|
|
+ // task.AddTask("中国煤炭网爬取", refreshCoal)
|
|
|
task.AddTask("美联储加息概率爬取", refreshMeeting)
|
|
|
//task.AddTask("谷歌出行指数爬取", refreshVisitors)
|
|
|
task.AddTask("eia steo报告", syncEiaSteoData) //每天22点爬一次
|
zqbao