feat(nifi): 添加控制器服务启用、禁用和删除功能

- 新增 EnOrDiControllerServices12 和 Revision13 类用于启用或禁用控制器服务
- 在 NifiApiService 中添加 enabledOrDisabledControllerServices 方法实现控制器服务启用或禁用
- 在 NifiApiService 中添加 deleteControllerServices 方法实现控制器服务删除
This commit is contained in:
liuy 2025-05-16 17:49:06 +08:00
parent a37f6ab340
commit 6afd2264e3
4 changed files with 48 additions and 0 deletions

View File

@ -0,0 +1,17 @@
package com.hzya.frame.nifi.model.joincontrollerenabled;
import lombok.Data;
/**
* @Authorliuyang
* @Packagecom.hzya.frame.nifi.model.joincontrollerenabled
* @Projectfw-nifi
* @nameEnOrDiControllerServices
* @Date2025/5/16 16:54
* @FilenameEnOrDiControllerServices
*/
@Data
public class EnOrDiControllerServices12 {
private String state;
private Revision13 revision;
}

View File

@ -0,0 +1,16 @@
package com.hzya.frame.nifi.model.joincontrollerenabled;
import lombok.Data;
/**
* @Authorliuyang
* @Packagecom.hzya.frame.nifi.model.joincontrollerenabled
* @Projectfw-nifi
* @nameControllerServiceStatus
* @Date2025/5/16 16:54
* @FilenameControllerServiceStatus
*/
@Data
public class Revision13 {
private String version;
}

View File

@ -3,6 +3,7 @@ package com.hzya.frame.nifi.service;
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.joingetcontroller.ControllerService12;
import com.hzya.frame.nifi.model.joinparametercontexts.ParameterContextsJoin;
import com.hzya.frame.nifi.model.joinprocessgroups.ProcessGroupsJoin;
@ -145,4 +146,18 @@ public class NifiApiService {
public ControllerService12 createControllerServices(String id, ControllerService12 controllerService11) throws Exception {
return client.post(StrUtil.format("/process-groups/{}/controller-services", id), controllerService11, ControllerService12.class);
}
/**
* 启用或禁用控制器服务
*/
public ControllerService12 enabledOrDisabledControllerServices(String id, EnOrDiControllerServices12 enOrDiControllerServices) throws Exception {
return client.put(StrUtil.format("/controller-services/{}/run-status", id), enOrDiControllerServices, ControllerService12.class);
}
/**
* 删除控制器服务
*/
public ControllerService12 deleteControllerServices(String id, Map<String, String> queryParam) throws Exception {
return client.delete(StrUtil.format("/controller-services/{}", id), queryParam, ControllerService12.class);
}
}