From c0ef153a17cc6575e29d483c0a776855b2711a2a Mon Sep 17 00:00:00 2001 From: liuy <37787198+LiuyCodes@users.noreply.github.com> Date: Mon, 19 May 2025 15:47:32 +0800 Subject: [PATCH] =?UTF-8?q?feat(nifi):=20=E6=B7=BB=E5=8A=A0=E5=88=9B?= =?UTF-8?q?=E5=BB=BA=E8=BF=9E=E6=8E=A5=E5=85=B3=E7=B3=BB=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 新增 CreateConnection18、Component18、Revision18 等相关模型类- 在 NifiApiService 中添加 createProcessorConnections 方法用于建立连接关系 - 新增对应的请求和响应模型类，以支持创建连接关系的 API 调用 --- .../joincreateconnection/Component18.java | 20 ++++++++++++++++ .../CreateConnection18.java | 23 +++++++++++++++++++ .../joincreateconnection/Revision18.java | 16 +++++++++++++ .../joincreateconnections/Component18.java | 20 ++++++++++++++++ .../CreateConnections18.java | 17 ++++++++++++++ .../joincreateconnections/Revision18.java | 16 +++++++++++++ .../SourceOrDestination18.java | 18 +++++++++++++++ .../frame/nifi/service/NifiApiService.java | 9 ++++++++ 8 files changed, 139 insertions(+) create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Component18.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/CreateConnection18.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Revision18.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Component18.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/CreateConnections18.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Revision18.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/SourceOrDestination18.java diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Component18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Component18.java new file mode 100644 index 00000000..325eee96 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Component18.java @@ -0,0 +1,20 @@ +package com.hzya.frame.nifi.model.joincreateconnection; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.joincreateconnection + * @Project：fw-nifi + * @name：Component18 + * @Date：2025/5/19 15:39 + * @Filename：Component18 + */ +@Data +public class Component18 { + private String id; + private String parentGroupId; + private String backPressureObjectThreshold; + private String backPressureDataSizeThreshold; + private String flowFileExpiration; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/CreateConnection18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/CreateConnection18.java new file mode 100644 index 00000000..32c1ecf0 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/CreateConnection18.java @@ -0,0 +1,23 @@ +package com.hzya.frame.nifi.model.joincreateconnection; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.joincreateconnection + * @Project：fw-nifi + * @name：CreateConnection + * @Date：2025/5/19 15:35 + * @Filename：CreateConnection + */ +@Data +public class CreateConnection18 { + private String id; + private String sourceId; + private String sourceGroupId; + private String sourceType; + private String destinationId; + private String destinationGroupId; + private String destinationType; + private Revision18 revision; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Revision18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Revision18.java new file mode 100644 index 00000000..1612e300 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnection/Revision18.java @@ -0,0 +1,16 @@ +package com.hzya.frame.nifi.model.joincreateconnection; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.joincreateconnection + * @Project：fw-nifi + * @name：Revision18 + * @Date：2025/5/19 15:36 + * @Filename：Revision18 + */ +@Data +public class Revision18 { + private String version; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Component18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Component18.java new file mode 100644 index 00000000..06492b0e --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Component18.java @@ -0,0 +1,20 @@ +package com.hzya.frame.nifi.model.joincreateconnections; + +import lombok.Data; + +import java.util.List; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.joincreateconnections + * @Project：fw-nifi + * @name：Component17 + * @Date：2025/5/19 11:58 + * @Filename：Component17 + */ +@Data +public class Component18 { + private SourceOrDestination18 source; + private SourceOrDestination18 destination; + private List selectedRelationships; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/CreateConnections18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/CreateConnections18.java new file mode 100644 index 00000000..4be35d8e --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/CreateConnections18.java @@ -0,0 +1,17 @@ +package com.hzya.frame.nifi.model.joincreateconnections; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.joincreateconnections + * @Project：fw-nifi + * @name：CreateConnections + * @Date：2025/5/19 11:56 + * @Filename：CreateConnections + */ +@Data +public class CreateConnections18 { + private Revision18 revision; + private Component18 component; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Revision18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Revision18.java new file mode 100644 index 00000000..dc387f19 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/Revision18.java @@ -0,0 +1,16 @@ +package com.hzya.frame.nifi.model.joincreateconnections; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.joincreateconnections + * @Project：fw-nifi + * @name：Revision17 + * @Date：2025/5/19 11:56 + * @Filename：Revision17 + */ +@Data +public class Revision18 { + private String version; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/SourceOrDestination18.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/SourceOrDestination18.java new file mode 100644 index 00000000..17252bb0 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joincreateconnections/SourceOrDestination18.java @@ -0,0 +1,18 @@ +package com.hzya.frame.nifi.model.joincreateconnections; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.joincreateconnections + * @Project：fw-nifi + * @name：SourceOrDestination + * @Date：2025/5/19 13:39 + * @Filename：SourceOrDestination + */ +@Data +public class SourceOrDestination18 { + private String id; + private String groupId; + private String type; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java index 7d321a3f..cc0fb693 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java @@ -4,6 +4,8 @@ import cn.hutool.core.util.StrUtil; import com.hzya.frame.nifi.client.NifiClient; import com.hzya.frame.nifi.model.joinbindparametercontexts.BindParameterContextsJoin11; import com.hzya.frame.nifi.model.joincontrollerenabled.EnOrDiControllerServices12; +import com.hzya.frame.nifi.model.joincreateconnection.CreateConnection18; +import com.hzya.frame.nifi.model.joincreateconnections.CreateConnections18; import com.hzya.frame.nifi.model.joincreatetemp.CreateTemplateJoin; import com.hzya.frame.nifi.model.joingetcontroller.ControllerService12; import com.hzya.frame.nifi.model.joinparametercontexts.ParameterContextsJoin; @@ -242,4 +244,11 @@ public class NifiApiService { public ProcessorsInfo16 deleteProcessor(String processId, Map queryParams) throws Exception { return client.delete(StrUtil.format("/processors/{}", processId), queryParams, ProcessorsInfo16.class); } + + /** + * 建立连接关系 + */ + public CreateConnection18 createProcessorConnections(String processGroupsId, CreateConnections18 createConnections17) throws Exception { + return client.post(StrUtil.format("/process-groups/{}/connections", processGroupsId), createConnections17, CreateConnection18.class); + } } \ No newline at end of file