当前位置： 首页 > article >正文

CSDN数据大屏可视化【开源】

article 2024/12/24 20:54:01

项目简介

本次基于版本3 开源

版本3开源地址：https://github.com/nangongchengfeng/CsdnBlogBoard.git
在这里插入图片描述

版本1开源地址：https://github.com/nangongchengfeng/CSDash.git

这是一个基于 Python 的 CSDN 博客数据可视化看板项目，通过爬虫采集 CSDN 博客数据，并以现代化的可视化界面展示博主的各项数据指标。该项目采用前后端分离架构，集成了数据采集、数据存储、API 服务和数据可视化等多个功能模块。
版本一**在这里插入图片描述
版本二
在这里插入图片描述
版本三
在这里插入图片描述

技术栈

后端技术

  • Python Flask: 作为 Web 框架，提供 RESTful API 服务
  • SQLAlchemy: ORM 框架，用于数据库操作
  • BeautifulSoup4: 网页解析，用于爬虫数据提取
  • Requests: HTTP 请求库，用于数据爬取

前端技术

  • ECharts: 强大的数据可视化图表库
  • Axios: HTTP 客户端，用于前后端数据交互
  • 现代 CSS: Flexbox 布局、CSS 变量、响应式设计

核心功能模块

1. 数据采集模块

数据采集模块通过spider.py实现，是项目的核心组件之一。该模块采用了多种技术和策略来确保数据采集的准确性、稳定性和实时性。

1.1 核心技术栈
  • Requests: 处理 HTTP 请求，支持自定义请求头和超时设置
  • BeautifulSoup4: 使用 lxml 解析器进行高效的 HTML 解析
  • 正则表达式(re): 用于精确提取数字和特定格式的数据
  • SQLAlchemy: 实现数据持久化和 ORM 映射
  • 随机延时策略: 使用 random.uniform() 避免频繁请求
1.2 数据采集功能
1.2.1 博主基础信息采集

  • 采集内容：

    • 用户名和头像
    • 文章数量统计
    • 粉丝数和访问量
    • 点赞和评论数
    • 等级和积分信息
    • 博主排名数据

  • 技术实现：

    # 示例：用户信息提取
user_info = soup.find('div', class_='user-info d-flex flex-column profile-intro-name-box')
author_name = user_info.find('a').get_text(strip=True)
1.2.2 文章分类信息采集

  • 采集内容：

    • 专栏名称和链接
    • 专栏文章数量
    • 订阅人数统计
    • 阅读量和收藏数
    • 专栏唯一标识

  • 技术实现：

    # 示例：分类信息提取
spans = soup.find_all('a', attrs={'class': 'special-column-name'})
for span in spans:
    href = span.get('href')
    blog_column = span.text.strip()
1.3 错误处理机制

  1. 多级异常处理

    • 请求异常捕获
    • 数据解析异常处理
    • 数据库操作异常处理

  2. 重试机制

    max_retries = 3
retry_count = 0
while retry_count < max_retries:
    try:
        # 请求逻辑
    except Exception:
        retry_count += 1
        time.sleep(5)  # 失败后等待
1.4 数据更新策略

  1. 增量更新机制

    • 检查数据是否存在
    • 根据情况执行更新或插入
    • 保持数据时效性

  2. 数据一致性保证

    with app.app_context():
    existing_info = Info.query.filter_by(author_name=author_name).first()
    if existing_info:
        # 更新现有记录
    else:
        # 插入新记录
1.5 性能优化策略

  1. 请求优化

    • 自定义请求头
    • 连接超时设置
    • 随机延时控制

  2. 解析优化

    • 使用 lxml 解析器提升性能
    • 精确的选择器定位
    • 数据预处理和清洗

  3. 存储优化

    • 批量数据处理
    • 事务管理
    • 会话复用
1.6 反爬虫策略应对

  1. 请求头模拟

    headers = {
    'User-Agent': 'Mozilla/5.0 (MSIE 10.0; Windows NT 6.1; Trident/5.0)',
    'referer': 'https://passport.csdn.net/login'
}

  2. 访问频率控制

    • 随机延时间隔
    • 请求限速
    • IP 代理支持（预留）

