Oleg,
this is actually a great idea, I will follow it for certain (a good
compromise, too). I have an additional question on the onTrigger method for
my Post Http. Among the main NiFi components, my custom processor contains a
number of separate methods, in particular one that send a Post HTTP request
to an endpoint and return a Json response. The method takes a number of
parameter such as userId, password, etc and this is where I am rather
confused when it comes to the operations I should be perform in my on
Trigger. I have the following:
@Override
public void onTrigger(final ProcessContext context, final ProcessSession
session) throws ProcessException {
FlowFile flowFile = session.get();
if (flowFile == null) return;
final String userId = context.getProperty(USER_ID).getValue();
final String password = context.getProperty(PASSWORD).getValue();
final String http_post_url =
context.getProperty(HTTP_POST_URL).getValue();
final AtomicReference<String> httpPostRequestHolder = new
AtomicReference<>();
session.read(flowFile, new InputStreamCallback() {
@Override
public void process(InputStream inputStream) throws IOException
{
StringWriter strWriter = new StringWriter();
IOUtils.copy(inputStream, strWriter, "UTF-8");
httpPostRequestHolder.set(userId);
httpPostRequestHolder.set(password);
httpPostRequestHolder.set(http_post_url);
}
});
try {
postHttpRequest(userId, password, http_post_url);
session.transfer(flowFile, SUCCESS);
} catch (IllegalArgumentException ex) {
session.transfer(flowFile, FAILURE);
ex.printStackTrace();
}
Is that what I am supposed to do? Is that correct? I am trying to process
the inputstream and convert it into an AtomicReference object with the same
arguments as the one passed in the postHttpRequest method. Does it make
sense?
Thank you again for all your help, so much appreciated!
--
View this message in context:
http://apache-nifi-developer-list.39713.n7.nabble.com/Is-my-custom-processor-doing-too-many-things-OnTrigger-question-tp9225p9232.html
Sent from the Apache NiFi Developer List mailing list archive at Nabble.com.
