|
@@ -69,7 +69,7 @@ async def root():
|
|
|
"version": "1.0.0",
|
|
|
"status": "running",
|
|
|
"endpoints": {
|
|
|
- "trigger": "/trigger",
|
|
|
+ "parse": "/parse",
|
|
|
"health": "/health",
|
|
|
"docs": "/docs"
|
|
|
}
|
|
@@ -80,15 +80,15 @@ async def health_check():
|
|
|
"""健康检查接口"""
|
|
|
return {"status": "healthy", "timestamp": time.time()}
|
|
|
|
|
|
-@app.post("/trigger", response_model=TriggerResponse)
|
|
|
-async def trigger_processing(request: TriggerRequest, background_tasks: BackgroundTasks):
|
|
|
+@app.post("/parse", response_model=TriggerResponse)
|
|
|
+async def parse_processing(request: TriggerRequest, background_tasks: BackgroundTasks):
|
|
|
"""
|
|
|
- 触发内容处理
|
|
|
+ 解析内容处理
|
|
|
|
|
|
- **requestId**: 请求ID,用于标识处理任务
|
|
|
"""
|
|
|
try:
|
|
|
- logger.info(f"收到触发请求: requestId={request.requestId}")
|
|
|
+ logger.info(f"收到解析请求: requestId={request.requestId}")
|
|
|
|
|
|
# 获取待处理数据
|
|
|
items = QueryDataTool.fetch_crawl_data_list(request.requestId)
|
|
@@ -154,15 +154,15 @@ async def trigger_processing(request: TriggerRequest, background_tasks: Backgrou
|
|
|
logger.error(f"处理请求失败: {e}")
|
|
|
raise HTTPException(status_code=500, detail=f"处理失败: {str(e)}")
|
|
|
|
|
|
-@app.post("/trigger/async")
|
|
|
-async def trigger_processing_async(request: TriggerRequest, background_tasks: BackgroundTasks):
|
|
|
+@app.post("/parse/async")
|
|
|
+async def parse_processing_async(request: TriggerRequest, background_tasks: BackgroundTasks):
|
|
|
"""
|
|
|
- 异步触发内容处理(后台任务)
|
|
|
+ 异步解析内容处理(后台任务)
|
|
|
|
|
|
- **requestId**: 请求ID,用于标识处理任务
|
|
|
"""
|
|
|
try:
|
|
|
- logger.info(f"收到异步触发请求: requestId={request.requestId}")
|
|
|
+ logger.info(f"收到异步解析请求: requestId={request.requestId}")
|
|
|
|
|
|
# 添加后台任务
|
|
|
background_tasks.add_task(process_request_background, request.requestId)
|