Modifications Ingest persistantes (registre NiFi)
Cette rubrique décrit comment apporter des modifications à un canal en modifiant sa propriété/configuration sur tous les connecteurs. Par exemple, la modification d'une instruction SQL pour un processeur, Execute SQL, dans un canal, DatabaseCategoryStage1b, sur tous les connecteurs dans NiFi.
About this task
Procedure
-
Recherchez le processeur que vous souhaitez modifier.
Note: Vous ne pouvez apporter que des modifications de propriété/configuration et aucune modification logique au processeur.
-
Recherchez tous les canaux dans NiFi contenant le processeur que vous souhaitez modifier, puis faites une liste de
pipe.name. -
Exécutez la commande suivante pour accéder au conteneur/pod NiFi Registry.
docker exec -it {registryContainer} bash -
Exécutez la commande suivante pour extraire le JSON de description du canal pour la liste de
pipe.namecréée à l'étape 2.sh /opt/nifi-registry/scripts/export_flow.sh {pipe.name} > /opt/nifi-registry/{pipe.name}.json - Ouvrez {pipe.name}.json, puis recherchez le processeur souhaité pour éditer et modifier sa valeur de propriété/configuration.
-
Exécutez la commande suivante pour importer le JSON de description du canal pour la liste de
pipe.name.sh /opt/nifi-registry/scripts/import_flow.sh {pipe.name} /opt/nifi-registry/{pipe.name}.json -
Exécutez la commande suivante pour quitter le conteneur et sauvegarder le JSON de description du canal mis à jour.
docker cp {registryContainer}:/opt/nifi-registry/{pipe.name}.json {pipe.name}.json - A l'aide de l'URL suivante, consultez NiFi Registry pour vérifier que ces JSON de descriptions de canal (flux) ont une nouvelle version définie.
-
Utilisez l'une des deux méthodes suivantes (a ou b) pour mettre à jour les canaux dans NiFi avec une nouvelle version :