HCL Commerce Version 9.1.7.0 or later

Persistencia de los cambios de Ingest (NiFi Registry)

Este tema describe cómo realizar cambios en un canal específico cambiando su propiedad/configuración en todos los conectores. Por ejemplo, cambiar la sentencia SQL para un procesador, Execute SQL, en un canal, DatabaseCategoryStage1b, a través de todo el conector en NiFi.

About this task

Complete los siguientes pasos para realizar cambios de Ingest en todos los conectores de NiFi.

Procedure

  1. Busque el procesador que desea cambiar.
    Note: Solo se pueden hacer cambios de propiedades/configuración, pero no se puede cambiar la lógica del procesador.
  2. Busque todos los canales en NiFi que contengan el procesador que desea cambiar y luego haga una lista de pipe.name.
  3. Ejecute el siguiente comando para navegar hasta el contenedor/pod NiFi Registry.
    docker exec -it {registryContainer} bash
  4. Ejecute el siguiente comando para extraer el JSON de la descripción del canal para la lista de pipe.name creada en el paso 2.
    sh /opt/nifi-registry/scripts/export_flow.sh {pipe.name} > /opt/nifi-registry/{pipe.name}.json
  5. Abra {pipe.name}.json y, a continuación, busque el procesador deseado para editarlo y cambiar su valor de propiedad/configuración.
  6. Ejecute el siguiente comando para importar el JSON de descripción del canal actualizado para la lista de pipe.name.
    sh /opt/nifi-registry/scripts/import_flow.sh {pipe.name} /opt/nifi-registry/{pipe.name}.json
  7. Ejecute el siguiente comando para salir del contenedor y hacer una copia de seguridad del JSON de la descripción del canal actualizado.
    docker cp {registryContainer}:/opt/nifi-registry/{pipe.name}.json {pipe.name}.json
  8. Utilizando la siguiente URL, compruebe el Registro NiFi para verificar que estos JSON de descripción de canales (flujo) tienen una nueva versión definida.
  9. Utilice cualquiera de las dos formas siguientes (a o b) para actualizar los canales en NiFi con una nueva versión:
    1. Uso de la API de actualización:
      1. Utilizando la siguiente URL, ejecute la API de actualización del servicio Ingest para obtener la última versión del canal en un conector concreto

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

      Note:
      • Utilice un cuerpo vacío.
      • Ejecute la API de actualización varias veces si el canal actualizado está en más de un conector.
      • No funciona con los canales de los conectores del marco, los servicios a granel, el servicio de registro, etc.
    2. Utilizando la consola NiFi:
      1. En la consola NiFi, navegue hasta el canal actualizado que aparece con un icono de una flecha roja.
      2. Haga clic con el botón derecho del ratón en el canal y, a continuación, vaya a Versión > Cambiar versión para elegir la versión deseada de la lista de versiones.
      3. Haga clic en Cambiar.