2. 数据存储模块

数据存储模块采用 SQLAlchemy ORM 框架进行数据建模，实现了高效的数据持久化和查询操作。该模块设计了三个核心数据模型，每个模型都针对特定的数据场景进行了优化。

2.1 数据模型设计
2.1.1 博主信息模型 (Info)
class Info(db.Model):
    __tablename__ = 'info'

    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
    date = db.Column(db.Text)                # 数据更新时间
    head_img = db.Column(db.Text)           # 博主头像URL
    author_name = db.Column(db.Text)        # 博主用户名
    article_num = db.Column(db.Text)        # 文章总数
    fans_num = db.Column(db.Text)           # 粉丝数量
    like_num = db.Column(db.Text)           # 获赞数量
    comment_num = db.Column(db.Text)        # 评论数量
    level = db.Column(db.Text)              # 博主等级
    visit_num = db.Column(db.Text)          # 访问量
    score = db.Column(db.Text)              # 积分
    rank = db.Column(db.Text)               # 排名

特点说明：

  • 使用自增主键确保记录唯一性
  • 采用 Text 类型存储可变长度文本
  • 包含完整的博主数据画像
  • 支持时间序列分析（通过 date 字段）
2.1.2 文章分类模型 (Categorize)
class Categorize(db.Model):
    __tablename__ = 'categorize'

    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
    href = db.Column(db.Text)               # 分类链接
    categorize = db.Column(db.Text)         # 分类名称
    categorize_id = db.Column(db.BigInteger) # 分类ID
    column_num = db.Column(db.BigInteger)    # 专栏数量
    num_span = db.Column(db.BigInteger)      # 订阅数量
    article_num = db.Column(db.BigInteger)   # 文章数量
    read_num = db.Column(db.BigInteger)      # 阅读量
    collect_num = db.Column(db.BigInteger)   # 收藏数

特点说明：

  • 使用 BigInteger 类型存储大数值数据
  • 支持分类数据的统计分析
  • 包含完整的分类元数据
  • 可追踪分类的受欢迎程度
2.1.3 文章详情模型 (Article)
class Article(db.Model):
    __tablename__ = 'article'

    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
    url = db.Column(db.Text)                # 文章链接
    title = db.Column(db.Text)              # 文章标题
    date = db.Column(db.Text)               # 发布日期
    read_num = db.Column(db.BigInteger)     # 阅读数
    comment_num = db.Column(db.BigInteger)  # 评论数
    type = db.Column(db.Text)               # 文章类型

特点说明：

  • 记录文章的基本信息和统计数据
  • 支持文章时间序列分析
  • 可追踪章的受欢迎程度
  • 便于文章分类统计
2.2 数据库优化策略

  1. 字段类型优化

    • 使用 BigInteger 存储大数值，避免数值溢出
    • 采用 Text 类型存储变长文本，节省存储空间
    • 主键使用自增 Integer，提高插入性能

  2. 查询性能优化

    • 可以根据需要添加索引
    • 支持复杂的聚合查询
    • 优化的数据结构设计

  3. 数据一致性保证

    • 主键约束确保记录唯一性
    • 适当的字段类型确保数据完整性
    • 支持事务操作
2.3 数据操作示例
  1. 数据插入
new_info = Info(
    author_name="博主名称",
    article_num="100",
    fans_num="1000"
)
db.session.add(new_info)
db.session.commit()
  1. 数据查询
# 获取博主信息
author_info = Info.query.filter_by(author_name="博主名称").first()

# 获取分类统计
categories = Categorize.query.order_by(Categorize.read_num.desc()).all()

# 获取热门文章
hot_articles = Article.query.order_by(Article.read_num.desc()).limit(10).all()
  1. 数据更新
info = Info.query.filter_by(author_name="博主名称").first()
info.fans_num = str(int(info.fans_num) + 1)
db.session.commit()

3. 可视化展示模块

前端采用现代化的可视化方案，基于 ECharts 实现了丰富的数据可视化功能，并通过 Axios 实现了与后端的数据交互。

