基础爬虫记~豆瓣+东方财富网爬虫

2023-10-31

基础小白,大佬轻点喷~

一、基础豆瓣爬虫

1、首先在某站上听讲解,简单建立起了对爬虫的基础框架,具体包括五个板块(当然 有些东西看个人 可写成函数 也可以直接写 但重复用到的东西建议写函数)

用到了下面五个库:

from bs4 import BeautifulSoup      ##网页解析,获取数据
import re       ##正则表达式,进行文字匹配
import urllib.request,urllib.error      ##制定URL,获取网页数据
import xlwt     ##进行excel操作
import sqlite3  ##进行SQLite数据库操作

然后在主函数写爬取网页的步骤(在脑海有个框架)

def main():
    baseurl = "https://movie.douban.com/top250?start="
    # 1.爬取网页
    datalist = getData(baseurl)
    savepath = "豆瓣电影Top250.xls"  ##./和不写就是当前文件夹 .\\就是文件系统
    dbpath = "movie.db"
    # 3.保存数据
    saveData(datalist,savepath)
    # savaData2DB(datalist,dbpath)

    #askURL("https://movie.douban.com/top250?start=")

保存路径有两个方式,一个是保存到Excel,另一个是保存到MySql(数据量小可选择前者 量大则选择后者)

2、然后写爬取网页的函数,注意观察豆瓣页面,一共10页,每页25个电影。https://movie.douban.com/top250?start=(具体数字) 0就是第一页 ,以此类推

故可用循环写入列表中

def getData(baseurl):
    datalist = []
    for i in range(0,10):    ##调用获取页面信息的函数 10次
        url = baseurl +str(i*25)
        html = askURL(url)  ##保存获取到的网页源码

通过BeautifulSoup 解析网页,获取数据

soup = BeautifulSoup(html,"html.parser")
        for item in soup.find_all('div',class_="item"):  ##查找符合要求的字符串,行程列表
            #print(item)  ##测试查看电影item 全部信息
            data = []   ##保存一部电影的所有信息
            item = str(item)

3、模拟浏览器头部信息,向豆瓣服务器发送消息,用户代理表示告诉豆瓣服务器,我们是什么类型的机器 浏览器(本质上是告诉浏览器,我们可以接受什么水平的文件内容)可以去主函数测试一下askURL,看是否成功模拟浏览器

def askURL(url):
    head = {  "User-Agent": "Mozilla / 5.0(Windows NT 10.0;Win64;x64) AppleWebKit / 537.36(KHTML, likeGecko) Chrome / 94.0.4606.61Safari / 537.36Edg / 94.0.992.31"}
    request = urllib.request.Request(url,headers=head)
    html = ""
    try:
        response = urllib.request.urlopen(request)
        html = response.read().decode("utf-8")
        #print(html)
    except urllib.error.URLError as e:
        if hasattr(e,"code"):
            print(e.code)  ##看错误信息
        if hasattr(e,"reason"):
            print(e.reason)   ##看错误信息产生的原因
    return html

可以去主函数测试一下askURL,看是否成功模拟浏览器

4、保存数据

1)保存到Excel

def saveData(datalist,savepath):
    book = xlwt.Workbook(encoding="utf-8",style_compression=0)  ##创建workbook对象
    sheet = book.add_sheet('豆瓣电影Top250',cell_overwrite_ok=True)  #cell_overwrite_ok=True每一个单元往里面输入的时候直接覆盖掉里面的内容
    col=('电影详情链接','图片链接','影片中文名','影片外国名','评分','评价数','概况','相关信息')
    for i in range(0,8):
        sheet.write(0,i,col[i])  ##列名
    for i in range(0,250):
        #print("第%d条"%(i+1))
        data = datalist[i]
        for j in range(0,8):
            sheet.write(i+1,j,data[j])  #数据
    book.save(savepath)  #保存

2)保存到MySql

