🎈 博主：一只程序猿子

🎈 博客主页：一只程序猿子 博客主页

🎈 个人介绍：爱好(bushi)编程！

🎈 创作不易：喜欢的话麻烦您点个👍和⭐！

🎈 欢迎访问我的主页（点我直达）

🎈 除此之外您还可以通过个人名片联系我

目录

1.介绍

2.网页分析

（1）市场价格数据

（2）药材历史价格数据

3.设计

（1）数据库设计

（2）代码结构

4.源码

5.测试

---

1.介绍

        本文将介绍如何编写Python爬虫，从中药材天地网，爬取中药材的市场价格和某几种中药材的历史价格数据，在下一篇文章中我们将根据这些数据，做一个简单的基于Flask的中药材价格数据分析与可视化系统。

2.网页分析

（1）市场价格数据

        其中我们需要获取到的市场价格数据来自如下图片标示的位置：

        在页面底部有翻页按钮：

         再看看数据在html中的位置：

        首先可以看到表格的表头在文件中的位置。

        这是表格数据的位置：

         这是翻页按钮的位置：

         这里可以很容易发现规律，既翻页是通过修改url的最后一位数字实现的。

（2）药材历史价格数据

        这里我们偷懒，只爬取四种中药材的历史价格数据，分别是白术、麦冬、川芎和白芍。

        我们只爬取这四种药材在亳州药市，规格一的历史价格数据。

         现在我们看下数据是怎么获取的 ：

通过开发者工具中的网络，很容易发现这个页面是一个动态页面，数据并不能在html中直接获取。

我们来抓下包看看： 

         很容易我们找到了我们想要的数据：

        看一下请求头和需要什么参数：

 

         然后可以找到mid从哪获取的：

         再看一下它的请求头和参数：

        因为我们只爬取四种中药材的历史价格，所以我们手动找到这四种中药材的MBID和MAreaID即可：

3.设计

（1）数据库设计

        总共设计了两张表，marketprice表用来存储药材的市场价格数据，historicalprice表用来存储四种药材的历史价格数据。

        表结构如下：

（2）代码结构

4.源码

db_helper.py：

import pymysql

"""数据库操作"""


class DBHelper(object):

    def __init__(self):
        pymysql.version_info = (1, 4, 13, "final", 0)  # 必须有这个不然会报版本不对错误
        pymysql.install_as_MySQLdb()  # 使用pymysql代替mysqldb连接数据库
        # 建立数据库连接
        self.conn = pymysql.connect(
            host="127.0.0.1",
            port=3306,
            user="用户名",
            passwd="密码",
            db="zhongyaoprice_demo"
        )
        # 通过 cursor() 创建游标对象，并让查询结果以字典格式输出
        self.cur = self.conn.cursor(cursor=pymysql.cursors.DictCursor)

    def __del__(self):  # 对象资源被释放时触发，在对象即将被删除时的最后操作
        # 关闭游标
        self.cur.close()
        # 关闭数据库连接
        self.conn.close()

    def select_db(self, sql):
        """查询"""
        # 使用 execute() 执行sql
        self.cur.execute(sql)
        # 使用 fetchall() 获取查询结果
        data = self.cur.fetchall()
        return data

    def execute_db(self, sql):
        """更新/插入/删除"""
        try:
            # 使用 execute() 执行sql
            self.cur.execute(sql)
            # 提交事务
            self.conn.commit()
        except Exception as e:
            print("操作出现错误：{}".format(e))
            # 回滚所有更改
            self.conn.rollback()

    def execute_db_ex(self, sql, params):
        """更新/插入/删除"""
        try:
            # 使用 execute() 执行sql
            self.cur.execute(sql, params)
            # 提交事务
            self.conn.commit()
        except Exception as e:
            print("操作出现错误：{}".format(e))
            # 回滚所有更改
            self.conn.rollback()

    def save_market_price(self, zhongyao):
        """查找或者保存中药材市场价格"""
        select_sql_temp = "select * from marketprice where name = '%s' and spec = '%s'" % (zhongyao[0], zhongyao[1])
        result = self.select_db(select_sql_temp)
        if result is None or len(result) == 0:
            self.execute_db_ex("insert into marketprice (name, spec, market, recentprice, tendency, "
                               "weeklyfluctuation, monthlyfluctuation, yearlyfluctuation)"
                               " values (%s,%s,%s,%s,%s,%s,%s,%s) ",
                               (zhongyao[0], zhongyao[1], zhongyao[2], zhongyao[3], zhongyao[4], zhongyao[5],
                                zhongyao[6], zhongyao[7])
                               )
            print(f'中药材：{zhongyao[0]}，规格：{zhongyao[1]} 的市场价格信息保存成功！！！')
        else:
            print(f'该规格的中药材：{zhongyao[0]} 的市场价格信息已在数据库存在！！！')

    def save_historical_price(self, prices_info):
        """查找或者保存中药材历史价格"""
        select_sql_temp = "select * from historicalprice where name = '%s' and spec = '%s'" % (prices_info[0], prices_info[1])
        result = self.select_db(select_sql_temp)
        if result is None or len(result) == 0:
            self.execute_db_ex("insert into historicalprice (name, spec, market, prices)"
                               " values (%s,%s,%s,%s) ",
                               (prices_info[0], prices_info[1], '亳州药市', prices_info[2])
                               )
            print(f'中药材：{prices_info[0]}，规格：{prices_info[1]} 的历史价格信息保存成功！！！')
        else:
            print(f'该规格的中药材：{prices_info[0]} 的历史价格信息已在数据库存在！！！')

