当前位置:编程学堂 > python爬虫(正则取数据)读取表格内的基金代码后爬取基金最新净值,同时写到对应的表格中,基于最近一次购买净值计算出涨跌幅(名字有点长)

python爬虫(正则取数据)读取表格内的基金代码后爬取基金最新净值,同时写到对应的表格中,基于最近一次购买净值计算出涨跌幅(名字有点长)

  • 发布:2023-09-26 02:30

-->

最近基金跌的真够猛,虽说是定投,但大幅度下跌,有时候适当的增加定投数也是降低平均成本的一种方式

每天去看去算太费时间,写了个爬虫,让他自动抓数据后自动计算出来吧

实现逻辑:

1、创建了一个excel表格,把当前定投的基金都备注到里面、

2、脚本依次读取表格中的基金代码

3、拿到基金代码,到“天天基金网”获取基金最新净值

4、把获取到净值和更新时间写到excel中

5、excel公示计算出基于最近一次购买值的涨跌幅

后续还可以把脚本搬到云上,每天自动运行,达到设置的跌幅发邮件提醒或者短信提醒,这都是后话

这里只写代码部分

第一步,读取表格中的基金代码,脚本如下

#读取表格内的基金代码
def code():
wb = www.sychzs.cn_workbook(path+'\\更新数据.xlsx')# 打开Excel文件
data = wb.sheet_by_name('Sheet1')#通过excel表格名称(rank)获取工作表
b=data.col_values(1)#获取第一列数据(数组)
list=[]
for c in b[1:]:#for循环,排除第一行数据
d=int(c)
s="%06d" % d#股票代码一共有6位,常规打印无法打印出首位带0的代码的0部分,补齐缺失的0
#print(s)
list.append(s)
return(list)
code=code()

返回数据如下格式

“['161005', '161903', '110003', '160222', '000248', '163406']”

这一步涉及到对excel操作(读取)处理,请参考:https://www.sychzs.cn/becks/p/11397995.html

第二步,从上一步返回的基金代码list中取值,拼接成有效链接爬取基金信息,脚本如下

