Styjun

Is there an API to get a ProcessGroup by id from a custom processor or an ExecuteScript processor?

I know that it is possible by using the REST-API, but for security reasons, I don't have the chance to use the credentials to invoke the API from a service.

Regards

If you use a InvokeScriptedProcessor using groovy you can use

context.procNode.processGroup

from the ProcessContext
If you want to extract all the parents in a breadcrum way, you can use this:

import groovy.json.*;
import org.apache.nifi.groups.*;

class GroovyProcessor implements Processor 

 def REL_SUCCESS = new Relationship.Builder()
 .name("success")
 .description('FlowFiles that were successfully processed are routed here').build()

 def ComponentLog log

 @Override
 void initialize(ProcessorInitializationContext context) 
 log = context.logger 
 

 @Override
 Set<Relationship> getRelationships() 
 return [REL_SUCCESS] as Set 
 

 void executeScript(ProcessSession session, ProcessContext context) 
 def flowFile = session.get()
 if (!flowFile) return 

 def breadcrumb = getBreadCrumb(context.procNode.processGroup) + '->' + context.getName()
 flowFile = session.putAttribute(flowFile, 'breadcrumb', breadcrumb)

 // transfer
 session.transfer(flowFile, this.REL_SUCCESS) 
 

 // Recursive funtion that gets the breadcrumb
 String getBreadCrumb(processGroup) 
 def breadCrumb = ''
 if(processGroup.parent != null)
 breadCrumb = getBreadCrumb(processGroup.parent) + '->'

 return breadCrumb + processGroup.name
 

 @Override
 void onTrigger(ProcessContext context, ProcessSessionFactory sessionFactory) throws ProcessException 
 def session = sessionFactory.createSession() 
 try 
 executeScript( session, context)
 session.commit()
 
 catch (final Throwable t) 
 log.error(' failed to process due to ; rolling back session', [this, t] as Object[])
 session.rollback(true)
 throw t
 
 

 @Override
 PropertyDescriptor getPropertyDescriptor(String name) null 

 @Override
 List<PropertyDescriptor> getPropertyDescriptors() 
 return [] as List
 


 @Override
 void onPropertyModified(PropertyDescriptor descriptor, String oldValue, String newValue) 

 @Override
 Collection<ValidationResult> validate(ValidationContext context) null 

 @Override
 String getIdentifier() null 
 

processor = new GroovyProcessor()