# def init_db(dbpath):
#     ##autoincrement 是一个关键字,用于表中的字段值自动递增
#     ##text表示文本格式  后面加的就是跟的格式
#     sql = '''
#         create table movie250
#         (
#         id integer primary key autoincrement ,
#         info_link text,
#         pic_link text,
#         cname varchar,
#         ename varchar,
#         score numeric,
#         rated numeric,
#         instroduction text,
#         info text
#         )
#
#
#     ''' #创建数据库
#     conn = sqlite3.connect(dbpath)
#     cursor = conn.cursor()
#     cursor.execute(sql)
#     conn.commit()
#     conn.close()
# def savaData2DB(datalist,dbpath):
#     init_db(dbpath)
#     conn = sqlite3.connect(dbpath)
#     cur = conn.cursor()
#
#     for data in datalist:
#         for index in range(len(data)):
#             if index == 4 or index == 5:
#                 continue
#             data[index] = '"'+data[index]+'"'
#         sql = '''
#                 insert into movie250(
#                 info_link,pic_link,cname,ename,score,rated,instroduction,info)
#                 values(%s)'''%",".join(data)
#         print(sql)
#         cur.execute(sql)
#         conn.commit()
#     cur.close()
#     conn.close()

5、当然最后也别忘记调用主函数

if __name__ =="__main__":  ##当程序执行时
##调用函数
    main()
    #init_db("movietest.db")  ##测试movietest.db是否生成
    print("爬虫完毕!")

6、以上完整操作知识获取到了这个页面,但是并没有说明我想找到什么,所以我们还需要去主函数添加你想得到的东西,运用re库中的compile(findall也是可以的)

##影片详情链接的规则
findlink = re.compile(r'<a href="(.*?)">')  ##re.compile()创建正则表达式对象,表示规则(字符串的模式)
##影片图片的链接
findImgSrc = re.compile(r'<img.*src="(.*?)"',re.S)  ##re.S让换行符包含在字符中
##影片的片名
findTitle= re.compile(r'<span class="title">(.*)</span>')
##影片的评分
findRating= re.compile(r'<span class="rating_num" property="v:average">(.*)</span>')
#找到评价人数
findJudge = re.compile(r'<span>(\d*)人评价</span>')
#找到概况
findInq = re.compile(r'<span class="inq">(.*)</span>')
#找到影片的相关内容
findBd = re.compile(r'<p class="">(.*?)</p>',re.S)

7、getData中也需要在for循环下去逐一解析数据,最后全部添加到一个列表中

 # 2.逐一解析数据
        soup = BeautifulSoup(html,"html.parser")
        for item in soup.find_all('div',class_="item"):  ##查找符合要求的字符串,行程列表
            #print(item)  ##测试查看电影item 全部信息
            data = []   ##保存一部电影的所有信息
            item = str(item)

            ##影片详情的链接
            link = re.findall(findlink,item)[0]  ##re库用来通过正则表达式查找指定的字符串
            data.append(link)   ##添加链接

            imgSrc = re.findall(findImgSrc,item)[0]
            data.append(imgSrc)  ##添加图片

            titles = re.findall(findTitle,item)   ##片名可能只有一个中文名,没有外国名
            if len(titles) == 2:
                ctitle = titles[0]     ##添加中文名
                data.append(ctitle)
                otitle = titles[1].replace("/","")  ##去掉无关的符号
                data.append(otitle)    ##添加外国名
            else:
                data.append(titles[0])
                data.append(' ')  ##给没有外国名的影片留空,保持对应

            rating = re.findall(findRating,item)[0]
            data.append(rating)    ##添加评分

            judgeNum = re.findall(findJudge,item)[0]
            data.append(judgeNum)  ##添加评价人数

            inq = re.findall(findInq,item)
            if len(inq) != 0:
                inq = inq[0].replace("。","")   #去掉句号
                data.append(inq)               ##添加概述
            else:
                data.append(" ")   ##留空

            bd = re.findall(findBd,item)[0]  #找到影片的相关内容
            bd = re.sub('<br(\s+)?/>(\s+)?'," ",bd)   #去掉<br/>
            bd = re.sub('/'," ",bd)  #替换/
            data.append(bd.strip())  ##去掉前后空格

            datalist.append(data)  ##把处理好的一部电影信息放入datalist
    #print(datalist)  ##打印全部代码的信息
    return datalist

