使用Dapr调用Python服务时request.data为空且报400错误求助

已观测到的问题 #

• 调用服务时持续返回错误：code 400, message Bad request syntax ('4')
• 接收端的request.data始终为空
• 临时通过网关路由请求可正常工作，但非长期可行方案

环境详情 #

• Dapr Python SDK版本：1.12.1
• Dapr运行时版本：1.12.5
• 部署平台：Azure容器
• 调用方式：Dapr HTTP API服务间调用

已尝试的解决措施 #

• 验证请求头及application/json内容类型
• 尝试字符串化JSON、Python字典等不同负载格式
• 参照Dapr官方文档及示例代码调整实现
• 修改代码逻辑、不使用Dapr库直接传参、更换接收数据的方法

核心问题 #

1. 接收端request.data始终为空的原因是什么？
2. 在Azure容器环境下使用Dapr进行服务间调用，是否有遗漏的特定配置或步骤？

代码示例 #

调用端代码 #

from dapr.clients import DaprClient
import json

with DaprClient() as d:
    if method.lower() == "get":
        response = d.invoke_method(
            appid="filemanagement",
            path="api/file_management/test_update",
            data='{"message":"Hello World"}',
            metadata=None,
            content_type="application/json",
        )
    else:
        response = d.invoke_method(
            appid="filemanagement",
            path="api/file_management/test_update",
            data=json.dumps(payload),
            metadata=None,
            http_verb="post"
        )

接收端代码 #

from rest_framework.views import APIView
from rest_framework.parsers import JSONParser
from rest_framework.response import Response

class Test1(APIView):
    parser_classes = [JSONParser]

    def post(self, request, *args, **kwargs):
        print("Received data:", request.data)
        return Response({"status": "success"})

问题分析与解决方案 #

针对request.data为空的问题 #

1. 绕开DRF解析器直接读取原始请求体
   Dapr转发请求时的封装格式可能导致DRF的JSONParser无法正确解析，可直接读取原始请求体处理：

import json
from rest_framework.views import APIView
from rest_framework.response import Response

class Test1(APIView):
    def post(self, request, *args, **kwargs):
        raw_data = request.body.decode('utf-8')
        data = json.loads(raw_data) if raw_data else {}
        print("Received data:", data)
        return Response({"status": "success"})

2. 补全POST请求的content_type参数
   你的POST分支调用未指定content_type="application/json"，Dapr默认不会设置正确的请求头，导致接收端无法识别JSON格式，修改代码：

response = d.invoke_method(
    appid="filemanagement",
    path="api/file_management/test_update",
    data=json.dumps(payload),
    metadata=None,
    http_verb="post",
    content_type="application/json"  # 新增此行
)

3. 排查Dapr转发的请求完整性
   在接收端打印完整请求信息，确认路径、头信息是否被Dapr sidecar修改：

def post(self, request, *args, **kwargs):
    print("Request headers:", request.headers)
    print("Request path:", request.path)
    print("Raw request body:", request.body.decode('utf-8'))
    return Response({"status": "success"})

针对400错误的问题 #

1. GET请求避免传递请求体
   GET请求规范上不携带请求体，Dapr处理GET请求的data参数时易出现解析异常，改用查询参数传递数据：

if method.lower() == "get":
    response = d.invoke_method(
        appid="filemanagement",
        path="api/file_management/test_update?message=Hello%20World",
        http_verb="get"
    )

接收端通过request.query_params获取参数：

def get(self, request, *args, **kwargs):
    message = request.query_params.get('message')
    print("Received query param:", message)
    return Response({"status": "success"})

2. Azure容器环境Dapr配置检查

• 确认容器中Dapr sidecar已正确注入，服务app-id与调用端appid完全一致
• 检查网络策略，确保Dapr sidecar之间的通信未被防火墙或安全组拦截
• 查看Dapr运行时日志，获取请求转发失败的详细错误信息

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