graph TB
    subgraph Control["🖥️ 控制节点"]
        PB[Playbook YAML]
        API[Ansible API / ansible-runner]
        ENG[Ansible Engine]
        INV[Inventory 解析器]
    end

    subgraph Transport["📡 传输层"]
        SSH[(SSH 连接)]
        PBK[paramiko / native ssh]
    end

    subgraph Targets["🎯 目标节点群"]
        T1[节点 1<br/>crawler-1<br/>10.0.1.11]
        T2[节点 2<br/>crawler-2<br/>10.0.1.12]
        T3[节点 3<br/>crawler-3<br/>10.0.1.13]
        T4[节点 4<br/>crawler-4<br/>10.0.1.14]
        T5[节点 5<br/>crawler-5<br/>10.0.1.15]
    end

    subgraph Ext["🗄️ 外部依赖"]
        REDIS[(Redis 队列<br/>10.0.1.100:6379)]
        GIT[Git 仓库<br/>GitHub]
    end

    PB --> API
    API --> ENG
    ENG --> INV
    INV --> SSH
    SSH --> T1
    SSH --> T2
    SSH --> T3
    SSH --> T4
    SSH --> T5
    T1 -.-> REDIS
    T2 -.-> REDIS
    T3 -.-> REDIS
    T4 -.-> REDIS
    T5 -.-> REDIS
    T1 -.-> GIT
    T2 -.-> GIT

sequenceDiagram
    participant User as 用户/脚本
    participant AR as ansible-runner
    participant AN as Ansible Core
    participant INV as Inventory
    participant SSH as SSH Client
    participant Node as 目标节点

    User->>AR: run(playbook, inventory, extravars)
    AR->>AN: 加载 Playbook
    AN->>INV: 解析主机清单
    INV-->>AN: 返回主机列表
    AN->>AN: 解析 tasks / handlers

    loop 每个 Task
        AN->>AN: 序列化模块参数
        AN->>SSH: 建立连接 (fork=5 并行)
        SSH->>Node: 推送模块代码
        Node->>Node: 执行模块逻辑
        Node-->>SSH: 返回 JSON 结果
        SSH-->>AN: 收集 ok/changed/failed
    end

    AN->>AR: 汇总统计 (stats)
    AR-->>User: 返回结构化结果对象

graph LR
    subgraph "🎛️ 控制平面"
        CTL[控制节点<br/>ansible-runner<br/>deploy-crawler.yml]
    end

    subgraph "🕷️ 爬虫层 - 蜘蛛节点"
        S1[crawler-1<br/>spider<br/>4C/8G]
        S2[crawler-2<br/>spider<br/>4C/8G]
    end

    subgraph "🔍 爬虫层 - 解析节点"
        P3[crawler-3<br/>parser<br/>2C/4G]
        P4[crawler-4<br/>parser<br/>2C/4G]
        P5[crawler-5<br/>parser<br/>2C/4G]
    end

    subgraph "📦 数据层"
        RS[Redis 集群<br/>队列/去重/调度<br/>10.0.1.100:6379]
        PG[(PostgreSQL<br/>结果存储)]
    end

    CTL -.->|SSH 并行部署| S1
    CTL -.->|SSH 并行部署| S2
    CTL -.->|SSH 并行部署| P3
    CTL -.->|SSH 并行部署| P4
    CTL -.->|SSH 并行部署| P5

    S1 -->|推送任务| RS
    S2 -->|推送任务| RS
    P3 -->|消费任务| RS
    P4 -->|消费任务| RS
    P5 -->|消费任务| RS
    P3 -->|写入结果| PG
    P4 -->|写入结果| PG
    P5 -->|写入结果| PG

flowchart TD
    Start[Task 开始执行] --> LoadModule[加载对应模块<br/>如: service, file, pip]
    LoadModule --> QueryCurrent[查询当前状态]
    QueryCurrent --> Compare{当前状态<br/>== 目标状态?}
    Compare -->|是| NoChange[返回 changed=false<br/>不做任何操作]
    Compare -->|否| DoChange[执行变更操作<br/>安装/启动/修改]
    DoChange --> ReturnChanged[返回 changed=true]
    NoChange --> End[Task 结束]
    ReturnChanged --> End
    End --> NextTask[下一个 Task]

graph TD
    Failed[Task 失败] --> Strategy{错误策略}
    Strategy -->|any_errors_fatal: true| Fatal[立即停止所有主机<br/>整个 play 失败]
    Strategy -->|max_fail_percentage: 30%| Percentage[允许 30% 节点失败<br/>其余继续]
    Strategy -->|default| Default[单节点失败不影响其他<br/>继续执行下一 task]
    Strategy -->|ignore_errors: yes| Ignore[标记失败但继续<br/>不计入失败统计]
    Strategy -->|block/rescue/always| Block[进入 rescue 区块<br/>执行回滚/补救]
    Fatal --> Report[生成失败报告]
    Percentage --> Report
    Default --> Report
    Ignore --> Report
    Block --> Report