settings.py:

HEADERS = {
    'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7',
    'Accept-Language': 'zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6',
    'Cache-Control': 'max-age=0',
    'Connection': 'keep-alive',
        'Sec-Fetch-Dest': 'document',
    'Sec-Fetch-Mode': 'navigate',
    'Sec-Fetch-Site': 'none',
    'Sec-Fetch-User': '?1',
    'Upgrade-Insecure-Requests': '1',
    'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.0.0 Safari/537.36 Edg/123.0.0.0',
    'sec-ch-ua': '"Microsoft Edge";v="123", "Not:A-Brand";v="8", "Chromium";v="123"',
    'sec-ch-ua-mobile': '?0',
    'sec-ch-ua-platform': '"Windows"',
}

COOKIES = {
    'FromsAuthByDbCookie_zytd_Edwin.PrvGuest': '1c1uuuuuuuuuuaI98Rb8c9916R6R18a8U1da851Rd59Ud4S49c40o5qqnc78ca99o698qac9nadmoll5moad015',
    'Hm_lvt_ba57c22d7489f31017e84ef9304f89ec': '1713054805,1713141612',
    'Hm_lpvt_ba57c22d7489f31017e84ef9304f89ec': '1713143695',
}

spider.py:

if __name__ == '__main__':
    for i in range(1, 31):
        url = f'https://www.zyctd.com/jiage/1-0-341699-{i}.html'
        print(f'开始爬取第 {i} 页！')
        get_market_price(url)
        if i < 30:
            print('休息两秒然后继续')
        else:
            print('爬取完毕，再见！')
        time.sleep(2)

    # 分别对应了白术，麦冬，川芎， 白芍的历史价格请求参数
    items = [{'name': '白术', 'MBID': 34, 'MAreaID': 341699},
             {'name': '麦冬', 'MBID': 396, 'MAreaID': 341699},
             {'name': '川芎', 'MBID': 102, 'MAreaID': 341699},
             {'name': '白芍', 'MBID': 32, 'MAreaID': 341699}]

    get_historical_price(items)

        篇幅有限，spider.py我只在此展示了部分源码，可以通过文章底部个人名片联系我获取完整代码！ 

5.测试

        运行spider.py: