提交 3a9a25c9 编写于 作者: S shi.zeyuan

1.xxx

上级 1ae4836f
[mysql] [mysql]
#url=root:Meta.123@tcp(mysql.io:3306)/foot?charset=utf8 url=root:Meta.123@tcp(mysql.io:3306)/foot?charset=utf8
url=root:awe.FOG5188@tcp(39.108.212.245:3306)/foot?charset=utf8 #url=root:awe.FOG5188@tcp(39.108.212.245:3306)/foot?charset=utf8
maxIdle=10 maxIdle=10
maxConn=50 maxConn=50
[cookies] [cookies]
......
...@@ -79,11 +79,11 @@ func Spider_History() { ...@@ -79,11 +79,11 @@ func Spider_History() {
Spider_match_his(v) Spider_match_his(v)
Spider_euroLast_his(v) Spider_euroLast_his(v)
time.Sleep(28 * time.Minute) time.Sleep(28 * time.Minute)
Spider_euroHis_his(v) Spider_asiaLastNew_his(v)
time.Sleep(28 * time.Minute) time.Sleep(28 * time.Minute)
Spider_baseFace_his(v) Spider_baseFace_his(v)
time.Sleep(28 * time.Minute) time.Sleep(28 * time.Minute)
Spider_asiaLastNew_his(v) Spider_euroHis_his(v)
time.Sleep(28 * time.Minute) time.Sleep(28 * time.Minute)
mysql.ShowSQL(false) mysql.ShowSQL(false)
} }
......
...@@ -50,6 +50,12 @@ func (this *AsiaLastNewProcesser) Startup() { ...@@ -50,6 +50,12 @@ func (this *AsiaLastNewProcesser) Startup() {
for i, v := range this.MatchLastList { for i, v := range this.MatchLastList {
if !this.SingleThread && i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider if !this.SingleThread && i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider
//先将前面的spider启动
newSpider.SetDownloader(down.NewMAsiaLastApiDownloader())
newSpider = newSpider.AddPipeline(pipeline.NewPipelineConsole())
newSpider.SetSleepTime("rand", 1, 300)
newSpider.SetThreadnum(1).Run()
processer = GetAsiaLastNewProcesser() processer = GetAsiaLastNewProcesser()
processer.Setup(this) processer.Setup(this)
newSpider = spider.NewSpider(processer, "AsiaLastNewProcesser"+strconv.Itoa(i)) newSpider = spider.NewSpider(processer, "AsiaLastNewProcesser"+strconv.Itoa(i))
...@@ -65,12 +71,6 @@ func (this *AsiaLastNewProcesser) Startup() { ...@@ -65,12 +71,6 @@ func (this *AsiaLastNewProcesser) Startup() {
url := strings.Replace(win007.WIN007_ASIAODD_NEW_URL_PATTERN, "${matchId}", win007_id, 1) url := strings.Replace(win007.WIN007_ASIAODD_NEW_URL_PATTERN, "${matchId}", win007_id, 1)
newSpider = newSpider.AddUrl(url, "json") newSpider = newSpider.AddUrl(url, "json")
if !this.SingleThread && i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider
newSpider.SetDownloader(down.NewMAsiaLastApiDownloader())
newSpider = newSpider.AddPipeline(pipeline.NewPipelineConsole())
newSpider.SetSleepTime("rand", 1, 300)
newSpider.SetThreadnum(1).Run()
}
} }
newSpider.SetDownloader(down.NewMAsiaLastApiDownloader()) newSpider.SetDownloader(down.NewMAsiaLastApiDownloader())
......
...@@ -55,6 +55,12 @@ func (this *BaseFaceProcesser) Startup() { ...@@ -55,6 +55,12 @@ func (this *BaseFaceProcesser) Startup() {
for i, v := range this.MatchLastList { for i, v := range this.MatchLastList {
if !this.SingleThread && i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider if !this.SingleThread && i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider
//先将前面的spider启动
newSpider.SetDownloader(down.NewMWin007Downloader())
newSpider = newSpider.AddPipeline(pipeline.NewPipelineConsole())
newSpider.SetSleepTime("rand", 1, 300)
newSpider.SetThreadnum(1).Run()
processer = GetBaseFaceProcesser() processer = GetBaseFaceProcesser()
processer.Setup(this) processer.Setup(this)
newSpider = spider.NewSpider(processer, "BaseFaceProcesser"+strconv.Itoa(i)) newSpider = spider.NewSpider(processer, "BaseFaceProcesser"+strconv.Itoa(i))
...@@ -70,12 +76,6 @@ func (this *BaseFaceProcesser) Startup() { ...@@ -70,12 +76,6 @@ func (this *BaseFaceProcesser) Startup() {
url := strings.Replace(win007.WIN007_BASE_FACE_URL_PATTERN, "${matchId}", win007_id, 1) url := strings.Replace(win007.WIN007_BASE_FACE_URL_PATTERN, "${matchId}", win007_id, 1)
newSpider = newSpider.AddUrl(url, "html") newSpider = newSpider.AddUrl(url, "html")
if !this.SingleThread && i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider
newSpider.SetDownloader(down.NewMWin007Downloader())
newSpider = newSpider.AddPipeline(pipeline.NewPipelineConsole())
newSpider.SetSleepTime("rand", 1, 300)
newSpider.SetThreadnum(1).Run()
}
} }
newSpider.SetDownloader(down.NewMWin007Downloader()) newSpider.SetDownloader(down.NewMWin007Downloader())
......
...@@ -57,6 +57,12 @@ func (this *EuroLastProcesser) Startup() { ...@@ -57,6 +57,12 @@ func (this *EuroLastProcesser) Startup() {
for i, v := range this.MatchLastList { for i, v := range this.MatchLastList {
if !this.SingleThread && i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider if !this.SingleThread && i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider
//先将前面的spider启动
newSpider.SetDownloader(down.NewMWin007Downloader())
newSpider = newSpider.AddPipeline(pipeline.NewPipelineConsole())
newSpider.SetSleepTime("rand", 1, 300)
newSpider.SetThreadnum(1).Run()
processer = GetEuroLastProcesser() processer = GetEuroLastProcesser()
processer.Setup(this) processer.Setup(this)
newSpider = spider.NewSpider(processer, "EuroLastProcesser"+strconv.Itoa(i)) newSpider = spider.NewSpider(processer, "EuroLastProcesser"+strconv.Itoa(i))
...@@ -72,12 +78,6 @@ func (this *EuroLastProcesser) Startup() { ...@@ -72,12 +78,6 @@ func (this *EuroLastProcesser) Startup() {
url := strings.Replace(win007.WIN007_EUROODD_URL_PATTERN, "${matchId}", win007_id, 1) url := strings.Replace(win007.WIN007_EUROODD_URL_PATTERN, "${matchId}", win007_id, 1)
newSpider = newSpider.AddUrl(url, "html") newSpider = newSpider.AddUrl(url, "html")
if !this.SingleThread && i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider
newSpider.SetDownloader(down.NewMWin007Downloader())
newSpider = newSpider.AddPipeline(pipeline.NewPipelineConsole())
newSpider.SetSleepTime("rand", 1, 300)
newSpider.SetThreadnum(1).Run()
}
} }
newSpider.SetDownloader(down.NewMWin007Downloader()) newSpider.SetDownloader(down.NewMWin007Downloader())
......
...@@ -56,6 +56,12 @@ func (this *EuroTrackProcesser) Startup() { ...@@ -56,6 +56,12 @@ func (this *EuroTrackProcesser) Startup() {
for i, v := range this.MatchLastList { for i, v := range this.MatchLastList {
if !this.SingleThread &&i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider if !this.SingleThread &&i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider
//先将前面的spider启动
newSpider.SetDownloader(down.NewMWin007Downloader())
newSpider = newSpider.AddPipeline(pipeline.NewPipelineConsole())
newSpider.SetSleepTime("rand", 1, 300)
newSpider.SetThreadnum(1).Run()
processer = GetEuroTrackProcesser() processer = GetEuroTrackProcesser()
processer.Setup(this) processer.Setup(this)
newSpider = spider.NewSpider(processer, "EuroTrackProcesser"+strconv.Itoa(i)) newSpider = spider.NewSpider(processer, "EuroTrackProcesser"+strconv.Itoa(i))
...@@ -73,12 +79,6 @@ func (this *EuroTrackProcesser) Startup() { ...@@ -73,12 +79,6 @@ func (this *EuroTrackProcesser) Startup() {
url := strings.Replace(base_url, "${cId}", v, 1) url := strings.Replace(base_url, "${cId}", v, 1)
newSpider = newSpider.AddUrl(url, "html") newSpider = newSpider.AddUrl(url, "html")
} }
if !this.SingleThread && i%1000 == 0 { //10000个比赛一个spider,一个赛季大概有30万场比赛,最多30spider
newSpider.SetDownloader(down.NewMWin007Downloader())
newSpider = newSpider.AddPipeline(pipeline.NewPipelineConsole())
newSpider.SetSleepTime("rand", 1, 300)
newSpider.SetThreadnum(1).Run()
}
} }
newSpider.SetDownloader(down.NewMWin007Downloader()) newSpider.SetDownloader(down.NewMWin007Downloader())
......
...@@ -67,6 +67,12 @@ func (this *MatchHisProcesser) Startup() { ...@@ -67,6 +67,12 @@ func (this *MatchHisProcesser) Startup() {
for i, v := range seasonList { for i, v := range seasonList {
if i%10 == 0 { //10个联赛一个spider,总数1000多个联赛,最多100spider if i%10 == 0 { //10个联赛一个spider,总数1000多个联赛,最多100spider
//先将前面的spider启动
newSpider.SetDownloader(down.NewMWin007Downloader())
newSpider = newSpider.AddPipeline(pipeline.NewPipelineConsole())
newSpider.SetSleepTime("rand", 1, 300)
newSpider.SetThreadnum(1).Run()
processer = GetMatchHisProcesser() processer = GetMatchHisProcesser()
processer.Setup(this) processer.Setup(this)
newSpider = spider.NewSpider(processer, "MatchHisProcesser"+strconv.Itoa(i)) newSpider = spider.NewSpider(processer, "MatchHisProcesser"+strconv.Itoa(i))
...@@ -84,12 +90,6 @@ func (this *MatchHisProcesser) Startup() { ...@@ -84,12 +90,6 @@ func (this *MatchHisProcesser) Startup() {
processer.SUrl_Season[round_url] = v processer.SUrl_Season[round_url] = v
newSpider = newSpider.AddUrl(round_url, "html") newSpider = newSpider.AddUrl(round_url, "html")
} }
if i%10 == 0 { //10个联赛一个spider,总数1000多个联赛,最多100spider
newSpider.SetDownloader(down.NewMWin007Downloader())
newSpider = newSpider.AddPipeline(pipeline.NewPipelineConsole())
newSpider.SetSleepTime("rand", 1, 300)
newSpider.SetThreadnum(1).Run()
}
} }
newSpider.SetDownloader(down.NewMWin007Downloader()) newSpider.SetDownloader(down.NewMWin007Downloader())
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册