FilesExpand file tree

 master

/

fastapi_background_task_di.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

29 lines (19 loc) · 806 Bytes

 master

/

fastapi_background_task_di.py

Copy path

Top

File metadata and controls

• Code
• Blame

29 lines (19 loc) · 806 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

from typing import Optional

from fastapi import FastAPI, BackgroundTasks, status, Query, Depends

app = FastAPI()

def write_log(message: str):

with open("/tmp/log.txt", "a") as log:

log.write(message)

def get_query(background_tasks: BackgroundTasks, q: Optional[str] = None):

if q:

message = f"found query: {q}\n"

background_tasks.add_task(write_log, message)

return q

@app.post("/send-notification/{email}", status_code=status.HTTP_202_ACCEPTED)

async def send_notification(

email: str, background_tasks: BackgroundTasks, q: str = Depends(get_query)

):

message = f"message to {email}\n"

background_tasks.add_task(write_log, message)

return {"message": "Message sent"}

# PYTHONPATH=module_fastapi uvicorn fastapi_background_task_di:app --reload