日本不卡不码高清免费观看,久久国产精品久久w女人spa,黄色aa久久,三上悠亚国产精品一区二区三区

您的位置:首頁技術文章
文章詳情頁

python實現scrapy爬蟲每天定時抓取數據的示例代碼

瀏覽:35日期:2022-06-29 08:22:01
1. 前言。1.1. 需求背景。 每天抓取的是同一份商品的數據,用來做趨勢分析。 要求每天都需要抓一份,也僅限抓取一份數據。 但是整個爬取數據的過程在時間上并不確定,受本地網絡,代理速度,抓取數據量有關,一般情況下在20小時左右,極少情況下會超過24小時。1.2. 實現功能。

通過以下三步,保證爬蟲能自動隔天抓取數據: 每天凌晨00:01啟動監控腳本,監控爬蟲的運行狀態,一旦爬蟲進入空閑狀態,啟動爬蟲。

一旦爬蟲執行完畢,自動退出腳本,結束今天的任務。

一旦腳本距離啟動時間超過24小時,自動退出腳本,等待第二天的監控腳本啟動,重復這三步。

2. 環境。

python 3.6.1

系統:win7

IDE:pycharm

安裝過scrapy

3. 設計思路。

3.1. 前提:

目前爬蟲是通過scrapy模塊自帶的cmdline.execute來啟動的。

from scrapy import cmdlinecmdline.execute(’scrapy crawl mySpider’.split())

3.2. 將自動執行腳本做到scrapy爬蟲的外部

(1)每天凌晨00:01啟動腳本(控制腳本的存活時間為24小時),監測爬蟲的運行狀態(需要用一個標記信息來表示爬蟲的狀態:運行還是停止)。

如果爬蟲處于運行狀態(前一天爬取數據尚未結束),進入第(2)步; 如果爬蟲處于非運行狀態(前一天的爬取任務已完成,今天的尚未開始),進入第(3)步;

(2)腳本進入等待階段,每隔10分鐘,檢查一下爬蟲的運行狀態,如(1)。但是一旦發現,腳本的等待時間超過了24小時,則自動退出腳本,因為第二天的監測腳本已經開始運行了,接替了它的任務。

(3)做一些爬蟲啟動前的準備工作(刪除用來續爬的文件,防止爬蟲不運行了),啟動爬蟲爬取數據,待爬蟲正常結束后,退出腳本,完成當天的爬取任務。

4. 準備工作。4.1. 標記爬蟲的運行狀態。

通過判斷文件是否存在的方式來判斷爬蟲是否處于運行狀態:

在爬蟲啟動時,創建一個isRunning.txt文件。 在爬蟲結束時,刪除這個isRunning.txt文件。

那么isRunning.txt存在,就說明爬蟲正在運行;文件不存在,就說明爬蟲不在運行。

# 文件pipelines.py# 爬蟲啟動時checkFile = 'isRunning.txt'class myPipeline: def open_spider(self, spider): self.client = MongoClient(’localhost:27017’) # 連接Mongodb self.db = self.client[’mydata’]# 待存儲數據的數據庫mydata f = open(checkFile, 'w') # 創建一個文件,代表爬蟲在運行中 f.close()

# 文件pipelines.py# 爬蟲正常結束時checkFile = 'isRunning.txt'class myPipeline: def close_spider(self, spider): self.client.close() isFileExsit = os.path.isfile(checkFile) if isFileExsit: os.remove(checkFile)4.2. 爬蟲支持續爬,能隨時暫停,方便調試。

# 在scrapy項目中添加start.py文件,用于啟動爬蟲from scrapy import cmdline# 在爬蟲運行過程中,會自動將狀態信息存儲在crawls/storeMyRequest目錄下,支持續爬cmdline.execute(’scrapy crawl mySpider -s JOBDIR=crawls/storeMyRequest’.split())# Note:若想支持續爬,在ctrl+c終止爬蟲時,只能按一次,爬蟲在終止時需要進行善后工作,切勿連續多次按ctrl+c

python實現scrapy爬蟲每天定時抓取數據的示例代碼

4.3. Log按照每天的日期命名,方便查看和調試

設置Log等級:

# 文件mySpider.pyclass mySpider(CrawlSpider): name = 'mySpider' allowed_domains = [’http://photo.poco.cn/’] custom_settings = { ’LOG_LEVEL’:’INFO’, # 減少Log輸出量,僅保留必要的信息 # ...... 在爬蟲內部用custom_setting可以讓這個配置信息僅對這一個爬蟲生效 }

以日期為Log文件命名

# 文件settings.pyimport datetimeBOT_NAME = ’mySpider’ROBOTSTXT_OBEY = FalsestartDate = datetime.datetime.now().strftime(’%Y%m%d’)LOG_FILE=f'mySpiderlog{startDate}.txt'

4.4. 為數據按日期存儲到不同的表(mongodb的集合)中

# 文件pipelines.pyimport datetimeGALANCE=f’galance{datetime.datetime.now().strftime('%Y%m%d')}’ # 表名

