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
Procedure
-
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.
-
Busque todos los canales en NiFi que contengan el procesador que desea cambiar y luego haga una lista de
pipe.name
. -
Ejecute el siguiente comando para navegar hasta el contenedor/pod NiFi Registry.
docker exec -it {registryContainer} bash
-
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
- Abra {pipe.name}.json y, a continuación, busque el procesador deseado para editarlo y cambiar su valor de propiedad/configuración.
-
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
-
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
- 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.
-
Utilice cualquiera de las dos formas siguientes (a o b) para actualizar los canales en NiFi con una nueva versión: