0
我正在運行一個腳本,該腳本應該抓取大約150000個網頁,並將信息輸出到Excel表格中。我發現程序每50頁左右就會停止工作,所以我一次輸出20頁。我怎麼能讓我的腳本依賴於它已經不活動,然後再說一分鐘,然後重新啓動它停止的地方?在python中處於非活動狀態後重新啓動功能
這裏是我的代碼:
def main():
pass
if __name__ == '__main__':
main()
import urllib2
import re
import time
def get_next_target(page):
start_link = page.find('<tr onclick=' + '"openurl(')
if start_link == -1:
return None, 0
start_quote = page.find("'", start_link)
end_quote = page.find("</tr", start_quote + 1)
url = page[start_quote + 1:end_quote]
url = "http://www.kipa.co.il/" + url
return url, end_quote
def get_all_links(page):
links = []
while True:
url, endpos = get_next_target(page)
if url:
links.append(url)
page = page[endpos:]
else:
break
return links
def split_qa(qa):
splitfrom = qa.find('show_banner')
split = qa.find("s", splitfrom)
q = qa[0:split]
split = qa.find(");", splitfrom)
a = qa[split + 2:]
return q, a
def clear_line(page):
newpage = ''
add = 'yes'
for extract in page:
if extract == '<':
add = 'no'
if add == 'yes':
newpage = newpage + extract
if extract == '>':
add = 'yes'
q, a = split_qa(newpage)
return q, a
def main():
pass
if __name__ == '__main__':
main()
import urllib2
import re
def get_next_target(page):
start_link = page.find('<tr onclick=' + '"openurl(')
if start_link == -1:
return None, 0
start_quote = page.find("'", start_link)
end_quote = page.find("</tr", start_quote + 1)
url = page[start_quote + 1:end_quote]
url = "http://www.kipa.co.il/" + url
return url, end_quote
def get_all_links(page):
links = []
while True:
url, endpos = get_next_target(page)
if url:
links.append(url)
page = page[endpos:]
else:
break
return links
def split_qa(qa):
splitfrom = qa.find('show_banner')
split = qa.find("s", splitfrom)
q = qa[0:split]
split = qa.find(");", splitfrom)
a = qa[split + 2:]
return q, a
def clear_line(page):
newpage = ''
add = 'yes'
for extract in page:
if extract == '<':
add = 'no'
if add == 'yes':
newpage = newpage + extract
if extract == '>':
add = 'yes'
q, a = split_qa(newpage)
return q, a
def get_content(url):
response = urllib2.urlopen(url)
page = response.read()
page = page.decode('utf-8')
start_link = page.find('<p class="padd10">')
if start_link == -1:
return None, 0
start_quote = page.find("<strong>", start_link)
end_quote = page.find('<p class="padd10 ravName">', start_quote + 1)
content = page[start_quote:end_quote]
q, a = clear_line(content)
return q, a
import xlsxwriter
print('where to start?')
i = int(raw_input())
for sheet in range(i,6760):
workbook = xlsxwriter.Workbook('kipa' + str(sheet) + '.xlsx')
worksheet = workbook.add_worksheet()
bold = workbook.add_format({'bold': 1})
worksheet.set_column('A:A', 20)
worksheet.set_column('A:C', 10)
worksheet.set_column('A:D', 30)
worksheet.set_column('A:E', 30)
worksheet.set_column('A:F', 30)
worksheet.write('A1', 'Link', bold)
worksheet.write('B1', 'Date', bold)
worksheet.write('C1', 'Rabbi', bold)
worksheet.write('D1', 'Title', bold)
worksheet.write('E1', 'Qestion', bold)
worksheet.write('F1', 'Answer', bold)
xlplace = 0
qa_page = "http://www.kipa.co.il/ask/page/" + str(i)
i = i + 1
response = urllib2.urlopen(qa_page)
page_source = response.read()
page_source = page_source.decode('utf-8')
biglist = get_all_links(page_source)
qnumeber = 1
for extract in biglist:
xlplace = xlplace + 1
end_quote = extract.find("'", 0)
url = extract[0:end_quote]
worksheet.write(xlplace, 0, url)
start_link = extract.find('<td')
start_quote = extract.find(">", start_link)
end_quote = extract.find("</td>", start_quote + 1)
date = extract[start_quote + 1:end_quote]
worksheet.write(xlplace, 1, date)
start_link = extract.find('<td', end_quote)
start_quote = extract.find(">", start_link)
end_quote = extract.find("</td>", start_quote + 1)
rabbi = extract[start_quote + 1:end_quote]
worksheet.write(xlplace, 2, rabbi)
start_link = extract.find('">', end_quote)
start_quote = extract.find(">", start_link)
end_quote = extract.find("<", start_quote + 1)
title = extract[start_quote + 1:end_quote]
worksheet.write(xlplace, 3, title)
q, a = get_content(url)
worksheet.write(xlplace, 4, q)
worksheet.write(xlplace, 5, a)
print(qnumeber)
qnumeber = qnumeber + 1
print(qa_page)
workbook.close()
有些並行也會有所幫助。這樣,當一件事情超時時,其他人可以繼續徘徊。 – dstromberg
謝謝,我想設置一個超時時間,但是如何讓它再次嘗試網址,比如說4或5次?我創建了一個功能來做到這一點,但它似乎沒有工作 高清GET_URL(URL): 嘗試: 源= urllib2.urlopen(URL,超時= 10) 除了socket.timeout: 打印(」嘗試2') source = urllib2.urlopen(url,timeout = 10) return source – user3084455
好的,再次檢查答案,我只是添加了你的要求。 –