Python学习笔记之抓取某只基金历史净值数据实战案例-创新互联
本文实例讲述了Python抓取某只基金历史净值数据。分享给大家供大家参考,具体如下:
创新互联建站坚持“要么做到,要么别承诺”的工作理念,服务领域包括:成都网站建设、做网站、企业官网、英文网站、手机端网站、网站推广等服务,满足客户于互联网时代的松江网站设计、移动媒体设计的需求,帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴!http://fund.eastmoney.com/f10/jjjz_519961.html
1、接下来,我们需要动手把这些html抓取下来(这部分知识我们之前已经学过,现在不妨重温)
# coding: utf-8 from selenium.webdriver.support.ui import WebDriverWait from selenium import webdriver from bs4 import BeautifulSoup from threading import Thread,Lock import os import csv # 下面是利用 selenium 抓取html页面的代码 # 初始化函数 def initSpider(): driver = webdriver.PhantomJS(executable_path=r"你phantomjs可执行文件的绝对路径") driver.get("http://fund.eastmoney.com/f10/jjjz_519961.html") # 要抓取的网页地址 # 找到"下一页"按钮,就可以得到它前面的一个label,就是总页数 getPage_text = driver.find_element_by_id("pagebar").find_element_by_xpath( "div[@class='pagebtns']/label[text()='下一页']/preceding-sibling::label[1]").get_attribute("innerHTML") # 得到总共有多少页 total_page = int("".join(filter(str.isdigit, getPage_text))) # 返回 return (driver,total_page) # 获取html内容 def getData(myrange,driver,lock): for x in myrange: # 锁住 lock.acquire() tonum = driver.find_element_by_id("pagebar").find_element_by_xpath( "div[@class='pagebtns']/input[@class='pnum']") # 得到 页码文本框 jumpbtn = driver.find_element_by_id("pagebar").find_element_by_xpath( "div[@class='pagebtns']/input[@class='pgo']") # 跳转到按钮 tonum.clear() # 第x页 输入框 tonum.send_keys(str(x)) # 去第x页 jumpbtn.click() # 点击按钮 # 抓取 WebDriverWait(driver, 20).until(lambda driver: driver.find_element_by_id("pagebar").find_element_by_xpath("div[@class='pagebtns']/label[@value={0} and @class='cur']".format(x)) != None) # 保存到项目中 with open("../htmls/details/{0}.txt".format(x), 'wb') as f: f.write(driver.find_element_by_id("jztable").get_attribute("innerHTML").encode('utf-8')) f.close() # 解锁 lock.release() # 开始抓取函数 def beginSpider(): # 初始化爬虫 (driver, total_page) = initSpider() # 创建锁 lock = Lock() r = range(1, int(total_page)+1) step = 10 range_list = [r[x:x + step] for x in range(0, len(r), step)] #把页码分段 thread_list = [] for r in range_list: t = Thread(target=getData, args=(r,driver,lock)) thread_list.append(t) t.start() for t in thread_list: t.join() # 这一步是需要的,等待线程全部执行完成 print("抓取完成") # #################上面代码就完成了 抓取远程网站html内容并保存到项目中的 过程
文章名称:Python学习笔记之抓取某只基金历史净值数据实战案例-创新互联
本文地址:http://pwwzsj.com/article/ddhjep.html