百木园-与人分享，
就是让自己快乐。
当前位置：百木园 > 野生技术 > 正文

Python 爬虫高阶

2022-03-04 分类：野生技术 阅读(262) 评论(0)

目录

  • 爬虫高阶
    • 一、 验证码识别
      • 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 爬虫高阶
标签：

相关推荐

  • 暂无文章

热门文章