-
Notifications
You must be signed in to change notification settings - Fork 9
/
Copy pathnifi-graph.graphml
35 lines (35 loc) · 16 KB
/
nifi-graph.graphml
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
<?xml version='1.0' encoding='UTF-8'?><graphml xmlns="http://graphml.graphdrawing.org/xmlns" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://graphml.graphdrawing.org/xmlns http://graphml.graphdrawing.org/xmlns/1.1/graphml.xsd"><key id="character-set" for="node" attr.name="character-set" attr.type="string"/><key id="isRoot" for="node" attr.name="isRoot" attr.type="boolean"/><key id="File Location" for="node" attr.name="File Location" attr.type="string"/><key id="procId" for="node" attr.name="procId" attr.type="string"/><key id="channel" for="node" attr.name="channel" attr.type="string"/><key id="SMTP Auth" for="node" attr.name="SMTP Auth" attr.type="string"/><key id="procName" for="node" attr.name="procName" attr.type="string"/><key id="attributes-to-log-regex" for="node" attr.name="attributes-to-log-regex" attr.type="string"/><key id="Include All Attributes In Message" for="node" attr.name="Include All Attributes In Message" attr.type="string"/><key id="Unique FlowFiles" for="node" attr.name="Unique FlowFiles" attr.type="string"/><key id="Content Type" for="node" attr.name="Content Type" attr.type="string"/><key id="To" for="node" attr.name="To" attr.type="string"/><key id="SMTP TLS" for="node" attr.name="SMTP TLS" attr.type="string"/><key id="tailfile-recursive-lookup" for="node" attr.name="tailfile-recursive-lookup" attr.type="string"/><key id="Initial Start Position" for="node" attr.name="Initial Start Position" attr.type="string"/><key id="log_level" for="node" attr.name="log_level" attr.type="string"/><key id="SMTP Hostname" for="node" attr.name="SMTP Hostname" attr.type="string"/><key id="labelV" for="node" attr.name="labelV" attr.type="string"/><key id="processorid" for="node" attr.name="processorid" attr.type="string"/><key id="webhook-url" for="node" attr.name="webhook-url" attr.type="string"/><key id="tailfile-maximum-age" for="node" attr.name="tailfile-maximum-age" attr.type="string"/><key id="webhook-text" for="node" attr.name="webhook-text" attr.type="string"/><key id="Batch Size" for="node" attr.name="Batch Size" attr.type="string"/><key id="schema.name" for="node" attr.name="schema.name" attr.type="string"/><key id="tail-mode" for="node" attr.name="tail-mode" attr.type="string"/><key id="SMTP Socket Factory" for="node" attr.name="SMTP Socket Factory" attr.type="string"/><key id="Message" for="node" attr.name="Message" attr.type="string"/><key id="Store State" for="node" attr.name="Store State" attr.type="string"/><key id="pgId" for="node" attr.name="pgId" attr.type="string"/><key id="record-writer" for="node" attr.name="record-writer" attr.type="string"/><key id="SMTP Port" for="node" attr.name="SMTP Port" attr.type="string"/><key id="Attributes to Log" for="node" attr.name="Attributes to Log" attr.type="string"/><key id="error" for="node" attr.name="error" attr.type="string"/><key id="pgName" for="node" attr.name="pgName" attr.type="string"/><key id="Log Payload" for="node" attr.name="Log Payload" attr.type="string"/><key id="File Size" for="node" attr.name="File Size" attr.type="string"/><key id="File to Tail" for="node" attr.name="File to Tail" attr.type="string"/><key id="tailfile-lookup-frequency" for="node" attr.name="tailfile-lookup-frequency" attr.type="string"/><key id="record-reader" for="node" attr.name="record-reader" attr.type="string"/><key id="Data Format" for="node" attr.name="Data Format" attr.type="string"/><key id="Attach File" for="node" attr.name="Attach File" attr.type="string"/><key id="Log Level" for="node" attr.name="Log Level" attr.type="string"/><key id="icon-url" for="node" attr.name="icon-url" attr.type="string"/><key id="From" for="node" attr.name="From" attr.type="string"/><key id="message" for="node" attr.name="message" attr.type="string"/><key id="Subject" for="node" attr.name="Subject" attr.type="string"/><key id="SMTP X-Mailer Header" for="node" attr.name="SMTP X-Mailer Header" attr.type="string"/><key id="Routing Strategy" for="node" attr.name="Routing Strategy" attr.type="string"/><key id="generate-ff-custom-text" for="node" attr.name="generate-ff-custom-text" attr.type="string"/><key id="email-ff-content-as-message" for="node" attr.name="email-ff-content-as-message" attr.type="string"/><key id="labelE" for="edge" attr.name="labelE" attr.type="string"/><graph id="G" edgedefault="directed"><node id="0"><data key="labelV">processGroup</data><data key="isRoot">true</data><data key="pgId">dadb47f2-016a-1000-19a1-7aaa9f611417</data><data key="pgName">NiFi Flow</data></node><node id="64"><data key="labelV">processor</data><data key="tailfile-recursive-lookup">false</data><data key="File Location">Local</data><data key="tailfile-maximum-age">24 hours</data><data key="procId">bd0efd4c-3086-3c99-9cc0-16a9d50119b7</data><data key="File to Tail">./logs/nifi-app.log</data><data key="Initial Start Position">Beginning of File</data><data key="procName">TailFile</data><data key="tailfile-lookup-frequency">10 minutes</data><data key="tail-mode">Single file</data></node><node id="129"><data key="labelV">processor</data><data key="character-set">UTF-8</data><data key="File Size">0B</data><data key="Batch Size">1</data><data key="procId">ee6fbd7f-9c75-3da5-f81d-2489b3bfb2bc</data><data key="Unique FlowFiles">true</data><data key="procName">GenerateFlowFile</data><data key="Data Format">Text</data></node><node id="4"><data key="labelV">processGroup</data><data key="isRoot">false</data><data key="pgId">1ed3fd16-016b-1000-a7a1-1ecc2e3eb4f5</data><data key="pgName">PG 3</data></node><node id="9"><data key="labelV">processGroup</data><data key="isRoot">false</data><data key="pgId">1ed462af-016b-1000-af8d-6b496018c95c</data><data key="pgName">PG 3.1</data></node><node id="138"><data key="labelV">processor</data><data key="character-set">UTF-8</data><data key="Log Level">warn</data><data key="procId">9dde9644-32e1-34fa-442f-54b4c3f15983</data><data key="procName">LogAttribute - WARN</data><data key="attributes-to-log-regex">.*</data><data key="Log Payload">false</data></node><node id="75"><data key="labelV">processor</data><data key="processorid">${processorid:substringBefore(']')}</data><data key="Store State">Do not store state</data><data key="procId">dbe9eb33-016a-1000-34de-ca818afc0645</data><data key="procName">UpdateAttribute</data></node><node id="14"><data key="labelV">processGroup</data><data key="isRoot">false</data><data key="pgId">dae2291a-016a-1000-985b-23f9ea93a026</data><data key="pgName">nifi-c2c</data></node><node id="81"><data key="labelV">processor</data><data key="SMTP Socket Factory">javax.net.ssl.SSLSocketFactory</data><data key="Message">${message}</data><data key="Attach File">false</data><data key="procId">dbf3ab58-016a-1000-de37-7d9d1dd86147</data><data key="SMTP Port">25</data><data key="SMTP Auth">false</data><data key="procName">PutEmail</data><data key="From">[email protected]</data><data key="Include All Attributes In Message">false</data><data key="SMTP Hostname">mail.amwater.net</data><data key="Subject">Message from NiFi - ${processorid}</data><data key="SMTP X-Mailer Header">NiFi</data><data key="Content Type">text/plain</data><data key="To">[email protected],[email protected]</data><data key="email-ff-content-as-message">false</data><data key="SMTP TLS">true</data></node><node id="146"><data key="labelV">processor</data><data key="character-set">UTF-8</data><data key="Log Level">error</data><data key="procId">34c921bf-849b-3ed8-45fd-78f4605e0ba6</data><data key="procName">LogAttribute - ERROR</data><data key="attributes-to-log-regex">.*</data><data key="Log Payload">false</data></node><node id="19"><data key="labelV">processGroup</data><data key="isRoot">false</data><data key="pgId">cf8cbced-9c51-3722-a71f-1767f07906f3</data><data key="pgName">Generate Warnings & Errors</data></node><node id="24"><data key="labelV">processGroup</data><data key="isRoot">false</data><data key="pgId">28502cd8-016b-1000-3485-2e9d676499ff</data><data key="pgName">PG 4</data></node><node id="154"><data key="labelV">processor</data><data key="character-set">UTF-8</data><data key="Log Level">info</data><data key="procId">758a66ca-016b-1000-2c81-336e0ab88ea9</data><data key="procName">LogAttribute</data><data key="Attributes to Log">Nagaraj</data><data key="attributes-to-log-regex">.*</data><data key="Log Payload">false</data></node><node id="29"><data key="labelV">processGroup</data><data key="isRoot">false</data><data key="pgId">758e3141-016b-1000-18f8-b23c31a4b0a5</data><data key="pgName">PG 4.1 :: Generate Warnings & Errors</data></node><node id="34"><data key="labelV">processGroup</data><data key="isRoot">false</data><data key="pgId">1ed3e909-016b-1000-bd09-9a371b02316f</data><data key="pgName">PG 2</data></node><node id="99"><data key="labelV">processor</data><data key="Routing Strategy">Route to Property name</data><data key="procId">ee3bbc30-8af1-3b74-74d3-648ef8303a92</data><data key="procName">RouteOnAttribute</data><data key="error">${log_level:equals('ERROR')}</data></node><node id="163"><data key="labelV">processor</data><data key="character-set">UTF-8</data><data key="File Size">0B</data><data key="generate-ff-custom-text">2019-05-21 11:56:55,313 ERROR [Timer-Driven Process Thread-6] o.a.n.processors.standard.LogAttribute LogAttribute[id=34c921bf-849b-3ed8-45fd-78f4605e0ba6] logging for flow file StandardFlowFileRecord[uuid=db07754c-1d20-4409-96f4-888601ad6c2a,claim=,offset=0,name=609d4b92-bacd-4670-9e7d-cb39a2167ff6,size=0]
--------------------------------------------------
Standard FlowFile Attributes
Key: 'entryDate'
Value: 'Tue May 21 11:56:52 EDT 2019'
Key: 'lineageStartDate'
Value: 'Tue May 21 11:56:52 EDT 2019'
Key: 'fileSize'
Value: '0'
FlowFile Attribute Map Content
Key: 'filename'
Value: '609d4b92-bacd-4670-9e7d-cb39a2167ff6'
Key: 'path'
Value: './'
Key: 'uuid'
Value: 'db07754c-1d20-4409-96f4-888601ad6c2a'
--------------------------------------------------</data><data key="Batch Size">1</data><data key="procId">684c1ef3-3ca5-1625-8842-cbfe34b55559</data><data key="Unique FlowFiles">false</data><data key="procName">INACTIVE DUP 2 :: GenerateFlowFile</data><data key="Data Format">Text</data></node><node id="39"><data key="labelV">processGroup</data><data key="isRoot">false</data><data key="pgId">1ed41e56-016b-1000-5ee5-8c1ea6736822</data><data key="pgName">PG 2.1</data></node><node id="105"><data key="labelV">processor</data><data key="character-set">UTF-8</data><data key="File Size">0B</data><data key="generate-ff-custom-text">2019-05-21 11:56:55,313 ERROR [Timer-Driven Process Thread-6] o.a.n.processors.standard.LogAttribute LogAttribute[id=34c921bf-849b-3ed8-45fd-78f4605e0ba6] logging for flow file StandardFlowFileRecord[uuid=db07754c-1d20-4409-96f4-888601ad6c2a,claim=,offset=0,name=609d4b92-bacd-4670-9e7d-cb39a2167ff6,size=0]
--------------------------------------------------
Standard FlowFile Attributes
Key: 'entryDate'
Value: 'Tue May 21 11:56:52 EDT 2019'
Key: 'lineageStartDate'
Value: 'Tue May 21 11:56:52 EDT 2019'
Key: 'fileSize'
Value: '0'
FlowFile Attribute Map Content
Key: 'filename'
Value: '609d4b92-bacd-4670-9e7d-cb39a2167ff6'
Key: 'path'
Value: './'
Key: 'uuid'
Value: 'db07754c-1d20-4409-96f4-888601ad6c2a'
--------------------------------------------------</data><data key="Batch Size">1</data><data key="procId">db1e4631-016a-1000-29b7-5401a7d27f8b</data><data key="Unique FlowFiles">false</data><data key="procName">GenerateFlowFile</data><data key="Data Format">Text</data></node><node id="44"><data key="labelV">processGroup</data><data key="isRoot">false</data><data key="pgId">1ed43c0e-016b-1000-f87e-9581c7488ea7</data><data key="pgName">PG 2.1.1</data></node><node id="173"><data key="labelV">processor</data><data key="character-set">UTF-8</data><data key="File Size">0B</data><data key="Batch Size">1</data><data key="procId">016b1001-371e-1857-a949-a0f4bfd2c321</data><data key="Unique FlowFiles">true</data><data key="procName">GenerateFlowFile</data><data key="Data Format">Text</data></node><node id="49"><data key="labelV">processor</data><data key="processorid">/processorid</data><data key="record-writer">e1d48f9f-ef95-3ac5-559a-65d4381632fc</data><data key="procId">6c2b5fbd-9993-3466-fd79-a5d48e7d22ed</data><data key="log_level">/level</data><data key="procName">PartitionRecord</data><data key="record-reader">1bb1d190-8746-3f5b-81e7-4dedc47db534</data><data key="message">/message</data></node><node id="115"><data key="labelV">processor</data><data key="webhook-url">https://hooks.slack.com/services/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
</data><data key="webhook-text">${processorid}
${message}</data><data key="procId">dc00d177-016a-1000-5178-1589691787cc</data><data key="channel">#water-pipe</data><data key="icon-url">ERROR - ${processorid}</data><data key="procName">PutSlack</data></node><node id="182"><data key="labelV">processor</data><data key="character-set">UTF-8</data><data key="Log Level">error</data><data key="procId">849b3ed8-21bf-14c9-cbde-a8c03434efd6</data><data key="procName">LogAttribute - ERROR</data><data key="attributes-to-log-regex">.*</data><data key="Log Payload">false</data></node><node id="58"><data key="labelV">processor</data><data key="Store State">Do not store state</data><data key="schema.name">nifi-logs</data><data key="procId">8e439369-8abd-33e5-7d83-8239de081e46</data><data key="procName">Set schema.name = nifi-logs</data></node><node id="123"><data key="labelV">processor</data><data key="processorid">${processorid:substringAfter('=')}</data><data key="Store State">Do not store state</data><data key="procId">db9702eb-016a-1000-bea0-33b06652a8a9</data><data key="procName">UpdateAttribute</data></node><node id="190"><data key="labelV">processor</data><data key="character-set">UTF-8</data><data key="Log Level">warn</data><data key="procId">016b1002-371e-1857-cd4f-578f7e46cf10</data><data key="procName">LogAttribute - WARN</data><data key="attributes-to-log-regex">.*</data><data key="Log Payload">false</data></node><edge id="128" source="14" target="123"><data key="labelE">parent</data></edge><edge id="197" source="29" target="190"><data key="labelE">parent</data></edge><edge id="198" source="14" target="19"><data key="labelE">dependent</data></edge><edge id="199" source="24" target="29"><data key="labelE">dependent</data></edge><edge id="8" source="0" target="4"><data key="labelE">parent</data></edge><edge id="200" source="14" target="24"><data key="labelE">dependent</data></edge><edge id="137" source="19" target="129"><data key="labelE">parent</data></edge><edge id="74" source="14" target="64"><data key="labelE">parent</data></edge><edge id="13" source="4" target="9"><data key="labelE">parent</data></edge><edge id="80" source="14" target="75"><data key="labelE">parent</data></edge><edge id="145" source="19" target="138"><data key="labelE">parent</data></edge><edge id="18" source="0" target="14"><data key="labelE">parent</data></edge><edge id="23" source="14" target="19"><data key="labelE">parent</data></edge><edge id="153" source="19" target="146"><data key="labelE">parent</data></edge><edge id="28" source="0" target="24"><data key="labelE">parent</data></edge><edge id="33" source="24" target="29"><data key="labelE">parent</data></edge><edge id="98" source="14" target="81"><data key="labelE">parent</data></edge><edge id="162" source="24" target="154"><data key="labelE">parent</data></edge><edge id="38" source="0" target="34"><data key="labelE">parent</data></edge><edge id="104" source="14" target="99"><data key="labelE">parent</data></edge><edge id="43" source="34" target="39"><data key="labelE">parent</data></edge><edge id="172" source="24" target="163"><data key="labelE">parent</data></edge><edge id="48" source="39" target="44"><data key="labelE">parent</data></edge><edge id="114" source="14" target="105"><data key="labelE">parent</data></edge><edge id="181" source="29" target="173"><data key="labelE">parent</data></edge><edge id="57" source="14" target="49"><data key="labelE">parent</data></edge><edge id="122" source="14" target="115"><data key="labelE">parent</data></edge><edge id="189" source="29" target="182"><data key="labelE">parent</data></edge><edge id="63" source="14" target="58"><data key="labelE">parent</data></edge></graph></graphml>