# 如何像生产软件一样调度和监控网络爬虫

调度一个爬虫只占20%的工作。保持其正常运行——捕捉到它默默返回空行或阻塞率逐渐增加的那一天——才是真正的任务。以下是如何像生产软件一样运行爬虫的方法。

让爬虫按计划运行大约需要五行代码。让它在几个月内持续产生正确的数据——应对布局变化、新的访问控制和阻塞率的逐渐增加——才是真正的工程。一个定时爬虫是生产软件，你应该害怕的失败不是响亮的崩溃，而是无声的崩溃：一次返回`200 OK`和空行的运行，而下游的每个人都认为数据是新鲜的。本指南涵盖调度、新鲜度SLA、质量门槛、漂移检测和警报。

## 调度：本地，然后云端

对于单台机器，最简洁的选项是使用Python的`schedule`库进行直观的进程内定时，或在macOS和Linux上使用系统cron（Windows上使用任务计划程序）。`schedule`几乎像英语一样易读：

```python
import schedule, time
from my_scraper import run_job

schedule.every().day.at("06:30").do(run_job)     # daily pull
schedule.every(10).minutes.do(run_job)            # or a tight loop

while True:
    schedule.run_pending()
    time.sleep(1)
```

进程内调度的问题在于它会随着进程的结束而终止。对于任何重要的事情，转向一个可以在重启后继续运行的调度器。Cron是最简单的；像GitHub Actions这样的免费CI运行器是最便携的，因为它可以同时对爬虫和调度进行版本控制：

```bash
# crontab -e : run the scraper every day at 06:30, log output
30 6 * * *  cd /srv/scraper && /usr/bin/python run.py >> /var/log/scraper.log 2>&1
```

```js
# .github/workflows/scrape.yml  (GitHub Actions, free minutes)
name: daily-scrape
on:
  schedule:
    - cron: '30 6 * * *'      # 06:30 UTC daily
jobs:
  run:
    runs-on: ubuntu-latest
    steps:
      - uses: actions/checkout@v4
      - run: pip install -r requirements.txt
      - run: python run.py
        env:
          PROXY_URL: ${{ secrets.PROXY_URL }}   # USER:PASS@residentialpremium.quantumproxies.io:8080
```

云端运行器（GitHub Actions、托管函数、托管调度器）还提供免费重试和日志。不管你选择什么，把代理凭证保存在秘密存储中，而不是代码库中。

## 真正的问题是漂移，而不是调度

