Django DRF如何获取经ngrok转发的POST请求原始数据？

我正在开发基于Django REST framework（DRF）的API，该API接收经ngrok从外部端点转发的数据，当前使用的视图代码如下：

class MessageReceiver(generics.CreateAPIView):
    def post(self, request, org_id, channel_name):
        data = request.data
        if data:
            return Response(
                data={
                    "data": data
                },
                status=status.HTTP_200_OK
            )
        return Response(data={'message': 'No data received'}, status=status.HTTP_400_BAD_REQUEST)

我的需求是：在返回响应（或再次调用端点前），能够有效访问并处理request.data中的数据。

• 直接在视图的post方法内处理数据
  request.data是DRF已经解析后的结构化数据（通常为字典格式），你可以在返回响应前直接对其做校验、转换、存储等操作。示例：

  from django.utils import timezone
  from .models import Message
  
  class MessageReceiver(generics.CreateAPIView):
      def post(self, request, org_id, channel_name):
          data = request.data
          if data:
              # 处理数据：整合路径参数、提取关键内容
              processed_data = {
                  "org_id": org_id,
                  "channel": channel_name,
                  "content": data.get("content"),
                  "received_at": timezone.now()
              }
              # 示例：将处理后的数据存入数据库
              Message.objects.create(**processed_data)
              
              return Response(
                  data={"processed_data": processed_data},
                  status=status.HTTP_200_OK
              )
          return Response(data={'message': 'No data received'}, status=status.HTTP_400_BAD_REQUEST)
  

• 使用DRF序列化器做校验与结构化处理
  如果需要对输入数据做格式校验、字段映射，推荐用DRF序列化器，它能自动处理数据校验逻辑，还能直接生成模型实例。示例：
  先定义序列化器：

  from rest_framework import serializers
  from .models import Message
  
  class MessageSerializer(serializers.ModelSerializer):
      org_id = serializers.CharField()
      channel_name = serializers.CharField()
  
      class Meta:
          model = Message
          fields = ["org_id", "channel_name", "content", "received_at"]
          read_only_fields = ["received_at"]
  

  再修改视图：

  from django.utils import timezone
  
  class MessageReceiver(generics.CreateAPIView):
      serializer_class = MessageSerializer
  
      def post(self, request, org_id, channel_name):
          # 将路径参数合并到请求数据中
          request.data["org_id"] = org_id
          request.data["channel_name"] = channel_name
          
          serializer = self.get_serializer(data=request.data)
          # 自动校验数据，不通过则直接返回400响应
          serializer.is_valid(raise_exception=True)
          # 保存处理后的数据
          serializer.save(received_at=timezone.now())
          
          return Response(
              data={"processed_data": serializer.data},
              status=status.HTTP_201_CREATED
          )
  

• 获取原始请求体（针对未解析的原始数据需求）
  如果你需要访问DRF未解析的原始字节数据（比如外部发送非JSON格式数据、需要保留原始结构），可以直接调用request.body自行解析：

  import json
  
  class MessageReceiver(generics.CreateAPIView):
      def post(self, request, org_id, channel_name):
          try:
              # 解码原始字节为字符串，再解析为字典
              raw_data_str = request.body.decode("utf-8")
              data = json.loads(raw_data_str)
          except json.JSONDecodeError:
              return Response(data={'message': 'Invalid data format'}, status=status.HTTP_400_BAD_REQUEST)
          
          # 对原始解析后的数据做处理
          data["forward_info"] = {"org_id": org_id, "channel": channel_name}
          
          return Response(
              data={"raw_data": raw_data_str, "processed_data": data},
              status=status.HTTP_200_OK
          )
  

• 通过中间件提前统一处理数据
  如果需要在视图处理前就统一拦截并处理所有转发请求的数据，可以自定义中间件：

  import json
  from django.utils.deprecation import MiddlewareMixin
  from django.utils import timezone
  
  class DataProcessingMiddleware(MiddlewareMixin):
      def process_request(self, request):
          # 仅针对目标POST请求做处理
          if request.method == "POST" and "/api/message/receive/" in request.path:
              try:
                  raw_data = request.body.decode("utf-8")
                  parsed_data = json.loads(raw_data)
                  # 给request添加自定义属性，存储预处理后的数据
                  request.preprocessed_data = {
                      "original_data": parsed_data,
                      "processed_time": timezone.now().isoformat()
                  }
              except json.JSONDecodeError:
                  request.preprocessed_data = None
  

  在settings.py的MIDDLEWARE列表中添加该中间件后，即可在视图中直接使用预处理后的数据：

  class MessageReceiver(generics.CreateAPIView):
      def post(self, request, org_id, channel_name):
          if not request.preprocessed_data:
              return Response(data={'message': 'Invalid data'}, status=status.HTTP_400_BAD_REQUEST)
          
          # 整合路径参数到预处理数据中
          request.preprocessed_data["org_id"] = org_id
          request.preprocessed_data["channel_name"] = channel_name
          
          return Response(data=request.preprocessed_data, status=status.HTTP_200_OK)
  

内容的提问来源于stack exchange，提问作者kmg92