3.1 技术架构

  1. 核心技术

    • ECharts 5.5.1：数据可视化库
    • Axios：HTTP 客户端
    • CSS3：现代布局和动画
    • Flexbox：响应式布局

  2. 设计规范

    :root {
  --bg-primary: #f7f8fa;
  --bg-secondary: #ffffff;
  --text-primary: #333333;
  --text-secondary: #555555;
  --accent-color: #0066cc;
  --border-radius: 12px;
  --shadow: 0 4px 6px rgba(0, 0, 0, 0.05);
}
3.2 图表组件实现
3.2.1 柱状图（季度数据分析）

  1. 数据流程

    async function updateBarChart() {
  // 1. 获取数据
  const response = await axios.get("/api/quarter");

  // 2. 数据转换
  const dimensions = [
    ...Object.keys(chartData[0]).filter((key) => key !== "category"),
  ];
  const source = chartData.map((item) => ({
    product: item.category,
    ...item,
  }));

  // 3. 图表配置
  const option = {
    legend: {},
    tooltip: {},
    dataset: {
      dimensions: dimensions,
      source: source,
    },
    xAxis: { type: "category" },
    yAxis: {},
    series: dimensions.slice(1).map((dim) => ({
      type: "bar",
      name: dim,
    })),
  };
}

  2. 交互特性

    • 动态数据加载
    • 点击事件响应
    • 自适应布局
3.2.2 饼图（分类占比分析）

  1. 实现细节

    async function updatePieChart() {
  // 1. 数据获取
  const response = await axios.get("/api/categorize");

  // 2. 图表配置
  const option = {
    tooltip: {
      trigger: "item",
      formatter: "{a} <br/>{b}: {c} ({d}%)",
    },
    series: [
      {
        name: "分类统计",
        type: "pie",
        radius: ["30%", "70%"],
        data: chartData,
        label: {
          show: true,
          position: "outside",
          formatter: "{b}: {d}%",
        },
      },
    ],
  };
}

  2. 视觉优化

    • 内外半径设计
    • 标签自动布局
    • 悬停动画效果
3.2.3 混合图表（阅读量分析）
async function updateMixChart() {
  const option = {
    color: ["#3E82F7", "#F86C6B"],
    tooltip: {
      trigger: "axis",
      axisPointer: {
        type: "shadow",
      },
    },
    legend: {
      data: ["文章数", "阅读量"],
    },
    grid: {
      top: "10%",
      bottom: "25%",
      right: "10%",
    },
  };
}
3.3 响应式布局实现

  1. 布局结构

    <div class="dashboard-container">
  <div class="top-section">
    <div class="mac-header">...</div>
    <div class="stats-grid">...</div>
  </div>
  <!-- 图表容器 -->
</div>

  2. 样式优化

    .dashboard-container {
  display: flex;
  flex-direction: column;
  height: 100vh;
  padding: 15px;
  gap: 15px;
}
3.4 数据更新机制

  1. 初始化流程

    function initCharts() {
  updateBarChart();
  updatePieChart();
  updateMixChart();
  updateHeatmap();
  updateArticleList();
}

  2. 数据刷新策略

    • 页面加载时初始化
    • 用户交互触发更新
    • 定时自动刷新
3.5 交互设计

  1. 图表联动

    • 点击饼图更新文章列表
    • 柱状图分类筛选
    • 数据钻取功能

  2. 视觉反馈

    .stat-card:hover,
.chart-card:hover {
  transform: translateY(-5px);
  box-shadow: 0 6px 12px rgba(0, 0, 0, 0.08);
}
3.6 性能优化

  1. 加载优化

    • 异步数据加载
    • 图表按需渲染
    • 防抖和节流处理

  2. 渲染优化

    • 合理的图表配置
    • 数据预处理
    • 动画性能调优

4. 后端实现逻辑流程

4.1 核心技术栈
  • Flask: Web 框架
  • Blueprint: 路由模块化
  • Cache: 文件系统缓存
  • SQLAlchemy: ORM 数据库操作
  • PyMySQL: MySQL 数据库驱动
4.2 系统架构

在这里插入图片描述