二、东方财富网爬取名称与数据

爬取名称,相当于就是在页面表面的东西,直接可以通过re库中的compile找到要爬取的名称

findTitle = re.compile(r'<a href="(.*?)">(.*?)</a>')

其他都可参照一中的豆瓣爬虫写,比一更简单

下图呈现构造模拟浏览器参数

 

爬取数据比爬取名称复杂一点,最重要的是找到如下展示的这些元素:

params = {
        'cb': 'jQuery112302973922664351607_1634440511064',
        'lmt': '0',
        'klt': '101',
        'fields1': 'f1,f2,f3,f7',
        'fields2': 'f51,f52,f53,f54,f55,f56,f57,f58,f59,f60,f61,f62,f63,f64,f65',
        'ut': 'b2884a393a59ad64002292a3e90d46a5',
        'secid': '0.000005',
        '_': '1634440511065'
        }

具体情况需要具体分析,可以去网页页面右击检查里的网络里去找,有很多get?cb=……,要具体去看需要的是什么,再爬。

爬下来后注意看数据的形式,很多数据都是不规整的,需要通过strip(),join()或者split()去调节成可以用的数据,对于东方财富网这种数据量大的,建议直接保存到啊MySql。下图为展示

最后一些小技巧帮友友们避个雷

1、在cmd输入ipconfig/flushdns,重置IP,适用于被禁IP的友友~

2、正则表达式中的(.*)和(.*?),前者适用于查找全部数据放在一个框下架的,取全部,若用后者取,只能取到全部中的一个参数;后者适用于固定格式但不是直接相连的数据。(具体情况具体分析哦~)

3、用navicat可下载一个phpstdudy,启动一三即可,连接数据库即可用~

4、数据库若报错pymysql.err.InterfaceError: (0, ''),只需要加上一行conn.ping(reconnect=True),重新连接到数据库即可~

若有错误的地方,尽请大佬指教~  ...>.<...


                
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

