6 changed files with 7 additions and 35 deletions
@ -1,27 +0,0 @@ |
|||||
from typing import Union |
|
||||
|
|
||||
from fastapi import BackgroundTasks, Depends, FastAPI |
|
||||
from typing_extensions import Annotated |
|
||||
|
|
||||
app = FastAPI() |
|
||||
|
|
||||
|
|
||||
def write_log(message: str): |
|
||||
with open("log.txt", mode="a") as log: |
|
||||
log.write(message) |
|
||||
|
|
||||
|
|
||||
def get_query(background_tasks: BackgroundTasks, q: Union[str, None] = None): |
|
||||
if q: |
|
||||
message = f"found query: {q}\n" |
|
||||
background_tasks.add_task(write_log, message) |
|
||||
return q |
|
||||
|
|
||||
|
|
||||
@app.post("/send-notification/{email}") |
|
||||
async def send_notification( |
|
||||
email: str, background_tasks: BackgroundTasks, q: Annotated[str, Depends(get_query)] |
|
||||
): |
|
||||
message = f"message to {email}\n" |
|
||||
background_tasks.add_task(write_log, message) |
|
||||
return {"message": "Message sent"} |
|
||||
Loading…
Reference in new issue