This commit is contained in:
xyj 2023-12-18 11:22:31 +08:00
parent fa89f4b648
commit 55479f49b7
1 changed files with 4 additions and 8 deletions

12
tool.py
View File

@ -2,21 +2,17 @@ import json
import os import os
import subprocess import subprocess
import pydantic
import requests import requests
from pydantic import BaseModel
from config import mp4_path, post_record_list_url, post_record_url, info_topic from config import mp4_path, post_record_list_url, post_record_url, info_topic
class BaseResponse(BaseModel):
code: int = pydantic.Field(200, description="MQTT Return Status Code")
msg: str = pydantic.Field("success", description="MQTT Status Message")
# 统一返回 # 统一返回
def publish_payload(code, msg): def publish_payload(code, msg):
return json.dumps(BaseResponse(code=code, msg=msg), ensure_ascii=False) return json.dumps({
"code": 200,
"msg": msg
}, ensure_ascii=False)
def exception_handler(func): def exception_handler(func):