feat: 后台任务
This commit is contained in:
8
app.py
8
app.py
@@ -100,20 +100,20 @@ def read_items(
|
||||
# 微信对话-用户输入
|
||||
@app.get("/input",)
|
||||
async def getphonenum(
|
||||
background_tasks: BackgroundTasks,
|
||||
inputArguments: Union[str, None] = None,
|
||||
appid: Union[str, None] = Header(default=None),
|
||||
bid: Union[str, None] = Header(default=None),
|
||||
requestid: Union[str, None] = Header(default=None),
|
||||
uid: Union[str, None] = Header(default=None),
|
||||
# bt: BackgroundTasks
|
||||
uid: Union[str, None] = Header(default=None)
|
||||
):
|
||||
|
||||
# 存储uid和手机号
|
||||
# return {"appid": appid,"bid": bid,"requestid": requestid,"uid": uid,'inputArguments':inputArguments}
|
||||
|
||||
# 后台任务
|
||||
# bt.add_task(resData,inputArguments,uid)
|
||||
await resData(inputArguments,uid)
|
||||
background_tasks.add_task(resData,inputArguments,uid)
|
||||
# await resData(inputArguments,uid)
|
||||
content = {"err_code": 0,"data_list": [{"outputArguments":'test'}]}
|
||||
headers = {"Content-Type": "application/json"}
|
||||
return JSONResponse(content=content, headers=headers)
|
||||
|
||||
Reference in New Issue
Block a user