爬虫案例5——爬取东方财富网的港股数据

2024-08-22 12:12

本文主要是介绍爬虫案例5——爬取东方财富网的港股数据,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

简介:个人学习分享,如有错误,欢迎批评指正

任务从东方财富网中爬取港股的代码,名称,最近价格,涨跌幅,今开,最高等数据

目标网页地址:https://data.eastmoney.com/bbsj/yjbb/603112.htmll

一、思路和过程

目标网页具体内容如下图:
​​​​
图1

我们的任务是将上图中港股的代码,名称,最近价格,涨跌幅,今开,最高等数据爬取下来。

1.URL和User-Agent的确定

1.1. URL确定
在这里插入图片描述

东方财富网具有一定的反爬程序,具体分析如下:
如上图,当我们切换上图框2中的页码时,上图框2里面url地址并没有变化,也就是说上图框1的URL地址作为我们的目标URL时,将得不到我们想要的图中间部分内容(代码,名称,最近价格等信息)。

怎么解决:
在这里插入图片描述
如上图,鼠标右键选择检查,进入源代码操作页面,点击框2的元素,然后点击右边的框3的三个点,选择框4的搜索,在框5中搜索框1的股票代码,框6为搜索的结果。

在这里插入图片描述

如上图,点击刚才的搜索结果框1,上面源代码部分会对框1的内容进行一个格式化展示,可以看到刚才搜索的股票代码在框2中有了一个呈现,在框2旁边的空白处点击鼠标右键,复制框3的链接地址,该地址就是包含我们想要的股票信息的正确URL地址

1.2.User-Agent确定
由于网页普遍具有反爬程序,不加修饰的直接访问网页可能会失败,所以第一步学会伪装自己。
如何伪装自己呢,可以通过找到正常访问网页时的访问状态,将自己的这次爬虫模拟成一次正常访问网页,因此我们的目标是找到正常访问网页时的User-Agent。User Agent中文名为用户代理,(简称 UA,它是一个特殊字符串头,使得服务器能够识别客户使用的操作系统及版本、CPU 类型、浏览器及版本、浏览器渲染引擎、浏览器语言、浏览器插件等)。User-Agent就是你访问网页的身份证明。具体操作如下:

如下图,首先打开目标(或任意)网页,然后点击鼠标右键后选择检查打开网页的HTML 页面。
在这里插入图片描述

如下图,在HTML 页面里面依次点击网络,然后任意点一条网络请求(如果没有显示任何网络请求可以点击网页左上角的刷新),然后选择标头,下拉列表找到User-Agent,User-Agent后面那段内容就是我们用来伪装自己的身份码。

在这里插入图片描述

2.发送GET请求获取网页内容

通过上面的步骤我们获得了
url = ‘https://34.push2.eastmoney.com/api/qt/clist/get?cb=jQuery112406894991919602407_1720001154034&pn=1&pz=20&po=1&np=1&ut=bd1d9ddb04089700cf9c27f6f7426281&fltt=2&invt=2&dect=1&wbp2u=|0|0|0|web&fid=f3&fs=m:128+t:3,m:128+t:4,m:128+t:1,m:128+t:2&fields=f1,f2,f3,f4,f5,f6,f7,f8,f9,f10,f12,f13,f14,f15,f16,f17,f18,f19,f20,f21,f23,f24,f25,f26,f22,f33,f11,f62,f128,f136,f115,f152&_=1720001154170’

User-Agent:‘Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/126.0.0.0 Safari/537.36 Edg/126.0.0.0’

接下来发起网页访问请求,代码如下:

