通过搜狗搜索引擎爬取微信公众号文章

#!/usr/bin/env python

# coding=utf-8 import time import os import requests import re import urllib from urllib import request from lxml import etree from bs4 import BeautifulSoup import pymysql as mdb import logging import hashlib class weichat_spider: def __init__(self, ): self.check = True self.htmlPath = 'E:/A_crawling/data/raw/htmlPath/weichat/' self.PicPath = 'E:/A_crawling/data/raw/htmlPath/weichat/' self.headers = None self.search_url = None self.sublist = None self.config = None self.conn = None # 从数据库查询公众号列表 def getSubList(self): self.config = {'host': 'xxx.xxx.x.xx', 'port': 3306, 'user': 'root', 'passwd': '*****', 'db': '****', 'charset': 'utf8'} self.conn = mdb.connect(**self.config) cursor = self.conn.cursor() try: sql = http://g8akg8.riyuangf.com/static/image/nopic320.pngselect subEname,subName from subscription where status= 1 http://g8akg8.riyuangf.com/static/image/nopic320.png cursor.execute(sql) temp = cursor.fetchall() self.conn.commit() return temp except Exception as e: logging.error(e) self.conn.rollback() finally: cursor.close() self.conn.close() # 转换成哈希值 @staticmethod def toHash(x): m = hashlib.md5() m.update(x.encode('utf-8')) return m.hexdigest() # 运行程序 def run(self): self.sublist = self.getSubList() for self.ename, self.name in self.sublist: self.search_url = http://g8akg8.riyuangf.com/static/image/nopic320.pnghttp://weixin.sogou.com/weixin?type=1&s_from=input&query=%s&ie=utf8&_sug_=y&_sug_type_=http://g8akg8.riyuangf.com/static/image/nopic320.png % self.name self.headers = {http://g8akg8.riyuangf.com/static/image/nopic320.pngUser-Agenthttp://g8akg8.riyuangf.com/static/image/nopic320.png: http://g8akg8.riyuangf.com/static/image/nopic320.pngMozilla/5.0 (Windows NT 6.3; WOW64; rv:51.0) Gecko/20100101 Firefox/51.0http://g8akg8.riyuangf.com/static/image/nopic320.png, http://g8akg8.riyuangf.com/static/image/nopic320.pngRefererhttp://g8akg8.riyuangf.com/static/image/nopic320.png: self.search_url} print('开始抓取公众号[' + self.name + ']' + time.strftime('%Y-%m-%d') + '的文章' + ':') self.get_list(self.search_url, self.ename) # 获取被爬取公众号的url连接,并且将url传入爬取的函数 def get_list(self, search_url, ename): # html = requests.get(search_url, headers=self.headers, verify=False).content weichat_id = ename html_catalog = requests.get(search_url, verify=False).text selector = etree.HTML(html_catalog.encode(http://g8akg8.riyuangf.com/static/image/nopic320.pngUTF-8http://g8akg8.riyuangf.com/static/image/nopic320.png)) content = selector.xpath('/html/body/div[2]/div/div[4]/ul/li[1]/div/div[2]/p[1]/a') for list_catalog in content: list_catalog = list_catalog.attrib.get('href') self.get_content(list_catalog, weichat_id) # 获得公众号中文章的详情内容 def get_content(self, each, weichat_id): # article = requests.get(each, headers=self.headers, verify=False).content html_art_url = requests.get(each, verify=False).text soup = BeautifulSoup(html_art_url, 'html.parser') soup_url = soup.findAll(http://g8akg8.riyuangf.com/static/image/nopic320.pngscripthttp://g8akg8.riyuangf.com/static/image/nopic320.png)[7] # 循环获取公众号文章URL for list_art in soup_url: list_art_url_s = re.findall(r'content_url(.*?),', list_art) # 获取公众号文章 for list_art_url in list_art_url_s: list_art_url = 'http://mp.weixin.qq.com' + list_art_url.replace('http://g8akg8.riyuangf.com/static/image/nopic320.png:http://g8akg8.riyuangf.com/static/image/nopic320.png', '').replace('http://g8akg8.riyuangf.com/static/image/nopic320.png', '').replace('amp;', '') content = requests.get(list_art_url, verify=False) art_hash_code = self.toHash(content.url) # 以HTML格式保存文章到本地 htmlPath = self.htmlPath + weichat_id if not os.path.isdir(htmlPath): os.mkdir(htmlPath) self.get_img_text(list_art_url, weichat_id, content, htmlPath + '/%s.html' % art_hash_code) # 获取公众号图片和内容并且保存到本地文件夹 def get_img_text(self, list_art_url, weichat_id, r, out_path): try: # 打开保存路径的文件out_path f = open(out_path, 'w', encoding='utf-8') text = r.text # 保存图片数据 reg = r'-src=http://g8akg8.riyuangf.com/static/image/nopic320.png(https://mmbiz.qpic.cn/.+?)http://g8akg8.riyuangf.com/static/image/nopic320.png ' # print(reg) pic_re = re.compile(reg) html_art_url = requests.get(list_art_url, verify=False).text pic_list = re.findall(pic_re, html_art_url) for pic_url in pic_list: print(pic_url) pic_path = self.PicPath + weichat_id + '/' + self.toHash(list_art_url) + '/' if not os.path.isdir(pic_path): os.mkdir(pic_path) pic_url_new = os.path.join(pic_path, '%s.jpeg' % self.toHash(pic_url)) urllib.request.urlretrieve(pic_url, pic_url_new) # 替换data-src里面的路径,将图片换成本地路径,使其由JS加载的动态网页变成静态HTML,然后再解析保存在本地的HTML存储到数据库 pic_url_all = 'data-src=http://g8akg8.riyuangf.com/static/image/nopic320.png' + pic_url + 'http://g8akg8.riyuangf.com/static/image/nopic320.png' rep_pic_url = self.toHash(list_art_url) + '/' + '%s.jpeg' % self.toHash(pic_url) rep_pic_url_all = 'src=http://g8akg8.riyuangf.com/static/image/nopic320.png' + rep_pic_url + 'http://g8akg8.riyuangf.com/static/image/nopic320.png' text = text.replace(pic_url_all, rep_pic_url_all) # 替换完text里的数据后将数据写入并保存文件到本地 f.write(text) f.flush() f.close() # 解析保存到本地的文章 self.explain_art(out_path) except Exception as e: logging.error('save file:[e=%s,out_path=%s]' % (e, out_path)) # 解析下载到本地的公众号文章并且尝试存入数据库 @staticmethod def explain_art(local_art_url): # content = requests.get(local_art_url, verify=False).text htmlfile = open(local_art_url, 'r', encoding='UTF-8') htmlpage = htmlfile.read() content_html = BeautifulSoup(htmlpage, 'lxml') selector = etree.HTML(content_html.encode(http://g8akg8.riyuangf.com/static/image/nopic320.pngUTF-8http://g8akg8.riyuangf.com/static/image/nopic320.png)) # 文章标题 art_title = selector.xpath('//*[@id=http://g8akg8.riyuangf.com/static/image/nopic320.pngactivity-namehttp://g8akg8.riyuangf.com/static/image/nopic320.png]')[0].text # 文章作者 art_author_list = selector.xpath('/html/body/div[1]/div/div[1]/div[1]/div[1]/em[2]') if len(art_author_list) > 0: art_author = art_author_list[0].text # 文章发表时间 art_time = selector.xpath('//*[@id=http://g8akg8.riyuangf.com/static/image/nopic320.pngpost-datehttp://g8akg8.riyuangf.com/static/image/nopic320.png]')[0].text # 文章来源 art_source = selector.xpath('//*[@id=http://g8akg8.riyuangf.com/static/image/nopic320.pngpost-userhttp://g8akg8.riyuangf.com/static/image/nopic320.png]')[0].text # 文章正文内容 # art_connect = selector.xpath('//*[@id=http://g8akg8.riyuangf.com/static/image/nopic320.pngactivity-namehttp://g8akg8.riyuangf.com/static/image/nopic320.png]') art_connect = content_html.findAll('div', class_='rich_media_content')[0].contents # print(art_connect) if __name__ == '__main__': # @version : 3.5 # @Author : robot_lei # @Software: PyCharm Community Edition print(http://g8akg8.riyuangf.com/static/image/nopic320.pnghttp://g8akg8.riyuangf.com/static/image/nopic320.pnghttp://g8akg8.riyuangf.com/static/image/nopic320.png/* * * _oo8oo_ * o8888888o * 88http://g8akg8.riyuangf.com/static/image/nopic320.png . http://g8akg8.riyuangf.com/static/image/nopic320.png88 * (| -_- |) * 0 = /0 * ___/'==='___