def data(cookies,headers,params,code):
valuelist = []
for num in code:
response = requests.get('http://www.sychzs.cn/'+num+'.html', headers=headers, params=params, cookies=cookies, verify=False)
response.encoding = 'utf-8' #处理编码得步骤
response = response.text
#获取当前基金净值
valueD = re.findall('(.+?)', response, re.S)
if len(valueD)>0: #如果返回值长度大于0,即可理解为当天是跌,value从valueD取值
value = valueD
else: #否则,即可理解为当天是涨,value从valueZ取值
valueZ = re.findall('(.+?)', response, re.S)#当天净值为涨
value = valueZ
#print(value)
#获取当前最新净值更新时间
valuetime = re.findall(' valuelist.append(value[0])
#timelist.append(value1)
return(valuelist,valuetime)
test=data(cookies,headers,params,code)

返回数据如下:这一步没有对数据进行处理,里面包含了所有基金净值和更新时间

“(['3.7090', '2.1096', '2.5932', '1.2488', '3.2830', '2.1112'], ['2021-03-05'])”

这一步涉及对数据的正则处理,可参考:https://www.sychzs.cn/becks/p/14494929.html

第三步,处理数据,并保存到excel中,脚本如下

def save(test):
xfile = openpyxl.load_workbook(path+'\\更新数据.xlsx')
sheet1 = xfile.get_sheet_by_name('Sheet1')
for i in range(len(test[0])):
sheet1.cell(i+2, 5).value=test[0][i]
for i in range(len(test[0])):
sheet1.cell(i+2, 6).value=test[1][0]
www.sychzs.cn(path+'\\更新数据.xlsx')
save(test)

这一步涉及到对excel进行操作(追加写入),可参考:https://www.sychzs.cn/becks/p/12250052.html

整个脚本执行后,将自动更新下图表格中的红框数据,且涨跌幅一栏也会基于购买时的净值,计算得出结果

需要注意的是,excel文件的命名还有存放位置需要跟脚本在一个目录下

附完整代码

# -*-coding:utf8-*-
# encoding:utf-8
import requests
import os
import sys
import re
import time
import random
import openpyxl
import xlrd path = os.path.abspath(os.path.dirname(sys.argv[0])) cookies = {
'intellpositionL': '1010.67px',
'em_hq_fls': 'js',
'em-quote-version': 'topspeed',
'qgqp_b_id': '134fc3fcff10a2a2c4035eebfe40f119',
'intellpositionT': '455px',
'HAList': 'a-sh-600909-%u534E%u5B89%u8BC1%u5238%2Ca-sh-605003-%u4F17%u671B%u5E03%u827A%2Ca-sz-300855-%u56FE%u5357%u80A1%u4EFD%2Ca-sz-300015-%u7231%u5C14%u773C%u79D1%2Ca-sh-603939-%u76CA%u4E30%u836F%u623F%2Ca-sz-300677-%u82F1%u79D1%u533B%u7597%2Ca-sh-600036-%u62DB%u5546%u94F6%u884C%2Ca-sz-000860-%u987A%u946B%u519C%u4E1A%2Ca-sz-002352-%u987A%u4E30%u63A7%u80A1%2Ca-sz-002034-%u65FA%u80FD%u73AF%u5883',
'kforders': '0%3B-1%3B%3B%3B0%2C2%2C24%2C25%2C18%2C19%2C22%2C23%2C21%2C3',
'Eastmoney_Fund_Transform': 'true',
'Eastmoney_Fund': '000297_000001_000011',
'st_si': '89636864382855',
'st_asi': 'delete',
'www.sychzs.cn_SessionId': 'kbxmonijodtnjbezidg0jzmq',
'searchbar_code': '519736_000032_000205_040040_206018_000248_110003_163406_161903_161005',
'EMFUND0': '02-08%2015%3A15%3A53@%23%24%u6613%u65B9%u8FBE%u4FE1%u7528%u503A%u503A%u5238A@%23%24000032',
'EMFUND2': '02-08%2015%3A16%3A12@%23%24%u534E%u5B89%u7EAF%u503A%u503A%u5238A@%23%24040040',
'EMFUND1': '02-08%2015%3A16%3A07@%23%24%u6613%u65B9%u8FBE%u6295%u8D44%u7EA7%u4FE1%u7528%u503A%u503A%u5238A@%23%24000205',
'EMFUND3': '02-08%2015%3A26%3A18@%23%24%u9E4F%u534E%u4EA7%u4E1A%u503A%u503A%u5238@%23%24206018',
'EMFUND4': '02-08%2015%3A27%3A25@%23%24%u6C47%u6DFB%u5BCC%u4E2D%u8BC1%u4E3B%u8981%u6D88%u8D39ETF%u8054%u63A5@%23%24000248',
'EMFUND5': '02-08%2015%3A28%3A40@%23%24%u6613%u65B9%u8FBE%u4E0A%u8BC150%u589E%u5F3AA@%23%24110003',
'EMFUND6': '02-08%2015%3A29%3A32@%23%24%u5174%u5168%u5408%u6DA6%u6DF7%u5408%28LOF%29@%23%24163406',
'EMFUND7': '02-08%2015%3A30%3A22@%23%24%u4E07%u5BB6%u884C%u4E1A%u4F18%u9009%u6DF7%u5408%28LOF%29@%23%24161903',
'EMFUND8': '03-07%2020%3A24%3A02@%23%24%u5357%u65B9%u660C%u5143%u8F6C%u503AA@%23%24006030',
'st_pvi': '18238554782275',
'st_sp': '2020-01-23%2014%3A56%3A33',
'st_inirUrl': 'https%3A%2F%www.sychzs.cn%2Flink',
'st_sn': '5',
'st_psi': '20210307202806812-112200305282-6714006413',
} headers = {
'Connection': 'keep-alive',
'Cache-Control': 'max-age=0',
'Upgrade-Insecure-Requests': '1',
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/78.0.3904.108 Safari/537.36',
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3',
'Accept-Encoding': 'gzip, deflate',
'Accept-Language': 'zh-CN,zh;q=0.9',
'If-None-Match': 'W/"6044c497-25fbe"',
'If-Modified-Since': 'Sun, 07 Mar 2021 12:18:31 GMT',
} params = (
('spm', 'search'),
) #读取表格内的基金代码
def code():
wb = www.sychzs.cn_workbook(path+'\\更新数据.xlsx')# 打开Excel文件
data = wb.sheet_by_name('Sheet1')#通过excel表格名称(rank)获取工作表
b=data.col_values(1)#获取第一列数据(数组)
list=[]
for c in b[1:]:#for循环,排除第一行数据
d=int(c)
s="%06d" % d#股票代码一共有6位,常规打印无法打印出首位带0的代码的0部分,补齐缺失的0
#print(s)
list.append(s)
return(list)
code=code() def data(cookies,headers,params,code):
valuelist = []
for num in code:
response = requests.get('http://www.sychzs.cn/'+num+'.html', headers=headers, params=params, cookies=cookies, verify=False)
response.encoding = 'utf-8' #处理编码得步骤
response = response.text
#获取当前基金净值
valueD = re.findall('(.+?)', response, re.S)
if len(valueD)>0: #如果返回值长度大于0,即可理解为当天是跌,value从valueD取值
value = valueD
else: #否则,即可理解为当天是涨,value从valueZ取值
valueZ = re.findall('(.+?)', response, re.S)#当天净值为涨
value = valueZ
#print(value)
#获取当前最新净值更新时间
valuetime = re.findall(' valuelist.append(value[0])
#timelist.append(value1)
return(valuelist,valuetime)
test=data(cookies,headers,params,code) def save(test):
xfile = openpyxl.load_workbook(path+'\\更新数据.xlsx')
sheet1 = xfile.get_sheet_by_name('Sheet1')
for i in range(len(test[0])):
sheet1.cell(i+2, 5).value=test[0][i]
for i in range(len(test[0])):
sheet1.cell(i+2, 6).value=test[1][0]
www.sychzs.cn(path+'\\更新数据.xlsx')
save(test) def over(test):
print("数据已更新",test[1][0])
over(test) -->

相关文章