Member since
02-25-2020
7
Posts
0
Kudos Received
0
Solutions
03-30-2023
12:37 AM
Where can i get the client id?
... View more
09-29-2020
02:10 PM
Hi @vineet_harkut , To check if the required parameters are valid in MongoDB processor, what I would do is Suppose, there is a query like {"key":"someValue","name":"someOtherValue"}. And "someValue" and "someOtherValue" are values inside the attributes of the incoming flowFile with attribute-names "key" and "name" respectively. Hence, the resulting query in the GetMongo processor will be {"key":"${key}","name":"${name}"}. Before using the GetMongo processor, I would use RouteOnAttribute processor to check if the input to the query is a valid one. If the input is correct, I will make a query to the GetMongo processor. If the document for the query is not found, the GetMongo processor will return empty document (empty string) as content in the flowfile only when Send Empty Result is set to true inside the GetMongo processor. Later, when I use EvaluateJsonPath processor, the flowfile will be routed to "failure" when the flowfile is empty, as empty string is not a valid JSON or to "matched" if the match for the given jsonPath is found. This will put the same content inside the flowfile as $ corresponds to entire JSON object that we are getting from the input flowfIle. Now, you can add the remaining logic.
... View more
03-09-2020
10:52 PM
@nick_mortimer @mburgess @jsensharma @emaxwell @egarelnabi @MattWho Hi All, I was able to solve the above problem (the issue was jar file which I was referring was outdated) but now facing another issue attaching the screenshot of that The issue of the above problem which I able to understand is salary & emp_id has bigint as a data type that why it is throwing do not know how to handle it (because users will give database name and table name dynamically through NiFi I am fetching those details) that if I convert it to int/double it is working fine any help will be great
... View more
03-08-2020
11:01 PM
Thanks @MattWho
... View more