使用openpyxl在Django中实现Excel数据批量导入

本教程详细指导如何在Django项目中实现Excel文件数据批量导入功能。我们将涵盖环境配置、前端文件上传表单的构建、后端视图逻辑处理，包括使用`openpyxl`库解析Excel文件、逐行读取数据并将其高效地保存到Django模型中，以及提供必要的代码示例和注意事项，帮助开发者轻松集成此功能。

在现代Web应用中，批量导入数据是一个常见需求，尤其是在需要初始化大量数据或定期更新数据时。手动输入效率低下且易出错，而通过Excel文件导入则能大大提高效率。本教程将以一个计算机产品管理系统为例，演示如何在Django中实现这一功能。

1. 准备工作：安装依赖

实现Excel文件导入功能的核心是使用一个能够解析Excel文件的Python库。openpyxl是广泛推荐且功能强大的选择，它支持读写.xlsx格式的Excel文件。

首先，请确保你的Python环境中安装了openpyxl：

pip install openpyxl

2. 定义Django模型

我们需要一个Django模型来存储从Excel文件中导入的数据。以下是一个示例模型，用于存储计算机产品信息：

# myapp/models.py
from django.db import models
from django.utils import timezone

class Product(models.Model):
    """
    用于存储计算机产品信息的模型。
    """
    model = models.CharField(max_length=50, null=True, verbose_name="型号")
    serial = models.CharField(max_length=50, null=True, verbose_name="序列号", unique=True) # 序列号通常是唯一的
    hd_size = models.CharField(max_length=50, null=True, verbose_name="硬盘大小")
    ram = models.CharField(max_length=50, null=True, verbose_name="内存")
    processor = models.CharField(max_length=50, null=True, verbose_name="处理器")
    date_created = models.DateTimeField(default=timezone.now, verbose_name="创建日期")
    date_updated = models.DateTimeField(auto_now=True, verbose_name="更新日期")

    class Meta:
        verbose_name = "产品"
        verbose_name_plural = "产品"
        ordering = ['-date_created'] # 按创建日期降序排序

    def __str__(self):
        return f"{self.serial} - {self.model}"

这个Product模型定义了计算机的型号、序列号、硬盘大小、内存和处理器等字段，以及创建和更新时间戳。注意，我们将serial字段设置为unique=True，以确保序列号的唯一性。

3. 创建文件上传前端页面

用户需要一个界面来选择并上传Excel文件。这通常通过一个HTML表单实现，该表单必须包含enctype="multipart/form-data"属性，以便正确处理文件上传。

创建一个名为import_product.html的模板文件（例如，在myapp/templates/myapp/目录下）：





    
    导入产品数据
    


    
        导入产品数据
        请选择一个包含计算机产品信息的Excel文件进行导入。

        {% if error_message %}
            {{ error_message }}
        {% endif %}
        {% if success_message %}
            {{ success_message }}
        {% endif %}

        
            {% csrf_token %}

enctype="multipart/form-data"：这是处理文件上传的关键属性，确保浏览器以正确的方式编码文件数据。
{% csrf_token %}：Django的安全机制，用于防止跨站请求伪造攻击（CSRF）。
：允许用户选择文件。name="excel_file"是后端视图中获取文件的键。
accept=".xlsx, .xls": 建议添加此属性以限制用户只能选择Excel文件类型，提高用户体验并减少后端不必要的文件类型检查。
onclick="history.back()": 提供一个简单的返回按钮，提升用户导航体验。

4. 实现后端导入逻辑

在Django的views.py文件中，我们将创建一个视图函数来处理文件上传和数据导入。

# myapp/views.py
import openpyxl
from django.shortcuts import render, redirect
from django.urls import reverse
from .models import Product # 假设Product模型在当前应用的models.py中

def import_product(request):
    """
    处理Excel文件上传并导入产品数据到数据库。
    """
    if request.method == 'POST':
        # 1. 获取上传的Excel文件
        if 'excel_file' not in request.FILES:
            return render(request, 'myapp/import_product.html', {'error_message': '请选择一个Excel文件。'})

        excel_file = request.FILES['excel_file']

        # 2. 验证文件类型（可选但推荐）
        # 检查文件扩展名是否为 .xlsx 或 .xls
        if not excel_file.name.endswith(('.xlsx', '.xls')):
            return render(request, 'myapp/import_product.html', {'error_message': '文件类型不正确，请上传Excel文件（.xlsx或.xls）。'})

        imported_count = 0
        errors = []

        try:
            # 3. 加载Excel工作簿
            wb = openpyxl.load_workbook(excel_file)
            # 4. 获取活动工作表（或指定名称的工作表，例如 wb['Sheet1']）
            ws = wb.active 

            # 用于批量创建对象的列表
            products_to_create = []

            # 5. 遍历工作表中的每一行数据
            # min_row=2 表示从第二行开始读取，跳过表头
            for row_idx, row in enumerate(ws.iter_rows(min_row=2, values_only=True), start=2):
                try:
                    # 6. 解包行数据并准备创建Product实例
                    # 确保Excel列的顺序与模型的字段顺序一致：型号, 序列号, 硬盘大小, 内存, 处理器
                    if len(row) < 5: # 检查列数是否足够
                        errors.append(f"第 {row_idx} 行数据不完整，跳过。")
                        continue

                    model, serial, hd_size, ram, processor = row[:5] # 只取前5列

                    # 简单的数据清洗和验证
                    if not serial:
                        errors.append(f"第 {row_idx} 行序列号为空，跳过。")
                        continue

                    # 检查序列号是否已存在 (在批量创建前进行预检查)
                    if Product.objects.filter(serial=serial).exists():
                        errors.append(f"第 {row_idx} 行序列号 '{serial}' 已存在，跳过。")
                        continue

                    products_to_create.append(Product(
                        model=model, 
                        serial=serial, 
                        hd_size=hd_

# excel # python # html # 前端 # go # 计算机 # 处理器 # 编码 # 浏览器 # app # 硬盘 # 后端 # ai # 数据清洗

返回目录在线咨询

上一篇：Linux中dd命令使用实例教程
下一篇：电商平台建站公司提供的SEO优化服务对店铺有何帮助？

您的项目需求

*请认真填写需求信息，我们会在24小时内与您取得联系。