admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

retry机制抛出异常

Browse Source
This commit is contained in:
lxu75
2025-05-21 15:57:39 +08:00
parent a231fecaa5
commit af152be1a6
2 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java
View File

@@ -18,6 +18,7 @@ public interface DiFyFeign {
, produces = MediaType.APPLICATION_JSON_VALUE) , produces = MediaType.APPLICATION_JSON_VALUE)
JSONObject runWorkflows(@RequestHeader(value = "Authorization") String authorization, @RequestBody Map<String, Object> map); JSONObject runWorkflows(@RequestHeader(value = "Authorization") String authorization, @RequestBody Map<String, Object> map);
@Retryable(maxAttempts = 1, backoff = @Backoff(delay = 1000))
@PostMapping(value = "v1/workflows/run" @PostMapping(value = "v1/workflows/run"
, consumes = MediaType.APPLICATION_JSON_VALUE , consumes = MediaType.APPLICATION_JSON_VALUE
, produces = MediaType.APPLICATION_JSON_VALUE) , produces = MediaType.APPLICATION_JSON_VALUE)

7
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java
View File

@@ -3,19 +3,24 @@ package com.volvo.ai.analytic.center.service.impl;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.volvo.ai.analytic.center.dto.req.DiFyReq; import com.volvo.ai.analytic.center.dto.req.DiFyReq;
import com.volvo.ai.analytic.center.service.DiFyService; import com.volvo.ai.analytic.center.service.DiFyService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
/** /**
* dify调用retry * dify调用retry
*/ */
@Slf4j
@Service @Service
public class DiFyRetryImpl { public class DiFyRetryImpl {
@Autowired @Autowired
private DiFyService diFyService; private DiFyService diFyService;
@Retryable(maxAttempts = 1, backoff = @Backoff(delay = 1000))
public JSONObject getDiFyRetry(DiFyReq diFyReq) { public JSONObject getDiFyRetry(DiFyReq diFyReq) {
log.info("diFyService class: {}", diFyService.getClass());
return (JSONObject) diFyService.getDiFyObjectRetry(diFyReq); return (JSONObject) diFyService.getDiFyObjectRetry(diFyReq);
} }