class myPipeline: def open_spider(self, spider): self.client = MongoClient(’localhost:27017’) # 連接Mongodb self.db = self.client[’mydata’]# 待存儲數據的數據庫mydata

self.db[GALANCE].insert(dict(item))

python實現scrapy爬蟲每天定時抓取數據的示例代碼

4.5. 編寫批處理文件啟動爬蟲

# 文件run.batcd /d F:/newClawer20170831/mySpidercall python main.pypause

python實現scrapy爬蟲每天定時抓取數據的示例代碼

5. 實現代碼5.1. 編寫python腳本

# 文件timerStartDaily.pyfrom scrapy import cmdlineimport datetimeimport timeimport shutilimport osrecoderDir = r'crawls' # 這是為了爬蟲能夠續爬而創建的目錄,存儲續爬需要的數據checkFile = 'isRunning.txt' # 爬蟲是否在運行的標志startTime = datetime.datetime.now()print(f'startTime = {startTime}')i = 0miniter = 0while True: isRunning = os.path.isfile(checkFile) if not isRunning: # 爬蟲不在執行,開始啟動爬蟲 # 在爬蟲啟動之前處理一些事情,清掉JOBDIR = crawls isExsit = os.path.isdir(recoderDir) # 檢查JOBDIR目錄crawls是否存在 print(f'mySpider not running, ready to start. isExsit:{isExsit}') if isExsit: removeRes = shutil.rmtree(recoderDir) # 刪除續爬目錄crawls及目錄下所有文件 print(f'At time:{datetime.datetime.now()}, delete res:{removeRes}') else: print(f'At time:{datetime.datetime.now()}, Dir:{recoderDir} is not exsit.') time.sleep(20) clawerTime = datetime.datetime.now() waitTime = clawerTime - startTime print(f'At time:{clawerTime}, start clawer: mySpider !!!, waitTime:{waitTime}') cmdline.execute(’scrapy crawl mySpider -s JOBDIR=crawls/storeMyRequest’.split()) break #爬蟲結束之后,退出腳本 else: print(f'At time:{datetime.datetime.now()}, mySpider is running, sleep to wait.') i += 1 time.sleep(600) # 每10分鐘檢查一次 miniter += 10 if miniter >= 1440: # 等待滿24小時,自動退出監控腳本 break

5.2. 編寫bat批處理文件

# 文件runTimerRunDaily.batcd /d F:/newClawer20170831/mySpidercall python timerStartDaily.pypause6. 部署。6.1. 添加計劃任務。

參考以下這篇博客部署windows計劃任務:

https://www.jb51.net/article/204879.htm

有關windows計劃任務相關設置的詳細說明如下:

https://technet.microsoft.com/zh-cn/library/cc722178.aspx

6.2. 注意事項。

(1)在添加計劃任務時,要按照如下圖進行勾選(只在用戶登錄時運行),才能彈出下面的cmd任務界面,方便觀察和調試。

python實現scrapy爬蟲每天定時抓取數據的示例代碼

python實現scrapy爬蟲每天定時抓取數據的示例代碼

(2)由于爬蟲運行時間很長,如果按照默認設置,在凌晨運行實例時,上一次啟動尚未結束,會導致這次啟動失敗,所以要更改默認設置為(如果此任務已經運行:并行運行新實例。保護機制在于每個啟動腳本在等待24小時候會自動退出,來保證不會重復啟動)。

python實現scrapy爬蟲每天定時抓取數據的示例代碼

(3)如果想支持續傳,只能按一次 ctrl + c 來停止爬蟲運行。因為終止爬蟲時,爬蟲需要做一些善后工作,如果連續按多次ctrl + c來停止爬蟲,爬蟲將來不及善后,會導致無法續爬。 6.3. 效果展示。

正常執行完成:

python實現scrapy爬蟲每天定時抓取數據的示例代碼

正在執行中:

python實現scrapy爬蟲每天定時抓取數據的示例代碼