import requests  # 引入requests库,用于发送HTTP请求
import jsonpath  # 引入jsonpath库,用于解析JSON数据
import json  # 引入json库,用于处理JSON数据
import re  # 引入re库,用于使用正则表达式
import math  # 引入math库,用于数学计算
import csv  # 引入csv库,用于CSV文件读写# 定义目标URL,获取股票数据的API接口地址
url = 'https://34.push2.eastmoney.com/api/qt/clist/get?cb=jQuery112406894991919602407_1720001154034&pn=1&pz=20&po=1&np=1&ut=bd1d9ddb04089700cf9c27f6f7426281&fltt=2&invt=2&dect=1&wbp2u=|0|0|0|web&fid=f3&fs=m:128+t:3,m:128+t:4,m:128+t:1,m:128+t:2&fields=f1,f2,f3,f4,f5,f6,f7,f8,f9,f10,f12,f13,f14,f15,f16,f17,f18,f19,f20,f21,f23,f24,f25,f26,f22,f33,f11,f62,f128,f136,f115,f152&_=1720001154170'# 定义HTTP请求头,其中包括User-Agent信息,用于伪装成浏览器进行访问
headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 5.1; U; en; rv:1.8.1) Gecko/20061208 Firefox/2.0.0 Opera 9.50'
}# 发送GET请求获取网页内容,并将响应内容解码为字符串格式
data = requests.get(url, headers=headers).content.decode()
print(data)

下图查看print结果,我们发现成功获得了网页相关的html表达,

在这里插入图片描述

3.分析网页内容

接下来对html进行解析获得我们目标内容。
这里,我们需要借助工具json.cn来辅助内容解析,

找到目标内容方法
首先,对刚才得到的结果,使用正则表达式从响应内容中提取出JSON数据,红框为解析后的数据。

# 使用正则表达式从响应内容中提取出JSON数据,'{"rc":.*}]}}'表示匹配以{"rc":开头,后面跟着任意字符,再后面跟着"}]"的字符串
json_data = re.findall('{"rc":.*}]}}', data)[0]
print(json_data)  # 打印提取出的JSON数据,检查内容是否正确

在这里插入图片描述

明确目标内容的位置。将上一步得到的JSON数据复制到json.cn中进行格式化

在这里插入图片描述

通过json.cn的可视化,我们可以清晰的看到f1、f2、f3等序号,而与之对应的则是我们需要的港股的代码,名称,最近价格,涨跌幅,今开等数据。

但是,我们发现上面只能取到单页的内容,而如下图整个网页有很多页。
在这里插入图片描述

对于上述问题,我们通过对比不同页面提取的URL,发现url地址不同的页码的url仅仅换了"pn="后面的数字,数字即对应页码。
在这里插入图片描述
首先,获取总页数,总页数在刚才获取的json格式结果中有,因此使用如下代码获取:

# 使用jsonpath从JSON数据中提取出总记录数,$..total表示从根节点开始,取出total字段的值
total = jsonpath.jsonpath(json_data, '$..total')[0]
print(json_data)  # 打印JSON数据,检查内容
print(total)  # 打印总记录数# 计算总页数,每页20条数据
page = math.ceil(total / 20)
print(page)  # 打印总页数

其次,进一步添加一个for循环来取得所有页的url地址,代码如下:

   for i in range(1, page + 1):# 构建每一页的URLnew_url = 'https://34.push2.eastmoney.com/api/qt/clist/get?cb=jQuery112406894991919602407_1720001154034&pn={}&pz=20&po=1&np=1&ut=bd1d9ddb04089700cf9c27f6f7426281&fltt=2&invt=2&dect=1&wbp2u=|0|0|0|web&fid=f3&fs=m:128+t:3,m:128+t:4,m:128+t:1,m:128+t:2&fields=f1,f2,f3,f4,f5,f6,f7,f8,f9,f10,f12,f13,f14,f15,f16,f17,f18,f19,f20,f21,f23,f24,f25,f26,f22,f33,f11,f62,f128,f136,f115,f152&_=1720001154170'.format(i)# 发送GET请求获取当前页码的网页内容,并将响应内容解码为字符串格式data = requests.get(new_url, headers=headers).content.decode()j += 1  # 更新页数计数器print('第{}页已保存'.format(j))  # 打印当前页数已保存

4.获取目标数据

上一步得到了目标数据的地址,接下来就是分别获得到目标数据,代码如下:

 # 使用正则表达式从响应内容中提取出JSON数据new_json_data = re.findall('{"rc":.*}]}}', data)[0]# 将JSON数据字符串转换为Python字典对象json_data = json.loads(new_json_data)# 依次使用jsonpath从JSON数据中提取出代码、名称、最新价、涨跌幅、今开、最高、最低、昨收、成交量、成交额等数据code = jsonpath.jsonpath(json_data, '$..f12')  # 代码name = jsonpath.jsonpath(json_data, '$..f14')  # 名称new_price = jsonpath.jsonpath(json_data, '$..f2')  # 最新价up_and_down = jsonpath.jsonpath(json_data, '$..f4')  # 涨跌幅today = jsonpath.jsonpath(json_data, '$..f17')  # 今开highest = jsonpath.jsonpath(json_data, '$..f15')  # 最高minimum = jsonpath.jsonpath(json_data, '$..f16')  # 最低yesterday = jsonpath.jsonpath(json_data, '$..f18')  # 昨收volume = jsonpath.jsonpath(json_data, '$..f5')  # 成交量(股)turnover = jsonpath.jsonpath(json_data, '$..f6')  # 成交额(港元)

5.保存数据

首先创建一个csv文件。


with open('港股.csv', 'a+', newline='', encoding='utf-8-sig') as f:writer = csv.writer(f)# 写入CSV文件的表头writer.writerow(['代码', '名称', '最新价', '涨跌幅', '今开', '最高', '最低', '昨收', '成交量(股)', '成交额(港元)'])j = 0  # 初始化页数计数器

其次,对得到的数据进行清洗和写入csv文件

# 数据清洗和写入CSV文件
for i, code in enumerate(code):try:# 检查数据是否为空(即8个字段是否都为'-')res = new_price[i] + up_and_down[i] + today[i] + highest[i] + minimum[i] + yesterday[i] + volume[i] + \turnover[i]if res == '-' * 8:continue  # 如果数据为空,则跳过该条记录# 将提取到的数据写入CSV文件writer.writerow([code, name[i], new_price[i], up_and_down[i], today[i], highest[i], minimum[i], yesterday[i],volume[i], turnover[i]])except:continue  # 如果发生异常,跳过该条记录

二、完整python代码

