百木园-与人分享,
就是让自己快乐。

Python 爬虫高阶

目录

  • 爬虫高阶
    • 一、 验证码识别
      • 1、 简介
      • 2、 使用方法
    • 二、 模拟登录
      • 1、 通过抓包分析
      • 2、 基于 cookie
    • 三、 代理 ip
    • 四、 异步爬虫
      • 1、 简介
      • 2、 异步爬虫方式
        • 2.1 多线程,多进程
        • 2.2 线程池,进程池
        • 2.3 单线程 + 协程(推荐)
        • 2.3.1 单任务协程
        • 2.3.2 多任务协程
    • 五、 selenium
      • 1、 简介
      • 2、 用法
      • 3、 注意
      • 4、 动作链

爬虫高阶

一、 验证码识别

1、 简介

验证码和爬虫之间的爱恨情仇?

  • 反爬机制:验证码,识别验证码图片中的数据,用于登录验证

识别验证码的操作:

  • 人工肉眼识别(不推荐)
  • 第三方自动识别
    • 打码平台:超级鹰

2、 使用方法

  1. 注册

  2. 登录

    • 下载开发者文档:【http://www.chaojiying.com/download/Chaojiying_Python.rar】
    • 通过查看价格体系判断验证码类型:【http://www.chaojiying.com/price.html】
    • 查看题分是否充足:【http://www.chaojiying.com/user/】
    • 注册软件 ID :【http://www.chaojiying.com/user/mysoft/】
  3. 使用接口

    from chaojiying import Chaojiying_Client  # 导入文件
    
    # 用户中心>>软件ID 里面生成软件 ID
    chaojiying = Chaojiying_Client(\'用户名\', \'密码\', \'软件ID\')
    # 本地图片文件路径 
    im = open(\'图片路径\', \'rb\').read()  # im是图片的所有字节
    # 1902 验证码类型  官方网站>>价格体系
    print(chaojiying.PostPic(im, 1902)[\'pic_str\'])  # 得到字符串类型的验证码
    
  4. 编码流程

    • 将验证码进行本地下载
    • 调用平台提供的示例代码进行图片数据识别

二、 模拟登录

爬取某些基于某些用户数据的信息

1、 通过抓包分析

点击登录按钮之后会发起一个 post 请求

post 请求中会携带登录之前录入的相关的登录信息

http / https 协议特性:无状态信息,即,发起第二次基于个人主页请求的时候,服务器端并不知道该次请求是基于登录状态下的请求

cookie:用来让服务器记录

  • 手动获取:通过抓包工具获取 cookie 值,将该值封装到 headers 中

  • 自动获取:

    • cookie 来源

      • 进行模拟登录 post 请求后,由服务端创建
    • session 会话对象

      • 作用:
        1. 可以进行请求发送
        2. 如果请求过程中产生了 cookie ,则该 cookie 会被自动存储 / 携带在该 session 对象中
      • 创建一个 session 对象:session = requests.Session()
      • 使用 session 对象进行模拟登录 post 请求发送(cookie 被存储在 session 中)
      • session 对象对个人主页对应的 get 请求进行发送(携带了 cookie)
    • 使用 selenium 登录,获取 cookie

      from fake_useragent import UserAgent as ua  # 随机生成ua
      import requests
      
      
      def get_cookies(url, name, pwd):
          from selenium.webdriver import Chrome, ChromeOptions
          from selenium.webdriver.common.by import By
          from selenium.webdriver.common.keys import Keys
          option = ChromeOptions()
          option.add_argument(\"--headless\")
          option.add_argument(\'--disable-gpu\')
          option.add_argument(f\'user-agent={ua().random}\')
          web = Chrome(options=option)
          web.get(url=url)
          web.find_element(By.XPATH, \'//*[@id=\"username\"]\').send_keys(name)
          web.find_element(By.ID, \"password\").send_keys(pwd, Keys.ENTER)
          cookies = web.get_cookies()  # 得到 cookies
          web.close()
          cookie = {}
          for i in cookies:
              cookie[i[\"name\"]] = i[\"value\"]
              
          return cookie
      
      
      def get_page_source(url, name, password):
          resp = requests.get(url=url, cookies=get_cookies(url, name, pwd), headers={
              \"user-agent\": ua().random,
          })
          return resp
      

三、 代理 ip

什么是代理:

  • 代理服务器,本机和目标服务器的中介

代理的作用

  • 突破自身访问的限制
  • 隐藏自身真实的 ip,免受攻击

构建代理 ip 池

代理 ip 类型:

  • http:应用到 http 协议的 url 中
  • https:应用到 https 协议对应的 url 中
from requests import get
from fake_useragent import UserAgent as ua
from pyquery import PyQuery

def test_ip(ip):
    url = \"https://www.baidu.com/s?wd=ip\"
    resp = get(url=url, headers={
        \"user-agent\": ua().random,
    }, proxies={
        \"https\": ip,
        \"http\": ip
    }, timeout=10)
    doc = PyQuery(resp.text)(\'tr > td > span[@class=\"c-gap-right\"]\').text().split(\":\")[-1].strip()
    print(doc)

代理 ip 的匿名度

  • 透明:服务器知道此次请求使用了代理 ip,也知道请求对应的真实 ip
  • 匿名:知道使用了代理,但是不知道真实 ip
  • 高匿:不知道使用了代理,更不知道真实的 ip

四、 异步爬虫

1、 简介

目的:在爬虫中使用异步实现高性能的数据爬取操作

同步爬虫:

from time import time
from requests import get

urls = [
    \"wp-content/uploads/2022/03/https://www.173top.cn/wp-content/uploads/2022/03/1646282972-20220303044932-622048dcdc41d.jpg\",
    \"wp-content/uploads/2022/03/https://www.173top.cn/wp-content/uploads/2022/03/1646282973-20220303044933-622048dd855c5.jpg\",
    \"wp-content/uploads/2022/03/https://www.173top.cn/wp-content/uploads/2022/03/1646282973-20220303044933-622048ddb2cc3.jpg\",
]
def get_content(url):
    print(\"正在获取:\", url)
    resp = get(url=url).content
    name = url.split(\"/\")[-1]
    if resp:
        with open(f\"./img/{name}\", \"wb\") as f:
            f.write(resp)
        print(\"下载完成\")
    else:
        print(\"请求失败\")

sta = time()
for i in urls:
    get_content(i)
print(f\"全部下载完成,用时{time() - sta}\")

异步爬虫:

from time import time
from requests import get
import asyncio

urls = [
    \"wp-content/uploads/2022/03/https://www.173top.cn/wp-content/uploads/2022/03/1646282972-20220303044932-622048dcdc41d.jpg\",
    \"wp-content/uploads/2022/03/https://www.173top.cn/wp-content/uploads/2022/03/1646282973-20220303044933-622048dd855c5.jpg\",
    \"wp-content/uploads/2022/03/https://www.173top.cn/wp-content/uploads/2022/03/1646282973-20220303044933-622048ddb2cc3.jpg\",
]
async def get_content(url):
    print(\"开始下载:\", url)
    name = url.split(\"/\")[-1]
    loop = asyncio.get_event_loop()
    fut = loop.run_in_executor(None, get, url)  # 同步方法等待
    resp = await fut
    if resp:
        with open(f\"./img/{name}\", \"wb\") as f:
            f.write(resp.content)
        print(\"下载完成\")
    else:
        print(\"请求失败\")

sta = time()
tasks = [get_content(i) for i in urls]
asyncio.run(asyncio.wait(tasks))

print(f\"全部下载完成,用时{time() - sta}\")

2、 异步爬虫方式

2.1 多线程,多进程

  • 多线程 ,多进程:

    • 优点:可以为相关阻塞的操作单独开启线程或者进程,阻塞操作就可以异步执行
    • 弊端:无法无限制的开启多线程或者多进程
    from time import time
    from requests import get
    from threading import Thread
    
    
    class MyThread(Thread):
        def __init__(self, target, args=(), kwargs={}):
            super(MyThread, self).__init__()
            self.daemon = True
            self.target = target
            self.args = args
            self.kwargs = kwargs
            self.start()  # 自动开启进程
    
        def run(self):
            self.target(*self.args, **self.kwargs)
    
    urls = [
        \"wp-content/uploads/2022/03/https://www.173top.cn/wp-content/uploads/2022/03/1646282972-20220303044932-622048dcdc41d.jpg\",
        \"wp-content/uploads/2022/03/https://www.173top.cn/wp-content/uploads/2022/03/1646282973-20220303044933-622048dd855c5.jpg\",
        \"wp-content/uploads/2022/03/https://www.173top.cn/wp-content/uploads/2022/03/1646282973-20220303044933-622048ddb2cc3.jpg\",
    ]
    
    def get_content(url):
        print(\"正在获取:\", url)
        resp = get(url=url).content
        name = url.split(\"/\")[-1]
        if resp:
            with open(f\"./img/{name}\", \"wb\") as f:
                f.write(resp)
            print(\"下载完成\")
        else:
            print(\"请求失败\")
    
    sta = time()
    lis = []
    for i in urls:
        mt = MyThread(get_content, args=(i, ))
        lis.append(mt)
    
    for i in lis:
        i.join()
    
    print(f\"全部下载完成,用时{time() - sta}\")
    

2.2 线程池,进程池

  • 线程池,进程池:

    • 优点:我们可以降低系统对进程或者线程创建和销毁的一个频率,从而很好的降低系统的开销
    • 弊端:池中线程或进程的数量有上限,适当使用
    from time import time
    from requests import get
    from concurrent.futures import ThreadPoolExecutor
    
    urls = [
        \"wp-content/uploads/2022/03/https://www.173top.cn/wp-content/uploads/2022/03/1646282972-20220303044932-622048dcdc41d.jpg\",
        \"wp-content/uploads/2022/03/https://www.173top.cn/wp-content/uploads/2022/03/1646282973-20220303044933-622048dd855c5.jpg\",
        \"wp-content/uploads/2022/03/https://www.173top.cn/wp-content/uploads/2022/03/1646282973-20220303044933-622048ddb2cc3.jpg\",
    ]
    
    def get_content(url):
        print(\"正在获取:\", url)
        resp = get(url=url).content
        name = url.split(\"/\")[-1]
        if resp:
            with open(f\"./img/{name}\", \"wb\") as f:
                f.write(resp)
            print(\"下载完成\")
        else:
            print(\"请求失败\")
    
    sta = time()
    with ThreadPoolExecutor(len(urls)) as t:
        t.map(get_content, urls)
    print(f\"全部下载完成,用时{time() - sta}\")
    

2.3 单线程 + 协程(推荐)

  • 单线程 + 协程(推荐)

    • [1] event_loop:事件循环,相当于一个无限循环,我们可以把一些函数注册到这个事件循环上,当满足条件发生的时候,就会调用对应的处理方法
    • [2] coroutine:中文翻译叫协程,在 Python 中常指代为协程对象类型,我们可以将协程对象注册到时间循环中,它会被事件循环调用。我们可以使用 async 关键字来定义一个方法,这个方法在调用时不会立即被执行,而是返回一个协程对象
    • [3] task:任务,它是对协程对象的进一步封装,包含了任务的各个状态
    • [4] future:代表将来执行或没有执行的任务的结果,实际上和 task 没有本质区别。 另外我们还需要了解 async/await 关键字,它是从 Python 3.5 才出现的,专门用于定义协程。其中,async 定义一个协程,await 用来挂起阻塞方法的执行

2.3.1 单任务协程

import asyncio

async def request(url):
    print(\"正在请求:\", url)
    print(\"请求成功\")
    return url

# async修饰的函数,调用之后返回的一个协程对象
c = request(\"www.baidu.com\")


# # 创建一个任务循环对象
# loop = asyncio.get_event_loop()
# # task 的使用:基于 loop 创建一个对象
# task = loop.create_task(c)
# print(task)
# # 将协程对象注册到 loop 中
# loop.run_until_complete(task)
# print(task)

# loop = asyncio.get_event_loop()
# # future 的使用,不用基于协程对象
# task = asyncio.ensure_future(c)
# print(task)
# loop.run_until_complete(task)
# print(task)

# 绑定回调
def callback(task):
    print(task.result())


loop = asyncio.get_event_loop()
task = asyncio.ensure_future(c)
# 将回调函数绑定到任务对象中
task.add_done_callback(callback)
loop.run_until_complete(task)

2.3.2 多任务协程

import asyncio

# 在异步协程中如果出现了同步模块相关的代码,那么久无法实现异步
async def request(url):
    print(\"正在下载:\", url)
    await asyncio.sleep(3)
    print(\"下载完毕:\", url)
    return url

# 任务列表
tasks = [request(i) for i in range(10)]
done, pending = asyncio.run(asyncio.wait(tasks))
print(done)

#------------------------------
# 也可
tasks = []
for i in range(10):
    task =  asyncio.ensure_future(request(i))
    tasks.append(task)

loop = asyncio.get_event_loop()
done, pending = loop.run_until_complete(asyncio.wait(tasks))
print(done)

aiohttp:基于异步网络请求的模块

  • 注意:在获取响应数据操作之前一定要使用 await 进行手动挂起

  • text():返回字符串形式的响应数据

  • read():返回二进制形式的响应数据

  • json():返回的是 JSON 对象

requests:是基于同步的,必须使用基于异步的网络请求模块进行指定的url的请求发送

五、 selenium

1、 简介

selenium 基本使用

问题:selenium 模块和爬虫之间有怎么样的关系?

  • 便捷的获取网站中动态加载的数据
  • 便捷实现模拟登录

什么是 selenium 模块?

  • 基于浏览器自动化的一个模块

2、 用法

使用流程:

  • 环境安装:pip install selenium

  • 下载浏览器驱动程序

  • 实例化浏览器对象

  • 编写基于浏览器自动化的操作代码

    • 发起请求:get(url)
    • 标签定位:find 系列方法
    • 标签交互:send_keys(\"xxx\")
    • 执行 JS 代码:excute_script(\"jsCode\")

3、 注意

如果定位的标签是存在于 iframe 标签中的则必须要进入 iframe 标签内在进行定位

# 先通过xpth定位到iframe
xf = driver.find_element_by_xpath(\'//*[@id=\"x-URS-iframe\"]\')
# 再将定位对象传给switch_to_frame()方法
driver.switch_to_frame(xf)
driver.switch_to_default_content()  # 退出框架

4、 动作链

from selenium.webdriver.common.action_chains import ActionChains

# 实例化动作链
act = ActionChains(web)
# 点击长按
act.click_and_hold(div)
for i in range(5):
    act.move_by_offset(17, 0).perform()  # perform 表示立即执行动作链动作
# 释放动作链
act.release()
web.quit()

来源:https://www.cnblogs.com/liuzhongkun/p/15957329.html
本站部分图文来源于网络,如有侵权请联系删除。

未经允许不得转载:百木园 » Python 爬虫高阶

相关推荐

  • 暂无文章