mermaid画流程图

Mermaid 在线编辑器 (opens new window)
Mermaid 在线编辑器 (opens new window)

flowchart TB
    subgraph 采集层
        A[Scrapy-Redis 爬虫集群] -->|爬取原始 JSON| B[Kafka: raw_prices]
    end
    
    subgraph 实时处理层
        B --> C[Flink Streaming 作业]
        C -->|聚合结果| D[Kafka: agg_prices]
    end
    
    subgraph 存储层
        D --> E[InfluxDB（实时时序）]
        D --> F[HDFS 分区（yyyy/MM/dd）]
        F --> G[Hive 外部表]
    end
    
    subgraph 可视化层
        E --> H[Grafana 实时大屏]
        G --> I[ECharts Web 分析]
    end

flowchart TB
    subgraph 采集层
        A[Scrapy-Redis<br/>爬虫集群]
            -->|爬取原始 JSON|B[Kafka: raw_prices]
    end

    subgraph 实时处理层
        B
            --> C[Flink Streaming<br/>作业]
        C
            -->|聚合结果| D[Kafka: agg_prices]
    end

    subgraph 存储层
        D
            --> E[InfluxDB<br/>（实时时序）]
        D
            --> F[HDFS 分区<br/>（yyyy/MM/dd）]
        F
            --> G[Hive 外部表]
    end

    subgraph 可视化层
        E
            --> H[Grafana<br/>实时大屏]
        G
            --> I[ECharts Web 分析]
    end