Mailing-List: contact users-help@nifi.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@nifi.apache.org
From: Manish Gupta 8 <mgupta50@sapient.com>
To: "users@nifi.apache.org" <users@nifi.apache.org>
Subject: Processor to enrich attribute from external service
Thread-Topic: Processor to enrich attribute from external service
Thread-Index: AdIFY3L9rY+5xmckSvG/myw/OPnucA==
Date: Fri, 2 Sep 2016 21:47:13 +0000
Message-ID: <C323735DFA07DC4BBB568EC328CBC54331C8DBD4@DLUMAIL02.sapient.com>
Accept-Language: en-US
Content-Language: en-US
Content-Type: multipart/alternative;
	boundary="_000_C323735DFA07DC4BBB568EC328CBC54331C8DBD4DLUMAIL02sapien_"
MIME-Version: 1.0
archived-at: Fri, 02 Sep 2016 21:47:27 -0000

--_000_C323735DFA07DC4BBB568EC328CBC54331C8DBD4DLUMAIL02sapien_
Content-Type: text/plain; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable

Hello Everyone,

Is there a processor that we can use for updating/adding an attribute of an=
 incoming flow file from some external service (say MongoDB or Couchbase or=
 any RDBMS)? The processor will use the attribute of incoming flow file, qu=
ery the external service, and simply modify/add an additional attribute of =
flow-file (without touching the flow file content).

If we have to achieve this kind of "lookup" operation (but only to update a=
ttribute and not the content), what are the options in NiFi?
Should we create a custom processor (may be by taking GetMongo processor an=
d modifying its code to update an attribute with query result)?

Thanks,
Manish


--_000_C323735DFA07DC4BBB568EC328CBC54331C8DBD4DLUMAIL02sapien_
Content-Type: text/html; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable

<html xmlns:v=3D"urn:schemas-microsoft-com:vml" xmlns:o=3D"urn:schemas-micr=
osoft-com:office:office" xmlns:w=3D"urn:schemas-microsoft-com:office:word" =
xmlns:m=3D"http://schemas.microsoft.com/office/2004/12/omml" xmlns=3D"http:=
//www.w3.org/TR/REC-html40">
<head>
<meta http-equiv=3D"Content-Type" content=3D"text/html; charset=3Dus-ascii"=
>
<meta name=3D"Generator" content=3D"Microsoft Word 15 (filtered medium)">
<style><!--
/* Font Definitions */
@font-face
	{font-family:Mangal;
	panose-1:2 4 5 3 5 2 3 3 2 2;}
@font-face
	{font-family:"Cambria Math";
	panose-1:2 4 5 3 5 4 6 3 2 4;}
@font-face
	{font-family:Calibri;
	panose-1:2 15 5 2 2 2 4 3 2 4;}
/* Style Definitions */
p.MsoNormal, li.MsoNormal, div.MsoNormal
	{margin:0in;
	margin-bottom:.0001pt;
	font-size:11.0pt;
	font-family:"Calibri",sans-serif;}
a:link, span.MsoHyperlink
	{mso-style-priority:99;
	color:#0563C1;
	text-decoration:underline;}
a:visited, span.MsoHyperlinkFollowed
	{mso-style-priority:99;
	color:#954F72;
	text-decoration:underline;}
span.EmailStyle17
	{mso-style-type:personal-compose;
	font-family:"Calibri",sans-serif;
	color:windowtext;}
.MsoChpDefault
	{mso-style-type:export-only;
	font-family:"Calibri",sans-serif;}
@page WordSection1
	{size:8.5in 11.0in;
	margin:1.0in 1.0in 1.0in 1.0in;}
div.WordSection1
	{page:WordSection1;}
--></style><!--[if gte mso 9]><xml>
<o:shapedefaults v:ext=3D"edit" spidmax=3D"1026" />
</xml><![endif]--><!--[if gte mso 9]><xml>
<o:shapelayout v:ext=3D"edit">
<o:idmap v:ext=3D"edit" data=3D"1" />
</o:shapelayout></xml><![endif]-->
</head>
<body lang=3D"EN-US" link=3D"#0563C1" vlink=3D"#954F72">
<div class=3D"WordSection1">
<p class=3D"MsoNormal">Hello Everyone,<o:p></o:p></p>
<p class=3D"MsoNormal"><o:p>&nbsp;</o:p></p>
<p class=3D"MsoNormal">Is there a processor that we can use for updating/ad=
ding an attribute of an incoming flow file from some external service (say =
MongoDB or Couchbase or any RDBMS)? The processor will use the attribute of=
 incoming flow file, query the external
 service, and simply modify/add an additional attribute of flow-file (witho=
ut touching the flow file content).<o:p></o:p></p>
<p class=3D"MsoNormal"><o:p>&nbsp;</o:p></p>
<p class=3D"MsoNormal">If we have to achieve this kind of &#8220;lookup&#82=
21; operation (but only to update attribute and not the content), what are =
the options in NiFi?
<o:p></o:p></p>
<p class=3D"MsoNormal">Should we create a custom processor (may be by takin=
g GetMongo processor and modifying its code to update an attribute with que=
ry result)?<o:p></o:p></p>
<p class=3D"MsoNormal"><o:p>&nbsp;</o:p></p>
<p class=3D"MsoNormal"><span style=3D"color:black">Thanks,<o:p></o:p></span=
></p>
<p class=3D"MsoNormal"><span style=3D"color:black">Manish<o:p></o:p></span>=
</p>
<p class=3D"MsoNormal"><o:p>&nbsp;</o:p></p>
</div>
</body>
</html>

--_000_C323735DFA07DC4BBB568EC328CBC54331C8DBD4DLUMAIL02sapien_--