4.3 核心功能实现
4.3.1 应用初始化
app = Flask(__name__)
# 配置缓存
cache.init_app(app, config={
    'CACHE_TYPE': 'filesystem',
    'CACHE_DIR': 'cache-directory'
})
# 数据库配置
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://user:pass@host:port/db'
db.init_app(app)
4.3.2 路由注册机制
DEFAULT_BLUEPRINT = [
    (cs, '/'),  # CSDN API蓝图
]
url_path_prefix = "/api"

def config_blueprint(app):
    for blueprint, url_prefix in DEFAULT_BLUEPRINT:
        url_prefix = url_path_prefix + url_prefix
        app.register_blueprint(blueprint, url_prefix=url_prefix)
4.4 API 接口设计
4.4.1 数据统计接口
  1. 季度数据统计
@cs.route('/quarter')
@cache.cached(timeout=60)
def GetQuarter():
    """获取每年每季度博客数量"""
    year_quarter_count = defaultdict(lambda: defaultdict(int))
    data = GetArticle()
    for article in data:
        year = article["year"]
        quarter = article["quarter"]
        year_quarter_count[year][quarter] += 1
    return Result.success(result)
  1. 分类数据统计
@cs.route('/categorize')
@cache.cached(timeout=60)
def Pie():
    """获取文章分类统计"""
    categorize_data = Categorize.query.all()
    pie_data = [
        {"value": item.article_num, "name": item.categorize}
        for item in categorize_data
    ]
    return Result.success(pie_data)
4.4.2 数据处理流程

在这里插入图片描述

4.5 性能优化策略

  1. 缓存优化

    • 使用文件系统缓存
    • 60 秒缓存过期时间
    • 针对高频访问接口启用缓存

  2. 数据处理优化

    • 使用 defaultdict 优化数据聚合
    • 批量数据查询
    • 查询 据预处理和转换

  3. 查询优化

    • ORM 延迟加载
    • 查询结果缓存
    • 合理的数据索引
4.6 数据流转流程

在这里插入图片描述

4.7 错误处理机制

  1. 全局异常处理

    try:
    # 业务逻辑
except Exception as e:
    print(f"Error: {str(e)}")
    return Result.error(str(e))

  2. 数据验证

    if not data or not data.labels:
    return Result.error("Invalid data format")

  3. 结果封装

    class Result:
    @staticmethod
    def success(data):
        return jsonify({"code": 200, "data": data})

    @staticmethod
    def error(msg):
        return jsonify({"code": 500, "msg": msg})

技术总结

1. 技术栈全景图

在这里插入图片描述


http://www.kler.cn/a/443741.html

相关文章：

  • Spring Security 6 系列之七 - 自定义异常管理
  • Redis分片集群学习总结
  • RHEL 7.5 源码安装 mysql-5.7.17 数据库
  • 服务器数据恢复—V7000存储中多块磁盘出现故障导致业务中断的数据恢复案例
  • c++--------c++概念
  • 构建高性能异步任务引擎：FastAPI + Celery + Redis
  • 树莓派3B+驱动开发（8）- i2c控制PCF8591
  • [HNCTF 2022 Week1]baby_rsa
  • 计算机网络之王道考研读书笔记-2
  • linux_x64 下的一般汇编函数与syscall调用约定
  • 使用copilot轻松将电子邮件转为高效会议
  • 【WRF-Urban】输入空间分布人为热排放数据的WRF运行全过程总结
  • Android13 系统签名应用编译调试说明
  • 使用国内镜像网站在线下载安装Qt（解决官网慢的问题）——Qt
  • koa实现图片上传接口(本地生成)
  • 单点登录平台Casdoor搭建与使用，集成gitlab同步创建删除账号
  • Webpack学习笔记（2）
  • 智慧公交指挥中枢，数据可视化 BI 驾驶舱
  • 【操作系统】数据集合集！
  • 数电课设·简易数字钟（Quartus Ⅱ）
  • 【游戏中orika完成一个Entity的复制及其Entity异步落地的实现】 1.ctrl+shift+a是飞书下的截图 2.落地实现
  • 多个图片转换为PDF文件
  • 时空AI赋能低空智能科技创新
  • IAR中如何而将定义的数组放在指定的位置
  • 【硬件IIC】stm32单片机利用硬件IIC驱动OLED屏幕
  • C05S09-Keepalive服务架设