async
This commit is contained in:
12
main.py
12
main.py
@@ -480,16 +480,16 @@ async def process_parser_all_ist(url: Parserall, background_tasks: BackgroundTas
|
|||||||
|
|
||||||
# GET метод для получения
|
# GET метод для получения
|
||||||
@app.get("/get_tasks_offset", summary="Метод получения задач парсинга")
|
@app.get("/get_tasks_offset", summary="Метод получения задач парсинга")
|
||||||
def get_tasks_offset(limit: int = Query(10, gt=0), offset: int = Query(0, ge=0)):
|
async def get_tasks_offset(limit: int = Query(10, gt=0), offset: int = Query(0, ge=0)):
|
||||||
return wp.get_tasks_offset(limit, offset)
|
return wp.get_tasks_offset(limit, offset)
|
||||||
|
|
||||||
# GET метод для получения настроек
|
# GET метод для получения настроек
|
||||||
@app.get("/settings", summary="Метод получения настроек парсера")
|
@app.get("/settings", summary="Метод получения настроек парсера")
|
||||||
def get_settings():
|
async def get_settings():
|
||||||
return wp.get_all_promt()
|
return wp.get_all_promt()
|
||||||
|
|
||||||
@app.get("/categories_promt", summary="Метод получения categories_promt")
|
@app.get("/categories_promt", summary="Метод получения categories_promt")
|
||||||
def get_categories_promt():
|
async def get_categories_promt():
|
||||||
return wp.get_all_categories_promt()
|
return wp.get_all_categories_promt()
|
||||||
|
|
||||||
class Source(BaseModel):
|
class Source(BaseModel):
|
||||||
@@ -498,11 +498,11 @@ class Source(BaseModel):
|
|||||||
|
|
||||||
# POST метод для установки настроек
|
# POST метод для установки настроек
|
||||||
@app.post("/settings", summary="Метод сохранения настроек парсера")
|
@app.post("/settings", summary="Метод сохранения настроек парсера")
|
||||||
def set_settings(settings: Source):
|
async def set_settings(settings: Source):
|
||||||
return wp.update_promt(settings.name, settings.promt)
|
return wp.update_promt(settings.name, settings.promt)
|
||||||
|
|
||||||
@app.delete("/delete_task/{task_id}", summary="Метод удаления задачи")
|
@app.delete("/delete_task/{task_id}", summary="Метод удаления задачи")
|
||||||
def delete_task(task_id: int):
|
async def delete_task(task_id: int):
|
||||||
return print(wp.delete_task(task_id))
|
return print(wp.delete_task(task_id))
|
||||||
|
|
||||||
@app.get("/file_download", summary="Метод для скачивания файла")
|
@app.get("/file_download", summary="Метод для скачивания файла")
|
||||||
@@ -607,7 +607,7 @@ async def download_all(dates: DownloadRange, background_tasks: BackgroundTasks):
|
|||||||
return response
|
return response
|
||||||
|
|
||||||
@app.get("/logs", summary="Показать логи")
|
@app.get("/logs", summary="Показать логи")
|
||||||
def get_logs():
|
async def get_logs():
|
||||||
with open("app.log", "r") as file:
|
with open("app.log", "r") as file:
|
||||||
lines = file.readlines()[-10:] # последние 10 строк
|
lines = file.readlines()[-10:] # последние 10 строк
|
||||||
return {"logs": lines}
|
return {"logs": lines}
|
||||||
|
|||||||
Reference in New Issue
Block a user