Hi, I've been trying to run an update processor script for nifi using Groovy. I am reusing the below script from Github. import groovy.json.JsonBuilder
import groovyx.net.http.RESTClient
import static groovy.json.JsonOutput.prettyPrint
import static groovy.json.JsonOutput.toJson
import static groovyx.net.http.ContentType.JSON
//@Grab(group='org.codehaus.groovy.modules.http-builder',
// module='http-builder',
//version='0.7.1')
def processorName = 'Save File'
def host = 'localhost'
//def host = 'agrande-nifi-1'
def port = 9090
def nifi = new RESTClient("http://$host:$port/nifi-api/")
println 'Looking up a component to update...'
def resp = nifi.get(
path: 'controller/search-results',
query: [q: processorName]
)
assert resp.status == 200
assert resp.data.searchResultsDTO.processorResults.size() == 1
// println prettyPrint(toJson(resp.data))
def processorId = resp.data.searchResultsDTO.processorResults[0].id
def processGroup= resp.data.searchResultsDTO.processorResults[0].groupId
println "Found the component, id/group: $processorId/$processGroup"
println 'Preparing to update the flow state...'
resp = nifi.get(path: 'controller/revision')
assert resp.status == 200
// stop the processor before we can update it
println 'Stopping the processor to apply changes...'
def builder = new JsonBuilder()
builder {
revision {
clientId 'my awesome script'
version resp.data.revision.version
}
processor {
id "$processorId"
state "STOPPED"
}
}
resp = nifi.put(
path: "controller/process-groups/$processGroup/processors/$processorId",
body: builder.toPrettyString(),
requestContentType: JSON
)
assert resp.status == 200
// create a partial JSON update doc
// TIP: don't name variables same as json keys, simplifies your life
builder {
revision {
clientId 'my awesome script'
version resp.data.revision.version
}
processor {
id "$processorId"
config {
properties {
'Directory' '/tmp/staging'
'Create Missing Directories' 'true'
}
}
}
}
println "Updating processor...\n${builder.toPrettyString()}"
resp = nifi.put(
path: "controller/process-groups/$processGroup/processors/$processorId",
body: builder.toPrettyString(),
requestContentType: JSON
)
assert resp.status == 200
println "Updated ok."
// println "Got this response back:"
// print prettyPrint(toJson(resp.data))
println 'Bringing the updated processor back online...'
builder {
revision {
clientId 'my awesome script'
version resp.data.revision.version
}
processor {
id "$processorId"
state "RUNNING"
}
}
resp = nifi.put(
path: "controller/process-groups/$processGroup/processors/$processorId",
body: builder.toPrettyString(),
requestContentType: JSON
)
assert resp.status == 200
println 'Ok' Except i have commented out the Maven dependency part using @Grab part. I have directly download the http-builder-0.6.jar and put it into groovy designated Library directory to have the classes available. I have also downloaded and put the json-lib.jar in the library. I'm still getting below exception at run-time groovyx.net.http.ContentType.JSON Caught:
java.lang.NoClassDefFoundError: net/sf/json/JSONObject java.lang.NoClassDefFoundError:
net/sf/json/JSONObject at
groovyx.net.http.HTTPBuilder.<init>(HTTPBuilder.java:175) at
groovyx.net.http.HTTPBuilder.<init>(HTTPBuilder.java:194) at
groovyx.net.http.RESTClient.<init>(RESTClient.java:79) at
Groovy_Sample.run(Groovy_Sample.groovy:13) Caused by:
java.lang.ClassNotFoundException: net.sf.json.JSONObject I cant trace out whats possibly going wrong, even with the jars in library, I have read that setting the right version in Maven dependency might help, but I dont use it, is there no way to do it without Maven? OR am i missing something with the Jar and libraries.
... View more