import requests  # 引入requests库,用于发送HTTP请求
import jsonpath  # 引入jsonpath库,用于解析JSON数据
import json  # 引入json库,用于处理JSON数据
import re  # 引入re库,用于使用正则表达式
import math  # 引入math库,用于数学计算
import csv  # 引入csv库,用于CSV文件读写# 定义目标URL,获取股票数据的API接口地址
url = 'https://34.push2.eastmoney.com/api/qt/clist/get?cb=jQuery112406894991919602407_1720001154034&pn=1&pz=20&po=1&np=1&ut=bd1d9ddb04089700cf9c27f6f7426281&fltt=2&invt=2&dect=1&wbp2u=|0|0|0|web&fid=f3&fs=m:128+t:3,m:128+t:4,m:128+t:1,m:128+t:2&fields=f1,f2,f3,f4,f5,f6,f7,f8,f9,f10,f12,f13,f14,f15,f16,f17,f18,f19,f20,f21,f23,f24,f25,f26,f22,f33,f11,f62,f128,f136,f115,f152&_=1720001154170'# 定义HTTP请求头,其中包括User-Agent信息,用于伪装成浏览器进行访问
headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 5.1; U; en; rv:1.8.1) Gecko/20061208 Firefox/2.0.0 Opera 9.50'
}# 发送GET请求获取网页内容,并将响应内容解码为字符串格式
data = requests.get(url, headers=headers).content.decode()
print(data)
# 使用正则表达式从响应内容中提取出JSON数据,'{"rc":.*}]}}'表示匹配以{"rc":开头,后面跟着任意字符,再后面跟着"}]"的字符串
json_data = re.findall('{"rc":.*}]}}', data)[0]
print(json_data)  # 打印提取出的JSON数据,检查内容是否正确# 将JSON数据字符串转换为Python字典对象
json_data = json.loads(json_data)# 使用jsonpath从JSON数据中提取出总记录数,$..total表示从根节点开始,取出total字段的值
total = jsonpath.jsonpath(json_data, '$..total')[0]
print(json_data)  # 打印JSON数据,检查内容
print(total)  # 打印总记录数# 计算总页数,每页20条数据
page = math.ceil(total / 20)
print(page)  # 打印总页数# 打开一个CSV文件,准备写入数据。 a+
with open('港股.csv', 'a+', newline='', encoding='utf-8-sig') as f:writer = csv.writer(f)# 写入CSV文件的表头writer.writerow(['代码', '名称', '最新价', '涨跌幅', '今开', '最高', '最低', '昨收', '成交量(股)', '成交额(港元)'])j = 0  # 初始化页数计数器# 遍历所有页码for i in range(1, page + 1):# 构建每一页的URLnew_url = 'https://34.push2.eastmoney.com/api/qt/clist/get?cb=jQuery112406894991919602407_1720001154034&pn={}&pz=20&po=1&np=1&ut=bd1d9ddb04089700cf9c27f6f7426281&fltt=2&invt=2&dect=1&wbp2u=|0|0|0|web&fid=f3&fs=m:128+t:3,m:128+t:4,m:128+t:1,m:128+t:2&fields=f1,f2,f3,f4,f5,f6,f7,f8,f9,f10,f12,f13,f14,f15,f16,f17,f18,f19,f20,f21,f23,f24,f25,f26,f22,f33,f11,f62,f128,f136,f115,f152&_=1720001154170'.format(i)# 发送GET请求获取当前页码的网页内容,并将响应内容解码为字符串格式data = requests.get(new_url, headers=headers).content.decode()j += 1  # 更新页数计数器print('第{}页已保存'.format(j))  # 打印当前页数已保存# 使用正则表达式从响应内容中提取出JSON数据new_json_data = re.findall('{"rc":.*}]}}', data)[0]# 将JSON数据字符串转换为Python字典对象json_data = json.loads(new_json_data)# 依次使用jsonpath从JSON数据中提取出代码、名称、最新价、涨跌幅、今开、最高、最低、昨收、成交量、成交额等数据code = jsonpath.jsonpath(json_data, '$..f12')  # 代码name = jsonpath.jsonpath(json_data, '$..f14')  # 名称new_price = jsonpath.jsonpath(json_data, '$..f2')  # 最新价up_and_down = jsonpath.jsonpath(json_data, '$..f4')  # 涨跌幅today = jsonpath.jsonpath(json_data, '$..f17')  # 今开highest = jsonpath.jsonpath(json_data, '$..f15')  # 最高minimum = jsonpath.jsonpath(json_data, '$..f16')  # 最低yesterday = jsonpath.jsonpath(json_data, '$..f18')  # 昨收volume = jsonpath.jsonpath(json_data, '$..f5')  # 成交量(股)turnover = jsonpath.jsonpath(json_data, '$..f6')  # 成交额(港元)# 数据清洗和写入CSV文件for i, code in enumerate(code):try:# 检查数据是否为空(即8个字段是否都为'-')res = new_price[i] + up_and_down[i] + today[i] + highest[i] + minimum[i] + yesterday[i] + volume[i] + \turnover[i]if res == '-' * 8:continue  # 如果数据为空,则跳过该条记录# 将提取到的数据写入CSV文件writer.writerow([code, name[i], new_price[i], up_and_down[i], today[i], highest[i], minimum[i], yesterday[i],volume[i], turnover[i]])except:continue  # 如果发生异常,跳过该条记录

结~~~

这篇关于爬虫案例5——爬取东方财富网的港股数据的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1096236

相关文章

SpringBoot多环境配置数据读取方式

