# cd nifi-1.23.2
# mvn -Dmaven.test.skip=true install
# wget https://repo1.maven.org/maven2/io/swagger/swagger-codegen-cli/2.4.32/swagger-codegen-cli-2.4.32.jar
# java -jar swagger-codegen-cli-2.4.32.jar generate -i ../nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/target/swagger-ui/swagger.json -l java
- Apache Maven
- JDK 1.8 이상
mvn install
API 호출을 위해서 Basic Auth로 Access Token을 얻습니다.
import io.datadynamics.nifi.api.ApiClient;
import io.datadynamics.nifi.api.api.AccessApi;
import com.squareup.okhttp.Credentials;
public class AccessApiExample {
public static void main(String[] args) {
String username = "admin";
String password = "admin";
AccessApi accessApi = new AccessApi();
ApiClient client = new ApiClient(true);
client.setDebugging(true);
client.addDefaultHeader("Authorization", Credentials.basic(username, password));
client.setBasePath("https://localhost:8443/nifi-api");
accessApi.setApiClient(client);
String accessToken = accessApi.createAccessToken(username, password);
}
}
Access Token을 이용하여 API를 호출합니다.
import io.datadynamics.nifi.api.ApiClient;
import io.datadynamics.nifi.api.model.*;
public class ResourcesApiExample {
public static void main(String[] args) {
ResourcesApi api = new ResourcesApi();
ApiClient client = new ApiClient(true);
client.setDebugging(true);
client.setBasePath("https://localhost:8443/nifi-api");
client.addDefaultHeader("Authorization", String.format("Bearer %s", accessToken));
api.setApiClient(client);
ResourcesEntity response = api.getResources();
}
}