在Python中使用Marshmallow处理POST请求并实现数据持久化

# models.py (示例：Django Model)
from django.db import models

class ObjectEntity(models.Model):
    """
    表示数据库中的一个实体对象。
    """
    operatorId = models.CharField(max_length=100, verbose_name="操作员ID")
    createdAt = models.DateField(auto_now_add=True, verbose_name="创建日期")
    operator = models.CharField(max_length=100, verbose_name="操作员名称")
    inaction = models.IntegerField(default=1, verbose_name="不活跃状态")

    class Meta:
        verbose_name = "实体对象"
        verbose_name_plural = "实体对象"

    def __str__(self):
        return f"{self.operatorId} - {self.operator}"

# serializers.py (示例：Marshmallow Schema)
from marshmallow import Schema, fields, ValidationError
# 假设 ObjectEntity 模型定义在 models.py 中，需要正确导入
# from .models import ObjectEntity 

class ObjectSchema(Schema):
    """
    用于序列化和反序列化 ObjectEntity 对象的 Marshmallow Schema。
    """
    id = fields.Integer(dump_only=True, required=False, description="对象ID，只读")
    operatorId = fields.Str(required=True, description="操作员ID")
    createdAt = fields.Date(dump_only=True, required=False, description="创建日期，只读")
    operator = fields.Str(required=True, description="操作员名称")
    inaction = fields.Integer(required=False, load_default=1, description="不活跃状态，默认为1")

    def create(self, data: dict) -> dict:
        """
        根据验证后的数据创建并持久化 ObjectEntity 对象。
        """
        try:
            # 1. 验证输入数据
            errors = self.validate(data)
            if errors:
                raise ValidationError(errors)

            # 2. 从验证后的数据中移除id和createdAt，因为它们是自动生成或只读的
            # 确保传递给create方法的数据只包含可写入的字段
            creatable_data = {
                k: v for k, v in data.items()
                if k not in ['id', 'createdAt']
            }

            # 3. 创建数据库对象
            obj = ObjectEntity.objects.create(**creatable_data)

            # 4. 序列化新创建的对象并返回
            return self.dump(obj)

        except ValidationError as err:
            # 捕获Marshmallow验证错误
            return {'errors': err.messages}
        except Exception as e:
            # 捕获其他可能的数据库或业务逻辑错误
            return {'errors': {'_general': str(e)}}

    # 注意：如果需要完整的CRUD操作，通常还会实现 update 方法
    # def update(self, instance, data):
    #     # ... 更新逻辑 ...
    #     pass

# views.py (示例：Django REST Framework View)
from rest_framework import generics
from rest_framework.request import Request
from rest_framework.response import Response
from django.http import JsonResponse
from http import HTTPStatus
import logging

# 假设 ObjectEntity 模型和 ObjectSchema 序列化器已正确导入
# from .models import ObjectEntity
# from .serializers import ObjectSchema

logger = logging.getLogger(__name__)

class ListEntityAPIView(generics.ListCreateAPIView):
    """
    处理 ObjectEntity 对象的列表查询和创建。
    """
    queryset = ObjectEntity.objects.all()
    serializer_class = ObjectSchema # 将 Marshmallow Schema 作为 DRF 的 serializer_class

    def get(self, request: Request, *args, **kwargs) -> JsonResponse:
        """
        获取所有 ObjectEntity 对象的列表。
        """
        objects = list(self.get_queryset())
        # 使用 Marshmallow Schema 序列化多个对象
        result = self.get_serializer(many=True).dump(objects)
        return JsonResponse(result, safe=False, status=HTTPStatus.OK)

    def post(self, request: Request, *args, **kwargs) -> JsonResponse:
        """
        创建新的 ObjectEntity 对象。
        """
        query_data = request.data # DRF 会自动处理请求体数据

        # 调用 Marshmallow Schema 的 create 方法来处理数据验证和持久化
        result = self.get_serializer().create(query_data)

        if 'errors' in result:
            logger.error('Error creating object: %s', str(result['errors']))
            return JsonResponse(result, status=HTTPStatus.BAD_REQUEST)

        logger.info('Object created successfully: %s', str(result))
        # 成功创建，返回新创建的对象数据和 201 Created 状态码
        return JsonResponse(result, status=HTTPStatus.CREATED)