基础爬虫记~豆瓣+东方财富网爬虫 的相关文章

  • “扩展”numpy ndarray 的好方法?

    有没有 扩展 numpy ndarray 的好方法 假设我有一个像这样的 ndarray 1 2 3 4 我希望每行通过填充零来包含更多元素 1 2 0 0 0 3 4 0 0 0 我知道一定有一些蛮力的方法可以做到这一点 比如构造一个带有
  • Ubuntu Python shebang 线不工作

    无法让 shebang 线在 Ubuntu 中为 python 脚本工作 我每次只收到命令未找到错误 test py usr bin env python print Ran which python usr bin python 在 sh
  • 插入多行并返回主键时 Sqlalchemy 的奇怪行为

    插入多行并返回主键时 我注意到一些奇怪的事情 如果我在 isert 查询中添加使用参数值 我会得到预期的行为 但是当将值传递给游标时 不会返回任何内容 这可能是一个错误还是我误解了什么 我的sqlachemy版本是0 9 4 下面如何重现错
  • 创建一个行为类似于任何变量但具有更改/读取回调的类

    我想创建一个类 其行为类似于 python 变量 但在更改 读取 变量 时调用一些回调函数 换句话说 我希望能够按如下方式使用该类 x myClass change callback read callback 将 x 定义为 myclas
  • 计算 for 循环期间的运行总计 - Python

    编辑 下面是我根据收到的反馈 答案编写的工作代码 这个问题源于我之前使用 MIT 的开放课件学习 Python CS 时提出的问题 在这里查看我之前的问题 https stackoverflow com questions 4990159
  • Django REST Framework:无法使用视图名称解析超链接关系的 URL

    我已经广泛研究了这个相当常见的问题 但没有一个修复对我有用 我正在 REST 框架中构建 Django 项目 并希望使用超链接关系 用户可以拥有许多独立的汽车和路线 路线是位置的集合 这些是我的序列化器 class CarSerialize
  • 生产环境的 Flask-Login 与 Flask-Security

    我正在构建一个功能 供用户注册 登录 验证和授权自己 特别是使用 Python Flask 作为后端 我找到了一些解决方案 例如flask login and flask security 据我了解 flask login实际上并没有进行任
  • 自定义信号的声明

    在 Qt 中 我们可以通过将自定义信号设为静态变量来创建它们 然后我们使用self signame反而classname signame 这样就在类中创建了一个实例变量 我想了解这种模式之外的理论 这是我尝试过的一些伪代码 这些伪代码已记录
  • 在 PyCharm 中运行命令行命令

    你好 我正在使用Python 但之前从未真正使用过它 我收到一些命令 需要在终端中运行 基本上 python Test py GET feeds 我正在使用 PyCharm 我想知道是否有办法从该 IDE 中运行这些相同的命令 按 Alt
  • 使用 Twisted Python 的 UDP 客户端和服务器

    我想创建一个服务器和客户端 使用 Twisted 从网络发送和接收 UDP 数据包 我已经用 Python 中的套接字编写了此代码 但想利用 Twisted 的回调和线程功能 然而 我需要 Twisted 设计方面的帮助 我想接收多种类型的
  • PyCharm 输出错误消息散布在控制台输出中。如何解决这个问题?

    我正在运行 PyCharm 社区版 4 0 4 有谁知道为什么控制台输出后不显示错误消息 Thanks C Python27 python exe F Google Drive code python scripts leetcode lc
  • Pandas:向量化局部范围操作([i:i+2] 行的最大值和总和)

    我希望在数据帧中的每一行的局部范围内进行计算 同时避免速度缓慢for环形 例如 对于下面数据中的每一行 我想找到未来 3 天内 包括当天 的最高气温以及未来 3 天内的总降雨量 Day Temperature Rain 0 30 4 1 3
  • 如何使用子进程打开新的浏览器选项卡?

    我正在打开一个新的 IE 窗口 subprocess Popen r os environ PROGRAMFILES Internet Explorer IEXPLORE EXE Call URL 当 IE 关闭时这很好 但即使打开它也会生
  • Mac 上的 Errno 13 权限被拒绝

    我只是测试如何从一个 py 文件调用外部 py 文件 我有 2 个 py 文件 都在同一目录中 这是主要代码 runext py 假设调用 ext py import subprocess subprocess call Users tra
  • pip-tools 的干净设置不会编译非常基本的 pyproject.toml

    使用全新的pip tools设置总是会导致Backend subprocess exited error pyproject toml project dependencies openpyxl gt 3 0 9 lt 4 在仅包含上述 p
  • Celery 设计帮助:如何防止并发执行任务

    我对 Celery AMQP 相当陌生 正在尝试提出一个任务 队列 工作人员设计来满足以下要求 我有多种类型的 每用户 任务 例如 TaskA TaskB TaskC 这些 每用户 任务中的每一个都为系统中的一个特定用户读取 写入数据 因此
  • 检测计算机何时解锁 Windows

    我用过这个优秀的方法 https stackoverflow com questions 20733441 lock windows workstation using python 20733443锁定 Windows 计算机 那部分工作
  • Django:在单独的线程中使用相同的测试数据库

    我正在使用具有以下数据库设置的测试数据库运行 pytests DATABASES default ENGINE django db backends postgresql psycopg2 NAME postgres USER someth
  • 磁盘寻道时间测量方法

    我编写了一个脚本来测量 HDD 上的寻道时间 并且其完成方式的微小变化会导致显着不同的时间 第一个周期在磁盘开头的区域内进行跳转 第二个周期选择磁盘上执行查找的随机区域 相同大小 这种方法显然不同 但我不明白为什么它会改变结果 请注意 对于
  • Scrapy - 持续从数据库中获取要爬取的url

    我想不断地从数据库中获取要爬行的网址 到目前为止 我成功地从基地获取了 url 但我希望我的蜘蛛继续从该基地读取 因为该表将由另一个线程填充 我有一个管道 一旦爬行 工作 就会从表中删除 url 换句话说 我想使用我的数据库作为队列 我尝试

随机推荐