update

main.py

@@ -113,8 +113,12 @@ async def register(request: Request):
 @app.post("/api/xumu/data/collect")
 async def process_data(request: Request):
     # TODO mqtt检测
-    r = await request.body()
-    print(r)
+    data = await request.body()
+    data = data.decode("utf-8")
+    data = json.loads(data)
+    print(data)
+
+
     return 200
     # try:
     #     data = await request.body()