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

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 cmdline

cmdline.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

325139076119a9395befed58f10b0ef7.png

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

設置Log等級:

# 文件mySpider.py

class mySpider(CrawlSpider):

name = "mySpider"

allowed_domains = ["http://photo.poco.cn/"]

custom_settings = {

"LOG_LEVEL":"INFO", # 減少Log輸出量,僅保留必要的信息

# ...... 在爬蟲內部用custom_setting可以讓這個配置信息僅對這一個爬蟲生效

}

以日期為Log文件命名

# 文件settings.py

import datetime

BOT_NAME = "mySpider"

ROBOTSTXT_OBEY = False

startDate = datetime.datetime.now().strftime("%Y%m%d")

LOG_FILE=f"mySpiderlog{startDate}.txt"

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

# 文件pipelines.py

import datetime

GALANCE=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))

97c445acfc43de52ce59398c99d56bfe.png

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

# 文件run.bat

cd /d F:/newClawer20170831/mySpider

call python main.py

pause

bcf17057c078178afa7e425f73a5e22c.png

5. 實現代碼

5.1. 編寫python腳本

# 文件timerStartDaily.py

from scrapy import cmdline

import datetime

import time

import shutil

import os

recoderDir = r"crawls" # 這是為了爬蟲能夠續爬而創建的目錄,存儲續爬需要的數據

checkFile = "isRunning.txt" # 爬蟲是否在運行的標志

startTime = datetime.datetime.now()

print(f"startTime = {startTime}")

i = 0

miniter = 0

while 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.bat

cd /d F:/newClawer20170831/mySpider

call python timerStartDaily.py

pause

6. 部署。

6.1. 添加計劃任務。

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

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

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

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

6.2. 注意事項。

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

03baa5f1530be6deb3d1c74f6bc2c3eb.png

1d1c3dac6c087f83f17448da106d2162.png

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

a844305123d1b954b7a402ab3bc130cb.png

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

正常執行完成:

78ebbc27e8dd7b6bb639e96717419d6b.png

正在執行中:

28ee344c3d38133cd0548e56376fd5d0.png

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

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/259693.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/259693.shtml
英文地址,請注明出處:http://en.pswp.cn/news/259693.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

博客園win8客戶端開發記錄5-app設置 登錄 回復評論

這段時間完成了博客園cnblogs登錄,注銷和設置的相關功能 ,進入軟件, 打開win8的charm setting 選擇設置就是當前軟件的設置選項了, 感覺這有點山寨mac os x系統(所有軟件包括當前系統使用統一的設置)。 扯遠…

Oracle?修改SYS、system用戶密碼

Oracle 修改SYS、system用戶密碼 by:授客 QQ:1033553122 概念 SYS用戶是Oracle中權限最高的用戶,而SYSTEM是一個用于數據庫管理的用戶。在數據庫安裝完之后,應立即修改SYS,SYSTEM這兩個用戶的密碼,以保證數據庫的安全。 安裝完之…

春節小作業總結1

