def handle_starttag(self,tag,attrs):
if tag == ‘div‘:
for key,value in attrs:
if key == ‘class‘:
if value == ‘post-thumb‘:
self.isPostThumb = True
elif value == ‘meta-title‘:
self.isMetaTitle = True
elif tag == ‘a‘ and self.isPostThumb == True:
for key, value in attrs:
if self.isReadMore:
if key == ‘href‘:
self.data[‘redmoreLink‘] = value
self.data[‘keyword‘] = ",".join(jieba.cut(self.data[‘title‘]))
self.result.append(self.data)
self.isPostThumb = False
self.isMetaTitle = False
self.isReadMore = False
self.isCategoryTag = False
self.isComment = False
self.isexcerpt = False
self.isPicture = False
self.data = {}
else:
if key == ‘class‘:
if value == ‘meta-title‘:
self.isMetaTitle = True
elif key == ‘rel‘:
if value == ‘category tag‘:
self.isCategoryTag = True
elif key ==‘href‘:
if value.find(‘#respond‘) > 0:
self.isComment = True
elif tag == ‘span‘ and self.isComment == True:
for key, value in attrs:
if key == ‘class‘ and value == ‘excerpt‘:
self.isexcerpt = True
elif key == ‘class‘ and value == ‘read-more‘:
self.isReadMore = True
elif tag == ‘img‘ and self.isPostThumb and self.isPostMeta == False:
for key, value in attrs:
if key == ‘src‘:
self.data[‘imgSrc‘] = value
def handle_endtag(self,tag):
pass
def handle_data(self,data):
if self.isMetaTitle:
self.data[‘title‘] = data
self.isMetaTitle = False
elif self.isCategoryTag:
ct = ‘‘
if ‘tag‘ in self.data.keys() :
ct = self.data[‘tag‘] + "," + data
else:
ct = data
self.data[‘tag‘] = ct
self.isCategoryTag = False
elif self.isComment and ‘comment‘ not in self.data.keys():
self.data[‘comment‘] = data.split(" ")[0]
elif self.isexcerpt:
self.data[‘desc‘] = data
self.isexcerpt = False
def getResult(self):
return self.result
if __name__ == "__main__":
con = pymongo.Connection(‘localhost‘, 27017)
db = con.blog
fetchblog = db.fetch_blog
url = "http://blog.jobbole.com/all-posts/page/%d"
count = 1
flag = False
headers={
‘User-Agent‘:‘Mozilla/5.0 （Windows； U； Windows NT 6.1； en-US； rv：1.9.1.6） Gecko/20091201 Firefox/3.5.6‘}
while flag == False:
try:
req = urllib2.Request(url%count,headers=headers)
request = urllib2.urlopen(req)
data = request.read()
fj = FetchJobble()
fj.feed(data)
result = fj.getResult()
if len(result) < 1:
flag = True
else:
for doc in result:
fetchblog.insert(doc)
print "page is %d"%count
count += 1
