We can export and import flow from one NiFi Registry to another, using nifi-toolkit cli.sh. Let's say we have two clusters, CFM-A and CFB-B, each running its own NiFi Registry. CFM-A NiFi Registry URL : http://nifi-regA:18080 CFM-B NiFi Registry URL: http://nifi-regB:18080 Export flow from CFM-A NiFi Registry to the local directory: /opt/cloudera/parcels/CFM-1.1.0.0/TOOLKIT/bin/cli.sh Type 'help' to see a list of available commands, use tab to auto-complete. 1. List buckets from CFM-A NiFi Registry: #> registry list-buckets -u http://nifi-regA:18080 # Name Id Description - ---------- ------------------------------------ ----------- 1 TestBucket 187b3d50-03ee-4e45-a717-eb113c6edbf2 (empty) 2. List flows from CFM-A NiFi Registry using bucketIdentifier: #> registry list-flows -u http://nifi-regA:18080 --bucketIdentifier 187b3d50-03ee-4e45-a717-eb113c6edbf2 # Name Id Description - ------------ ------------------------------------ ----------- 1 TailFileFlow 98ea1331-cd61-41bb-be06-0a0e85c9a275 3. Export flow locally on the file-system using flowIdentifier. This command will store flow locally under file /tmp/test.json, in Jason format, on the Node where cli.sh is running: #> registry export-flow-version -u http://nifi-regA:18080 --flowIdentifier 98ea1331-cd61-41bb-be06-0a0e85c9a275 --outputFile /tmp/test.json --outputType json Now we can Import /tmp/test.json flow to CFM-B NiFi Registry On CFM-B NiFi Registry, create an empty flow using create-flow. Create a bucket on CFM-B NiFi Registry and use the same bucket OR create a new bucket. List buckets from CFM-A NiFi Registry #> registry list-buckets -u http://nifi-regB:18080 # Name Id Description - ---- ------------------------------------ ----------- 1 TestFlow cb152ab7-d569-4dcd-b332-8ca9025c8161 (empty) 1. Create flow-name test2 under bucket TestFlow, using bucketIdentifier: #>registry create-flow -u http://nifi-regB:18080 --bucketIdentifier cb152ab7-d569-4dcd-b332-8ca9025c8161 --flowName test2 2. List flows from CFM-B NiFi Registry using bucketIdentifier: #>registry list-flows -u http://nifi-regB:18080 --bucketIdentifier cb152ab7-d569-4dcd-b332-8ca9025c8161 # Name Id Description - ---- ------------------------------------ ----------- 1 test2 ef6550d5-6306-416a-9372-81286a635e7b (empty) 3. Import flow from local file /tmp/test.json using flowIdentifier, which can be viewed above the list-flows output: #>registry import-flow-version -u http://nifi-regB:18080 --flowIdentifier ef6550d5-6306-416a-9372-81286a635e7b --input /tmp/test.json 4. Check and verify flow name and version details on CFM-B NiFi Registry URL from the Web Browser.
... View more