《SpringBoot多环境配置数据读取方式》SpringBoot通过环境隔离机制,支持properties/yaml/yml多格式配置,结合@Value、Environment和@Configura... 目录一、多环境配置的核心思路二、3种配置文件格式详解2.1 properties格式(传统格式)1.

解决pandas无法读取csv文件数据的问题

《解决pandas无法读取csv文件数据的问题》本文讲述作者用Pandas读取CSV文件时因参数设置不当导致数据错位,通过调整delimiter和on_bad_lines参数最终解决问题,并强调正确参... 目录一、前言二、问题复现1. 问题2. 通过 on_bad_lines=‘warn’ 跳过异常数据3

RabbitMQ消费端单线程与多线程案例讲解

《RabbitMQ消费端单线程与多线程案例讲解》文章解析RabbitMQ消费端单线程与多线程处理机制,说明concurrency控制消费者数量,max-concurrency控制最大线程数,prefe... 目录 一、基础概念详细解释:举个例子:✅ 单消费者 + 单线程消费❌ 单消费者 + 多线程消费❌ 多

C#监听txt文档获取新数据方式

《C#监听txt文档获取新数据方式》文章介绍通过监听txt文件获取最新数据,并实现开机自启动、禁用窗口关闭按钮、阻止Ctrl+C中断及防止程序退出等功能,代码整合于主函数中,供参考学习... 目录前言一、监听txt文档增加数据二、其他功能1. 设置开机自启动2. 禁止控制台窗口关闭按钮3. 阻止Ctrl +

java如何实现高并发场景下三级缓存的数据一致性

《java如何实现高并发场景下三级缓存的数据一致性》这篇文章主要为大家详细介绍了java如何实现高并发场景下三级缓存的数据一致性,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 下面代码是一个使用Java和Redisson实现的三级缓存服务,主要功能包括:1.缓存结构:本地缓存:使

在MySQL中实现冷热数据分离的方法及使用场景底层原理解析

《在MySQL中实现冷热数据分离的方法及使用场景底层原理解析》MySQL冷热数据分离通过分表/分区策略、数据归档和索引优化,将频繁访问的热数据与冷数据分开存储,提升查询效率并降低存储成本,适用于高并发... 目录实现冷热数据分离1. 分表策略2. 使用分区表3. 数据归档与迁移在mysql中实现冷热数据分

C#解析JSON数据全攻略指南

《C#解析JSON数据全攻略指南》这篇文章主要为大家详细介绍了使用C#解析JSON数据全攻略指南,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录一、为什么jsON是C#开发必修课?二、四步搞定网络JSON数据1. 获取数据 - HttpClient最佳实践2. 动态解析 - 快速

MyBatis-Plus通用中等、大量数据分批查询和处理方法

《MyBatis-Plus通用中等、大量数据分批查询和处理方法》文章介绍MyBatis-Plus分页查询处理,通过函数式接口与Lambda表达式实现通用逻辑,方法抽象但功能强大,建议扩展分批处理及流式... 目录函数式接口获取分页数据接口数据处理接口通用逻辑工具类使用方法简单查询自定义查询方法总结函数式接口

MySql基本查询之表的增删查改+聚合函数案例详解

《MySql基本查询之表的增删查改+聚合函数案例详解》本文详解SQL的CURD操作INSERT用于数据插入(单行/多行及冲突处理),SELECT实现数据检索(列选择、条件过滤、排序分页),UPDATE... 目录一、Create1.1 单行数据 + 全列插入1.2 多行数据 + 指定列插入1.3 插入否则更

Python通用唯一标识符模块uuid使用案例详解

《Python通用唯一标识符模块uuid使用案例详解》Pythonuuid模块用于生成128位全局唯一标识符,支持UUID1-5版本,适用于分布式系统、数据库主键等场景,需注意隐私、碰撞概率及存储优... 目录简介核心功能1. UUID版本2. UUID属性3. 命名空间使用场景1. 生成唯一标识符2. 数