HCL Commerce Version 9.1.7.0 or later

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

Pour effectuer les modifications Ingest sur tous les connecteurs dans NiFi, vous pouvez effectuer les étapes suivantes.

Procedure

  1. 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.
  2. Recherchez tous les canaux dans NiFi contenant le processeur que vous souhaitez modifier, puis faites une liste de pipe.name.
  3. Exécutez la commande suivante pour accéder au conteneur/pod NiFi Registry.
    docker exec -it {registryContainer} bash
  4. Exécutez la commande suivante pour extraire le JSON de description du canal pour la liste de pipe.name créée à l'étape 2.
    sh /opt/nifi-registry/scripts/export_flow.sh {pipe.name} > /opt/nifi-registry/{pipe.name}.json
  5. Ouvrez {pipe.name}.json, puis recherchez le processeur souhaité pour éditer et modifier sa valeur de propriété/configuration.
  6. 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
  7. 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
  8. 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.
  9. Utilisez l'une des deux méthodes suivantes (a ou b) pour mettre à jour les canaux dans NiFi avec une nouvelle version :
    1. Utilisation de l'API de mise à niveau :
      1. A l'aide de l'URL suivante, exécutez l'API de mise à niveau à partir du service Ingest pour obtenir la dernière version du canal dans un connecteur particulier.

        http://INGEST_HOSTNAME_PORT/connectors/{id}/upgrade

      Note:
      • Utilisez un corps vide.
      • Exécutez l'API de mise à niveau plusieurs fois si le canal mis à niveau se trouve dans plusieurs connecteurs.
      • Ne fonctionne pas avec les canaux dans les connecteurs de structure, les services en masse, le service de journalisation, etc.
    2. Utilisation de la console NiFi :
      1. Dans la console NiFi, accédez au canal mis à niveau qui s'affiche avec une icône de flèche rouge.
      2. Cliquez avec le bouton droit de la souris sur le canal, puis accédez à Version > Modifier la version pour choisir la version souhaitée dans la liste des versions.
      3. Cliquez sur Modifier.