init

fn-opensearch/src/main/java/net/yaoyi/pipeline/opensearch/OpenSearchHandler.java

@@ -23,6 +23,7 @@ public class OpenSearchHandler implements PojoRequestHandler<TaskImageMsg, List<
 
     @Override
     public List<ImageMultiMsg> handleRequest(TaskImageMsg taskImageMsg, Context context) {
+        log.info("收到请求消息：{}", JacksonUtils.toJson(taskImageMsg));
         Long taskId = taskImageMsg.getTaskId();
         String namespace = taskImageMsg.getNamespace();
 
@@ -65,7 +66,7 @@ public class OpenSearchHandler implements PojoRequestHandler<TaskImageMsg, List<
     }
 
     private void saveByTask(TaskImageMsg taskImageMsg) {
-        String[] images = taskImageMsg.getImage();
+        String[] images = taskImageMsg.getImages();
 
         List<TaskImageIndex> taskImageList = fetchByTaskId(taskImageMsg.getNamespace(), taskImageMsg.getTaskId());
         Map<String, TaskImageIndex> map = taskImageList.stream().collect(Collectors.toMap(TaskImageIndex::getImage, Function.identity()));
@@ -128,12 +129,13 @@ public class OpenSearchHandler implements PojoRequestHandler<TaskImageMsg, List<
         try {
             FetchRequest request = new FetchRequest();
             request.setTableName(TABLE_NAME);
-            request.setFilter(String.format("taskId:%d AND namespace:\"%s\"", taskId, namespace));
+            request.setFilter(String.format("taskId=%d AND namespace=\"%s\"", taskId, namespace));
             request.setIncludeVector(true);
 
             SearchResponse response = OpenSearchUtils.getClient().fetch(request);
             JsonNode bodyNode = JacksonUtils.toJsonNode(response.getBody());
             if (bodyNode.has("errorCode")) {
+                log.error("查询失败，body:{}", response.getBody());
                 throw new RuntimeException(String.format("查询失败,namespace:[%s], taskId:%d ", namespace, taskId));
             }
 

yyc-pipeline-model/src/main/java/net/yaoyi/pipeline/model/mq/TaskImageMsg.java

@@ -12,5 +12,5 @@ public class TaskImageMsg extends AlgoBaseInfo {
     private Long userId;
     private Integer status;
     private String taskTime;
-    private String[] image;
+    private String[] images;
 }