1234567891011121314151617181920212223242526272829303132333435363738394041 |
- from fastapi import FastAPI, Request
- import uvicorn
- from MsgSend import send_message
- import json
- app = FastAPI()
- @app.post("/record")
- async def record_endpoint(request: Request):
- """
- 接收POST请求并返回ok
- """
- try:
- data = await request.json()
- content = json.loads(data.get("content", ""))
- # 如果需要发送消息,取消下面一行的注释
- send_message(content.get("text"))
- print(f"Received data: {data.get('content', '')}")
- return {"message": "ok"}
- except Exception as e:
- print(f"Error processing request: {e}")
- return {"message": "error", "detail": str(e)}
- @app.post("/text")
- async def message_endpoint(request: Request):
- """
- 接收POST请求并返回ok
- """
- try:
- data = await request.json()
- content = data.get("content", "")
- # 如果需要发送消息,取消下面一行的注释
- send_message(content)
- print(f"Received data: {data.get('content', '')}")
- return {"message": "ok"}
- except Exception as e:
- print(f"Error processing request: {e}")
- if __name__ == "__main__":
- uvicorn.run(app, host="0.0.0.0", port=9017)
|