使用 MitmProxy 自动抓取微信公众号阅读数、点赞和再看数据

优采云 发布时间: 2022-05-14 02:57

  使用 MitmProxy 自动抓取微信公众号阅读数、点赞和再看数据

  当安装好证书和设置好手机端 IP代理后,随便点击一篇微信公众号文章(这里使用本公众)

  

  从图上可以看到,阅读、再看、点赞的url为 .weixin. qq. com/mp/getappmsgext(提示:如果没有这个链接,可以右上角刷新文章),再看下它的request请求需要哪些东西

  

  

  只需要一个文章 url、user-agent、cookie 和 body这四个基本的数据,别看下面body里面有二三十个数据其实都是吓唬人的,只需要其中7个,分别是 __biz, mid, idx,sn 这四个参数是获取公众号文章内容的基石,可以在文章 url 处获得。其他三个参数的数据是固定的分别是 is_only_read = 1,is_temp_url = 0,appmsg_type = 9。getappmsgext 请求中的 appmsg_token 是一个有时效性的参数。

  分析完链接后就可以写代码了

  # articles.py<br />import html<br />import requests<br />import utils<br /><br />from urllib.parse import urlsplit<br /><br />class Articles(object):<br />    """文章信息"""<br /><br />    def __init__(self, appmsg_token, cookie):<br />        # 具有时效性<br />        self.appmsg_token = appmsg_token<br />        <br />        self.headers = {<br />            "User-Agent": "Mozilla/5.0 AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0Chrome/57.0.2987.132 MQQBrowser/6.2 Mobile",<br />            "Cookie": cookie<br />        }<br />        <br />        self.data = {<br />            "is_only_read": "1",<br />            "is_temp_url": "0",<br />            "appmsg_type": "9",<br />        }<br /><br /><br />    def read_like_nums(self, article_url):<br />        """获取数据"""<br />        appmsgstat = self.get_appmsgext(article_url)["appmsgstat"]<br />        return appmsgstat["read_num"], appmsgstat["old_like_num"], appmsgstat["like_num"]<br /><br />    def get_params(self, article_url):<br />        """<br />        获取到文章url上的请求参数<br />        :param article_url: 文章 url<br />        :return: <br />        """<br />        # url转义处理<br />        article_url = html.unescape(article_url)<br />        """获取文章链接的参数"""<br />        url_params = utils.str_to_dict(urlsplit(article_url).query, "&", "=")<br />        return url_params<br /><br />    def get_appmsgext(self, article_url):<br />        """<br />        请求阅读数<br />        :param article_url: 文章 url<br />        :return: <br />        """<br />        url_params = self.get_params(article_url)<br /><br />        appmsgext_url = "https://mp. weixin.qq.com/mp/getappmsgext?appmsg_token={}&x5=0".format(self.appmsg_token)<br />        self.data.update(url_params)<br /><br />        appmsgext_json = requests.post(<br />            appmsgext_url, headers=self.headers, data=self.data).json()<br /><br />        if "appmsgstat" not in appmsgext_json.keys():<br />            raise Exception(appmsgext_json)<br />        return appmsgext_json<br /><br /><br />if __name__ == '__main__':<br />    info = Articles('1068_XQoMoGGBYG8Tf8k23jfdBr2H_LNekAAlDDUe2aG13TN2fer8xOSMyrLV6s-yWESt8qg5I2fJr1r9n5Y5', 'rewardsn=; wxtokenkey=777; wxuin=1681274216; devicetype=android-29; version=27001037; lang=zh_CN; pass_ticket=H9Osk2CMhrlH34mQ3w2PLv/RAVoiDxweAdyGh/Woa1qwGy2jGATJ6hhg7syTQ9nk; wap_sid2=COjq2KEGEnBPTHRVOHlYV2U4dnRqaWZqRXBqaWl3Xy1saXVWYllIVjAzdlM1VkNDNHgxeWpHOG9pckdkREMwTFEwYmNWMl9FZWtRU3pRRnhDS0pyV1BaZUVMWXN1ZWN0WnZ6aHFXdVBnbVhTY21BYnBSUXNCQUFBMLLAjfgFOA1AAQ==')<br />    a, b,c = info.read_like_nums('http://mp. weixin.qq.com/s?__biz=MzU1NDk2MzQyNg==&amp;mid=2247486254&amp;idx=1&amp;sn=c3a47f4bf72b1ca85c99190597e0c190&amp;chksm=fbdad3a3ccad5ab55f6ef1f4d5b8f97887b4a344c67f9186d5802a209693de582aac6429a91c&amp;scene=27#wechat_redirect')<br />    print(a, b, c)<br />

  示例结果

  # 阅读数 点赞数 再看数<br />1561 23 18<br />

  动态获取 cookie 和 appmsg_token

  appmsg_token 是一个具有时效性的参数,和 cookie 一样是需要改变的,当这两个参数过期时就需要从抓包工具(MitmProxy 中)ctrl+C,ctrl+V到代码中,很是麻烦。

  MitmProxy 可以使用命令行接口 mitmdumvp 运行 Python 代码*敏*感*词*抓取的链接,如果抓到了 /mp/getappmsgext就保存在本地文件并退出抓包

  mitmdump 命令

  # -s 运行的python脚本, -w 将截取的内容保持到文件<br />mitmdump -s write_cookie.py -w outfile mp.weixin.qq.com/mp/getappmsgext<br />

  *敏*感*词*脚本

  # coding: utf-8<br /># write_cookie.py<br />import urllib<br />import sys<br /><br />from mitmproxy import http<br /><br /># command: mitmdump -s write_cookie.py -w outfile mp.weixin.qq.com/mp/getappmsgext<br /><br />class WriterCookie:<br />    """<br />    mitmproxy的*敏*感*词*脚本,写入cookie和url到文件<br />    """<br /><br />    def __init__(self, outfile: str) -> None:<br />        self.f = open(outfile, "w")<br /><br />    def response(self, flow: http.HTTPFlow) -> None:<br />        """<br />        完整的response响应<br />        :param flow: flow实例,<br />        """<br />        # 获取url<br />        url = urllib.parse.unquote(flow.request.url)<br /><br />        # 将url和cookie写入文件<br />        if "mp. weixin.qq.com/mp/getappmsgext" in url:<br />            self.f.write(url + '\n')<br />            self.f.write(str(flow.request.cookies))<br />            self.f.close()<br />            # 退出<br />            exit()<br /><br /># 第四个命令中的参数<br />addons = [WriterCookie(sys.argv[4])]<br />

  *敏*感*词*脚本写好之后,再来写启动命令和解析 url,cookie 文件的模块

  # read_cookie.py<br />import re<br />import os<br /><br />class ReadCookie(object):<br />    """<br />    启动write_cookie.py 和 解析cookie文件,<br />    """<br /><br />    def __init__(self, outfile):<br />        self.outfile = outfile<br /><br />    def parse_cookie(self):<br />        """<br />        解析cookie<br />        :return: appmsg_token, biz, cookie_str·<br />        """<br />        f = open(self.outfile)<br />        lines = f.readlines()<br />        appmsg_token_string = re.findall("appmsg_token.+?&", lines[0])<br />        biz_string = re.findall('__biz.+?&', lines[0])<br />        appmsg_token = appmsg_token_string[0].split("=")[1][:-1]<br />        biz = biz_string[0].split("__biz=")[1][:-1]<br /><br />        cookie_str = '; '.join(lines[1][15:-2].split('], [')).replace('\'','').replace(', ', '=')<br />        return appmsg_token, biz, cookie_str<br /><br />    def write_cookie(self):<br />        """<br />        启动 write_cookie。py<br />        :return:<br />        """<br /><br />        #当前文件路径<br />        path = os.path.split(os.path.realpath(__file__))[0]<br />        # mitmdump -s 执行脚本 -w 保存到文件 本命令<br />        command = "mitmdump -s {}/write_cookie.py -w {} mp.weixin.qq.com/mp/getappmsgext".format(<br />            path, self.outfile)<br /><br />        os.system(command)<br /><br /><br />if __name__ == '__main__':<br />    rc = ReadCookie('cookie.txt')<br />    rc.write_cookie()<br />    appmsg_token, biz, cookie_str = rc.parse_cookie()<br />    print("appmsg_token:" + appmsg_token , "\nbiz:" + biz, "\ncookie:"+cookie_str)<br />

  示例结果

  

  cookie.txt 文件内容解析后

  appmsg_token:1068_av3JWyDn2XCS2fwFj3ICCnwArRb2kU4Y5Y5m9Z9NkWoCOszl3a-YHFfBkAguUlYQJi2dWo83AQT4FsNK <br />biz:MzU1NDk2MzQyNg== <br />cookie:rewardsn=; wxtokenkey=777; wxuin=1681274216; devicetype=android-29; version=27001037; lang=zh_CN; pass_ticket=H9Osk2CMhrlH34mQ3w2PLv/RAVoiDxweAdyGh/Woa1qwGy2jGATJ6hhg7syTQ9nk; wap_sid2=COjq2KEGEnBPTHRVOHlYV2U4dnRqaWZqRXBqaWktTHpUSEJnTTdhU0hVZTEtZXpZZEY4a3lNY29zc0VZeEFvLS01YmJRRnQ5eFRmR2dOY29nUWdKSTRVWG13WE1obGs1blhQcVh0V18tRnBSRnVlc1VhOHNCQUFBMPeIjfgFOA1AAQ==<br />

  ReadCookie 模块可以自动获取到 appmsg_token 和 cookie,将它们当作参数一样传递到 Articles 模块中,就能解放双手再也不要复制黏贴 appmsg_token 和 cookie 了,只要在 appmsg_token 过期时刷新一下公众号文章就可以了,省心又省时

  批量抓取

  在公众号历史消息界面将屏幕向上滑动,每次都可以加载 10 条历史消息,盲猜这个翻页就是批量抓取的请求链接,用 MitmProxy 的 WEBUI 界面在 Response 面板查找一下,找到一个是 /mp/profile_ext?action=getmsg&__biz=MzU1NDk2MzQyNg==&f=json&offset=10&count=10... 的链接,它的响应返回值中有多个文章标题,再看这个链接上有 offset=10&count=10 参数,一看就是翻页偏移量和每页显示的条数,就它了

  

  在链接中比较重要的参数有:__biz、offset、pass_ticket、appmsg_token ,这些数据都可以在 cookie 和 appmsg_token 中得到。

  # utils.py<br /># 工具模块,将字符串变成字典<br />def str_to_dict(s, join_symbol="\n", split_symbol=":"):<br />    s_list = s.split(join_symbol)<br />    data = dict()<br />    for item in s_list:<br />        item = item.strip()<br />        if item:<br />            k, v = item.split(split_symbol, 1)<br />            data[k] = v.strip()<br />    return data<br /><br />

  # coding:utf-8<br /># wxCrawler.py<br />import os<br />import requests<br />import json<br />import urllib3<br />import utils<br /><br /><br />class WxCrawler(object):<br />    """翻页内容抓取"""<br />    urllib3.disable_warnings()<br /><br />    def __init__(self, appmsg_token, biz, cookie, begin_page_index = 0, end_page_index = 100):<br />        # 起始页数<br />        self.begin_page_index = begin_page_index<br />        # 结束页数<br />        self.end_page_index = end_page_index<br />        # 抓了多少条了<br />        self.num = 1<br /><br />        self.appmsg_token = appmsg_token<br />        self.biz = biz<br />        self.headers = {<br />            "User-Agent": "Mozilla/5.0 AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0Chrome/57.0.2987.132 MQQBrowser/6.2 Mobile",<br />            "Cookie": cookie<br />        }<br />        self.cookie = cookie<br /><br />    def article_list(self, context):<br />        articles = json.loads(context).get('general_msg_list')<br />        return json.loads(articles)<br /><br />    def run(self):<br /><br />        # 翻页地址<br />        page_url = "https://mp. weixin.qq.com/mp/profile_ext?action=getmsg&__biz={}&f=json&offset={}&count=10&is_ok=1&scene=&uin=777&key=777&pass_ticket={}&wxtoken=&appmsg_token=" + self.appmsg_token + "&x5=0f=json"<br />        # 将 cookie 字典化<br />        wx_dict = utils.str_to_dict(self.cookie, join_symbol='; ', split_symbol='=')<br />        # 请求地址<br />        response = requests.get(page_url.format(self.biz, self.begin_page_index * 10, wx_dict['pass_ticket']), headers=self.headers, verify=False)<br />        # 将文章列表字典化<br />        articles = self.article_list(response.text)<br /><br />        for a in articles['list']:<br />            # 公众号中主条<br />            if 'app_msg_ext_info' in a.keys() and '' != a.get('app_msg_ext_info').get('content_url', ''):<br />                print(str(self.num) + "条", a.get('app_msg_ext_info').get('title'), a.get('app_msg_ext_info').get('content_url'))<br />            # 公众号中副条<br />            if 'app_msg_ext_info' in a.keys():<br />                for m in a.get('app_msg_ext_info').get('multi_app_msg_item_list', []):<br />                    print(str(self.num) + "条", m.get('title'), a.get('content_url'))<br /><br />            self.num = self.num + 1<br /><br />        self.is_exit_or_continue()<br />        # 递归调用<br />        self.run()<br /><br />    def is_exit_or_continue(self):<br />        self.begin_page_index = self.begin_page_index + 1<br /><br />        if self.begin_page_index > self.end_page_index:<br />            os.exit()<br />

  最后用自动化cookie启动程序后刷新公众号文章

  # coding:utf-8<br /># main.py<br />from read_cookie import ReadCookie<br />from wxCrawler import WxCrawler<br /><br />"""程序启动类"""ss<br />if __name__ == '__main__':<br />    cookie = ReadCookie('E:/python/cookie.txt')<br /><br />    cookie.write_cookie()<br />    appmsg_token, biz, cookie_str = cookie.parse_cookie()<br />    wx = WxCrawler(appmsg_token, biz, cookie_str)<br />    wx.run()<br />

  示例结果

  

  - EOF -

  今天分享给大家一本名为《Python进阶》,是《Intermediate Python》的中文译本,这本书具有如下几个优点:简单、易读、易译。这些都不是重点,重点是:它是一本开脑洞的书。无论你是Python初学者,还是Python高手,它显现给你的永远是Python里最美好的事物。

  获取方法

  1. 扫描下方二维码

  2. 后台回复关键词:Python进阶

  编程技术进阶

  

  长按上方二维码 2 秒回复「Python进阶」即可获取资料

  <p data-tool="mdnice编辑器" style="color: rgb(62, 62, 62);padding-top: 8px;padding-bottom: 8px;letter-spacing: 0.544px;word-spacing: 1.6px;text-size-adjust: auto;font-family: Optima-Regular, Optima, PingFangSC-light, PingFangTC-light, "PingFang SC", Cambria, Cochin, Georgia, Times, "Times New Roman", serif;line-height: 26px;text-align: center;">其他

  最后涛哥推荐下我的视频号,我从3月份开通了视频号,坚持录制80多期左右的视频了,不说每篇干货满满,有爬虫技术,有工具推荐,有软件开发技能、副业赚钱但都是原创用心输出,有些东西公众号看不到,视频号能看到,一来不足以成文,二来可以看看逗比涛哥。

  今天是视频号80/100天打卡,公众号日更68/100天,加油呀!

  <br />

  

  <br />

  <br />

  <br />

  

<br />

  <br />

  

长按上方二维码回复「网络」抽奖3网络编程,7.27日20:00开奖,中奖需要24小时联系我哦</p>

0 个评论

要回复文章请先登录注册


官方客服QQ群

微信人工客服

QQ人工客服


线