Migrating variables using a directory with flow definition JSON files as input

bin/migration.sh nifi migrate-variables \
-i /etc/migration-tool-input \
-od /etc/migration-tool-output/variables \
--sourceCompatibleOutput

This generates a sourceVersion folder that contains the output files of the Stage 1 migration.

variables
└── sourceVersion
    ├── activity_log.json
    └── migrated_output
        ├── migrated_Elastic.json
        └── migrated_TCP_Listener.json

activity_log.json

• Log of all actions performed during this stage of the migration.

• The following changes were made during the variable migration:

  • A new parameter context was created with a new parameter called TCP Listener Port, which replaces the corresponding variable.
  • The TCP Listener Port variable was removed.
  • A new parameter context was created with a new parameter called Elasticsearch Index, which replaces the corresponding variable of the same name.
  • The new parameter is referenced from the PutElasticsearchJson processor.
  • The Elasticsearch Index variable was removed.

migrated_TCP_Listener.json

• A modified flow definition, which is not compatible with NiFi 2 yet.

• It contains everything the original flow definition did, except the TCP Listener process group now references a parameter instead of the removed variable.

• This is still a NiFi 1 flow definition, so do not load this file directly into NiFi 2. Use an empty NiFi 1 instance to review the modification made by the tool. The flow definition will appear unchanged, but variables will be replaced with parameters of the same name, which are now referenced by the processor instead.

• Changes in the syntax: Variables were previously referenced using ${}, whereas parameters are now referenced using #{}.

  • NiFi 1 variables: ${variable_name}
  • NiFi 2 parameters: #{parameter_name}

migrated_Elastic.json

• A modified NiFi 1 flow definition, which is not compatible with NiFi 2 yet.

• It contains everything the original flow definition did, but the Elastic process group now references a parameter instead of the removed variable.

At this point, both flow definitions have been updated to replace variables with parameters. If the result aligns with your expectations, you can either perform a full variable migration to validate the flow in NiFi 2 or continue with migrating the components.

bin/migration.sh nifi migrate-variables \
-i /etc/migration-tool-input \
-od /etc/migration-tool-output/variables

The contents of the previously generated sourceVersion folder will be overwritten, but this is not a concern as the tool generates the same sourceVersion output as before.

Additionally, a targetVersion directory is created, containing the output files of the Stage 2 part of the migration.

variables
└── sourceVersion
│    ├── activity_log.json
│    └── migrated_output
│        ├── migrated_Elastic.json
│        └── migrated_TCP_Listener.json
└──targetVersion
    ├── activity_log.json
    └── migrated_output
        ├── migrated_Elastic.json
        └── migrated_TCP_Listener.json

migrated_Elastic.json

• NiFi 2-compatible flow definition in terms of variables

• You can load it into NiFi 2 and validate it

migrated_TCP_Listener.json

• NiFi 2-compatible flow definition in terms of variables

• You can load it into NiFi 2 and validate it

activity_log.json

• List of all actions performed during this stage of the migration