-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathQiuBaiSpider.py
77 lines (60 loc) · 2.17 KB
/
QiuBaiSpider.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
# -*- coding=utf8 -*-
import urllib3
import urllib
import urllib.parse
import threading
import _thread
import re
import time
class QiuBaiSpider:
def __init__(self):
self.page = 1;
self.pages = [];
self.enable = False;
self.base_url = "http://m.qiushibaike.com/hot/page/"
self.http = urllib3.PoolManager()
def get_page(self, page):
url = self.base_url + str(page) + '/?s=4871432'
user_agent = 'Mozilla/4.0 (compatible; MSIE 5.5; Windows NT)'
headers = { 'User-Agent' : user_agent }
resp = self.http.request('GET', url, headers=headers)
b_content = resp.data
content = b_content.decode("utf-8")
#print(content)
items = re.findall('<div.*?class="content".*?title="(.*?)">(.*?)</div>', content, re.S)
list = []
for item in items:
print(item)
list.append([item[0].replace("\n",""),item[1].replace("\n","")])
return list
def load_page(self):
while self.enable:
if len(self.pages) < 2:
try:
myPage = self.get_page(str(self.page))
self.page += 1
self.pages.append(myPage)
except:
print ('can\'t connect')
else:
time.sleep(1)
def show_page(self,nowPage,page):
for items in nowPage:
print ( items[0] , items[1])
myInput = input()
if myInput == "quit":
self.enable = False
break
def start(self):
self.enable = True
page = self.page
print ("loading")
_thread.start_new_thread(self.load_page,())
while self.enable:
if self.pages:
nowPage = self.pages[0]
del self.pages[0]
self.show_page(nowPage,page)
page += 1
myModel = QiuBaiSpider()
myModel.get_page(1)