针对特定HTML选择器编写的爬虫几乎不可能无限期地保持活力，因为目标会在它们下面发生变化。网站会重构其标记，添加访问控制，收紧速率限制或更新robots.txt，任何这些都可能将一个正常工作的爬虫变成一个什么都不返回的爬虫——通常不会抛出错误。这就是为什么监控比调度更重要：调度器运行任务，但只有监控才能告诉你任务是否停止产生数据。一个在布局变化后持续返回空结果的爬虫是[页面呈现与预期不同](https://quantumproxies.io/blog/scraper-returns-empty-page-javascript)的经典案例。

让漂移可检测，而不仅仅是可生存。记录每次运行的行数和每个字段的填充率，并保留这些历史记录——一个简单的每次运行记录的图表可以将无声的布局变化变成明显的悬崖。与一个金丝雀配对：抓取一个你已硬编码正确输出的已知页面，并在解析器返回不同内容时大声失败。捕捉单个金丝雀页面上的漂移比在一周后发现它要便宜得多，因为坏数据已经传播到每个下游报告和模型中。

![每次定时抓取运行都要经过四个阶段：重启后依然生效的 cron 或 CI 调度、通过轮换住宅 IP 抓取、拦下异常运行的校验关卡，然后是告警和交付到云存储；卡片显示，正常运行照常交付，而返回空内容的 200 OK 运行和缺失的心跳会触发告警。](https://res.cloudinary.com/dmqliab0t/image/upload/f_auto,q_auto,w_1200/v1785335206/blog/generated/qp-b9-078-diag1.png)
*每次定时运行都经过相同的四个阶段——验证门槛是阻止无声空运行被发布的关键。*

## 设定数据新鲜度SLA

决定你的数据允许的最大年龄并强制执行。如果下游模型或仪表板需要不超过24小时的数据，那就是一个新鲜度SLA——它需要一个警报，而不是一个希望。在收集时为每条记录加上时间戳，跟踪每个来源的最新行的年龄，并在最新成功提取超过你的阈值时发出警报。过时的数据是无声的毒药，正因为没有东西坏掉；数字只是悄悄地停止移动。一个持续监控的模型——检查变化并只捕获移动的内容——比盲目地重新抓取所有内容要好得多，并且对你的阻塞预算更友好。

## 质量门槛捕捉崩溃未能捕捉的内容

抓取管道中最有价值的保护是一个验证门槛，当输出偏离正常时停止运行。设定明确的阈值：每次运行的最小记录数（一个通常返回约2,000行但返回400行的任务是基础设施故障），空页面的最大份额（比如3%），以及每列的履行规则（标题和价格100%，一个可选字段如折扣仅5%）。在违反时停止，而不是将坏数据写入下游：

```python
def quality_gate(rows, min_rows=2000, max_empty=0.03):
    empty = sum(1 for r in rows if not r.get("title"))
    if len(rows) < min_rows:
        raise RuntimeError(f"too few rows: {len(rows)} < {min_rows}")
    if empty / max(len(rows), 1) > max_empty:
        raise RuntimeError(f"empty pages {empty/len(rows):.0%} over {max_empty:.0%}")
    if any(r.get("price") in (None, "") for r in rows):
        raise RuntimeError("price column not 100% filled")
    return rows   # only clean runs reach storage and alerts
```

![一个 Python 质量关卡，当一次运行少于 2000 行、空页面超过 3% 或有任何价格缺失时抛出错误；卡片列出了阈值：每次运行至少 2,000 条记录，空页面最多 3%，价格 100% 填充，可选的折扣字段为 5%。](https://res.cloudinary.com/dmqliab0t/image/upload/f_auto,q_auto,w_1200/v1785335207/blog/generated/qp-b9-078-diag2.png)
*质量门槛将无声的空运行变成在坏数据传播之前被捕捉到的警报失败。*

## 对阻塞率而不仅仅是错误发出警报

一个突然被阻止的爬虫通常仍然会干净地退出——它只是返回更少、更薄的结果。跟踪被阻止或挑战的响应（403s、429s、CAPTCHA页面）与总请求的比率，并在超过阈值时发出警报。上升的阻塞率是你的IP或指纹被标记的最早信号，它让你在数据集退化之前做出反应。阻塞率的持久解决方案在上游：通过旋转的住宅IP路由，让[Scraper API](https://quantumproxies.io/scraper-api)处理渲染、旋转和重试，这样目标变化就不会默默地饿死你的管道。当429s逐渐出现时，我们的[速率限制指南](https://quantumproxies.io/blog/fix-429-too-many-requests-scraping)涵盖了退避和节奏方面。

[使用Scraper API保持定时爬虫不被阻止](https://quantumproxies.io/scraper-api)

## Webhooks和交付

通过推送通知而不是轮询来闭合循环。一个在运行完成时触发的webhook——带有状态、记录数和作业ID——让下游系统立即做出反应，并为你提供一个心跳，如果它丢失，你可以发出警报。将验证后的输出交付到云存储（S3、GCS、仓库）而不是本地文件，这样通过质量门槛的运行就可以直接进入分析。对于一系列定时作业下的队列和重试，请参阅我们的[大规模爬取架构指南](https://quantumproxies.io/blog/large-scale-web-scraping-architecture)。

## 常见问题

### 如何调度网络爬虫？

对于单台机器，使用Python的`schedule`库或系统cron；对于任何持久的东西，使用一个可以在重启后继续运行的调度器，比如服务器上的cron或带有cron触发器的GitHub Actions这样的免费CI运行器。云端运行器还提供重试和日志。将代理凭证保存在秘密存储中，并将爬虫与其调度一起进行版本控制。

### 如何知道我的定时爬虫是否出故障？

不要依赖崩溃——一个出故障的爬虫通常会干净地退出，带有空或部分数据。添加一个质量门槛，检查最小记录数、空页面份额和每列履行，并在任何阈值被突破时发出警报。同时跟踪阻塞率和数据新鲜度，因为一个爬虫可能在看似成功的情况下默默返回过时或被阻止的结果。

### 为什么定时爬虫会停止工作？

目标发生变化：网站重构其HTML，添加访问控制，收紧速率限制或更新robots.txt，而基于选择器的爬虫在新页面上失效。网络故障和上升的阻塞率加剧了这一问题。这就是为什么监控——新鲜度SLA、质量门槛和阻塞率警报——比调度本身更重要；调度运行任务，监控证明它仍然有效。

### 什么是数据新鲜度SLA？

新鲜度SLA是指在数据被认为过时之前允许达到的最大年龄——例如，没有记录超过24小时。通过在收集时为每条记录加上时间戳，跟踪每个来源的最新行，并在最新成功提取超过限制时发出警报来强制执行。它捕捉到爬虫停止更新而没有错误的安静失败。

使用一个可以在重启后继续运行的调度器进行调度，然后将精力花在实际隐藏失败的地方：新鲜度SLA、质量门槛、漂移检测和阻塞率警报。在能够吸收目标变化的基础设施上运行收集，你的爬虫就会像它们本身就是生产软件一样运行。

[在Scraper API上运行可靠的定时爬取](https://quantumproxies.io/scraper-api)