1、x Double.parseDouble(X);字符串轉Double類型; 2、使用正則表達式判斷輸入的是字母還是數字 要import java.util.regex.Pattern 和 java.util.regex.Matcher public boolean isNumeric(String str){ Pattern pattern Pattern.compile("[0-9]*&q…

簡單工廠模式,工廠方法模式,抽象工廠模式,spring的狂想

菜鳥D在項目中遇見一個比較糾結的高耦合,所以就想辦法來解耦。情況是這樣的:系統通過用戶選擇treeview控件的節點判斷調用不同的處理,這些處理中某些東西又是類似的。同事的建議是采用簡單工廠,耦合就耦合吧,反正treev…

堆、棧及靜態數據區詳解 轉

內存分為代碼區、全局數據區、堆區和棧區。堆一般存放動態數據,棧里一般存放局部成員。 關于堆棧和堆的概念[問題] C中創建本地(或者說局域)變量是在堆棧(stack)中分配內存地址,而創建全局變量則是在堆&…

如何使用CSS實現居中

前言: 這一篇主要是翻譯 《how-to-center-anything-with-css》這一篇文章的主要內容,再加上自己的一些概括理解;主要問題是解決垂直居中的問題。我們知道實現水平居中的方式很多種,比如: text-align:center; margin:0 …

java布局_運用 BoxLayout 進行 Swing 控件布局

引言在用戶使用 Java Swing 進行用戶界面開發過程中,會碰到如何對 Java Swing 的控件進行布局的問題。Swing 的控件放置在容器 (Container) 中,容器就是能夠容納控件或者其它容器的類,容器的具體例子有 Frame、Panel 等等。容器需要定義一個布…

js變量類型

js中有null和undefined,null是指對象不存在,undefined是指原生數據不存在 var h {name:lisi,age:28};console.log(h.name)//對象用的是點語法,php中是name->lisi 下面是數組,數組用的是【】語法 1 var arr [a,3,hello,true];…

OPENCV MFC 程序出錯修改

error C2146: 語法錯誤 : 缺少“;”(在標識符“PVOID64”的前面) 來源:http://houjixin.blog.163.com/blog/static/356284102009112395049370/ DirectShow 2009-12-23 09:50:49 閱讀311 評論0 字號:大中小打開winnt.h文件,發現問題就是在winnt.h頭文件中…

測試人員報BUG的正確姿勢

每次我提需求的時候,都會和開發一言不合就上BUG。曾經看到一個段子,告訴了我,吵架是不行滴!影響心情,正確報bug的姿勢應該是這樣:不要對程序員說,你的代碼有BUG。他的第一反應是:1、…

java鏈表實現_鏈表的原理及java實現

一:單向鏈表基本介紹鏈表是一種數據結構,和數組同級。比如,Java中我們使用的ArrayList,其實現原理是數組。而LinkedList的實現原理就是鏈表了。鏈表在進行循環遍歷時效率不高,但是插入和刪除時優勢明顯。下面對單向鏈表…

python和django中的常見錯誤

int() argument must be a string or a number, not tupleError in formatting: coercing to Unicode: need string or buffer, int foundData truncated for column content at row 1sql語句中單引號的設置字段類型字段長度 ascii codec cant decode byte 0xe7 in position 0:…

20141126-解決聯網問題-筆記

當你的網絡出現故障或無法連通時,如何才能簡單高效的找出故障?其實只需要一個ping命令,就可以判斷TCP/IP協議故障…… 1、Ping 127.0.0.1: 127.0.0.1是本地循環地址,如果本地址無法Ping通,則表明本地機TCP/…

inittab腳本啟動解析 (zz)

http://blog.chinaunix.net/uid-17188120-id-4073497.html 1,啟動inittab第一步:啟動內核第二步:執行init (配置文件/etc/inittab)第三步:啟動相應的腳本,執行inittab腳本,并且執行其…

java緩存技術_java緩存技術

最近在做java緩存,了解了一下.以下僅是對map對方式討論。沒有對點陣圖陣討論。作緩存要做以下2點:1:清理及更新緩存時機的處理:. 虛擬機內存不足,清理緩存.. 緩存時間超時,或訪問次數超出, 啟動線程更新2:類和方法的反射 (線程嵌套調用)reflect.invoke的使用。代碼如下&#xf…

xss challenge 解題思路(1-3)

challenge1: 用很基本的方法即可&#xff0c;截圖如下&#xff1a; 提交后成功彈窗&#xff0c;完成。 challenge2 這次我們發現我們輸入的內容被放入value”“ 中&#xff0c;所以需要將前面的結構閉合&#xff0c;構造如下&#xff1a; "><script>alert(docume…

賓得準餅干廣角鏡頭DA15

DA15的掛機效果圖&#xff0c;感覺還是超級的小&#xff0c;是最小的廣角鏡頭了&#xff1a; 主要特點1. 超廣視角當安裝在賓得數碼單反相機上時&#xff0c;這款全新的鏡頭提供相當于35mm膠片規格的約23mm畫面視角&#xff0c;可使拍攝者拍攝出獨特的誘人影像和超廣角鏡頭獨有…

無限“遞歸”的python程序

如果一個函數直接或者間接調用了自己&#xff0c;那么就形成了遞歸&#xff08;recursion&#xff09;&#xff0c;比如斐波那契數列的一個實現 def fib(n):if n < 2:return 1else:return fib(n - 1) fib(n - 2) 遞歸一定要有結束條件&#xff0c;否則就形成了死循環&#…

java slf4j_SLF4J 使用手冊

原文鏈接 譯者&#xff1a;zivyuJava的簡單日志門面( Simple Logging Facade for Java SLF4J)作為一個簡單的門面或抽象&#xff0c;用來服務于各種各樣的日志框架&#xff0c;比如java.util.logging、logback和log4j。SLF4J允許最終用戶在部署時集成自己想要的日志框架。需要…

[譯]Java 垃圾回收介紹

說明&#xff1a;這篇文章來翻譯來自于Javapapers 的Java Garbage Collection Introduction 在Java中&#xff0c;對象內存空間的分配與回收是由JVM中的垃圾回收進程自動完成的。和C語言不一樣的是&#xff0c;開發中不需要在Java中寫垃圾回收代碼。這也是使Java更加流行而且幫…