到此這篇關于python實現scrapy爬蟲每天定時抓取數據的示例代碼的文章就介紹到這了,更多相關python scrapy定時抓取內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Python 編程
相關文章:
日本不卡不码高清免费观看,久久国产精品久久w女人spa,黄色aa久久,三上悠亚国产精品一区二区三区
色爱综合av| 免费在线观看日韩欧美| 日韩欧美久久| 国产欧美日韩在线一区二区| 天堂av在线一区| 国产精品日本欧美一区二区三区| 亚洲国产一区二区三区在线播放| 国产综合精品| 日本 国产 欧美色综合| 日韩精品亚洲aⅴ在线影院| 亚洲精品2区| 热久久国产精品| 欧美视频精品全部免费观看| 国产精品午夜av| 亚洲天堂av影院| 99视频精品| 国产欧美日韩免费观看| 久久久久免费| 免费观看在线色综合| 国产精品xxx在线观看| 精品美女在线视频| 99在线|亚洲一区二区| 国产人成精品一区二区三| 一区二区三区四区日本视频| 久久国产高清| 国产成人精品亚洲线观看| 黄色在线一区| 欧美精品国产| 国产亚洲高清视频| 久久精品国产福利| 日韩一区二区在线免费| 欧美精品导航| 亚洲成人精品| 欧美视频久久| 天堂成人国产精品一区| 日韩精品视频在线看| 欧美日韩中文一区二区| 国产精品v亚洲精品v日韩精品| 国产在线看片免费视频在线观看| 亚洲a级精品| 国产真实久久| 精品九九久久| 亚洲人成亚洲精品| 欧美美女一区| 日韩在线高清| 日韩av片子| 美日韩一区二区三区| 日韩国产在线一| 麻豆91精品视频| 久久要要av| 精品国产黄a∨片高清在线| 无码日韩精品一区二区免费| 午夜国产精品视频免费体验区| 精品国产鲁一鲁****| 日韩avvvv在线播放| 亚洲免费资源| 亚洲资源网站| 影音先锋久久精品| 蜜桃久久久久久久| 日本欧美在线看| 亚洲乱亚洲高清| 亚洲欧美久久精品| 欧美一区91| 国产黄色精品| 精品国产乱码久久久久久樱花| 日韩av资源网| 国产精品久久乐| 色爱综合网欧美| 夜鲁夜鲁夜鲁视频在线播放| 日韩欧美一区二区三区在线观看| 日韩中文在线播放| 图片区亚洲欧美小说区| 香蕉久久夜色精品国产| 亚洲乱码久久| 国产一区二区三区日韩精品 | 亚洲综合图色| 日韩三级久久| 欧美精品aa| 欧美交a欧美精品喷水| 丝袜诱惑一区二区| 婷婷亚洲五月色综合| 欧美一区影院| 成人片免费看| 日本综合视频| 欧美日韩国产观看视频| 快she精品国产999| 国语精品一区| 国产视频一区三区| 国产一区二区精品久| 久久香蕉精品| 福利一区和二区| 天使萌一区二区三区免费观看| 久久av偷拍| 免费成人网www| 美腿丝袜亚洲三区| 丝袜a∨在线一区二区三区不卡| 免费亚洲一区| 免费日本视频一区| 伊伊综合在线| 欧美日韩亚洲一区三区| 亚洲福利久久| 美女久久久久久| 亚洲精品综合| 午夜欧美理论片| 中文在线资源| 欧美日韩精品一区二区三区视频 | 欧洲在线一区| 国产精品一级在线观看| 午夜在线一区二区| 激情视频一区二区三区| 成人一区而且| 国产精品主播| 午夜性色一区二区三区免费视频| 欧美黄色网页| 动漫av一区| 日本视频一区二区| 亚洲国产一区二区三区在线播放 | 欧美精选一区二区三区| 精品丝袜在线| 国产精品亚洲一区二区三区在线观看| 国产精品极品国产中出| 亚洲精品美女91| 亚洲综合婷婷| 日韩成人午夜精品| 日本91福利区| 欧美激情日韩| 91综合视频| 99精品小视频| 激情久久久久久久| 99国产精品| 色综合视频一区二区三区日韩 | 国产精品日本一区二区三区在线| 亚洲精品在线a| 欧美日韩黄网站| 久久伊人亚洲| 日韩高清欧美| 亚洲第一区色| 日韩午夜视频在线| 欧美日韩黄网站| 精品一区电影| se01亚洲视频| 三级一区在线视频先锋| 性色一区二区| 国产日韩欧美一区在线| 精品伊人久久| 久久一区二区三区喷水| 99日韩精品| 国产精品手机在线播放| 91精品韩国| 日本不卡一二三区黄网| 国产一区二区三区天码| 国产亚洲在线| 国产成人精品一区二区三区免费 | 亚洲18在线| 精品国产欧美日韩一区二区三区| japanese国产精品| 日韩在线精品| 久久不射中文字幕| 国产精品一区二区av日韩在线| 伊人久久在线| 日韩在线网址| 日本在线精品| 国产欧美一区二区三区精品观看 | 麻豆精品蜜桃视频网站| 尤物在线精品| 精品三级国产| 亚洲乱码视频| 亚洲激情婷婷| а√天堂8资源中文在线| 一区二区91| 久久人人97超碰国产公开结果| 亚洲我射av| 99tv成人| 蜜桃精品在线| 97国产成人高清在线观看| 亚洲精品一级| 免费在线观看精品| 性欧美69xoxoxoxo| 精品一区二区三区视频在线播放| 日韩高清一区| 中文字幕日韩欧美精品高清在线| 黄色av日韩| 伊人久久亚洲影院| 亚洲精品一级二级| 天堂а√在线最新版中文在线| 国产精品s色| 国产精品chinese| 日韩高清不卡一区二区| 日本va欧美va精品| 日本中文字幕视频一区| 精品一区亚洲| 99热免费精品| 蜜桃久久av| 99re国产精品| 免费在线观看不卡| 人人爱人人干婷婷丁香亚洲| 亚洲精品国产精品粉嫩| 欧美天堂在线| 麻豆一区二区三| 天堂av在线|