Editar flujos de procesamiento

En esta página se describe cómo editar flujos de procesamiento por lotes implementados en Cloud Data Fusion.

Al editar una canalización, puedes hacer lo siguiente:

  • Añade funciones de forma incremental a una canalización implementada sin crear duplicados. Por ejemplo, puedes añadir, quitar o modificar complementos y, a continuación, volver a implementar la canalización. Al editar una canalización, se crea una nueva versión de la misma, lo que evita que se multipliquen las canalizaciones y permite una mejor organización. Al duplicar un flujo de procesamiento, se crea otro con un nombre diferente.
  • Mantener un historial de las versiones editadas.
  • Ver y restaurar versiones antiguas de una canalización.
  • Edita cualquier parte del flujo de procesamiento, como la estructura, la configuración, los metadatos, las preferencias y los comentarios.
  • Exporta un archivo JSON editado de una canalización implementada.

Cuando editas el flujo de procesamiento, Cloud Data Fusion crea un nuevo borrador, que se convierte en la versión más reciente. El nombre de la canalización sigue siendo el mismo. Puedes desarrollar el flujo de procesamiento de forma iterativa sin crear flujos de procesamiento duplicados con nombres únicos. La versión más reciente conserva los activadores, las configuraciones de la canalización, los argumentos de tiempo de ejecución, los metadatos, los comentarios y las programaciones de la versión anterior. La versión más reciente es la versión activa de la canalización: se puede ejecutar o programar para que se ejecute.

Antes de empezar

  • Cloud Data Fusion permite editar flujos de procesamiento por lotes implementados en la versión 6.9.1 y posteriores. Para actualizar a la versión más reciente, consulta el artículo Actualizar el entorno de Cloud Data Fusion.
  • Cloud Data Fusion no admite la edición de flujos de procesamiento en tiempo real ni de tareas de replicación desplegados.

Editar el flujo de procesamiento

Para editar una canalización por lotes implementada en Cloud Data Fusion, sigue estos pasos:

  1. Ve a tu instancia:

    1. En la Google Cloud consola, ve a la página de Cloud Data Fusion.

    2. Para abrir la instancia en Cloud Data Fusion Studio, haga clic en Instancias y, a continuación, en Ver instancia.

      Ir a Instancias

  2. Haz clic en Lista > Implementado.

  3. Ve a la canalización que quieras editar y haz clic en Más > Editar.

    Aparecerá un nuevo borrador de la canalización en la página Studio.

  4. Edita tu flujo de procesamiento. Por ejemplo, añadir un nuevo nodo de analíticas o editar las propiedades de una fuente.

  5. Opcional: Para terminar de editar la canalización más adelante, haz clic en Guardar.

  6. Cuando hayas terminado de editar la canalización, haz clic en Implementar.

  7. En el cuadro de diálogo Enter change summary (Introduce un resumen de los cambios), escribe una descripción de los cambios que has hecho en la canalización y haz clic en Deploy (Desplegar). El flujo de procesamiento implementado se abre en la página Flujo de procesamiento.

.

Ver o restaurar una versión anterior de la canalización

Para ver o implementar una versión anterior de una canalización por lotes, sigue estos pasos:

  1. Abre tu instancia en la interfaz de Cloud Data Fusion.
  2. Haz clic en Lista > Implementado.
  3. Selecciona una canalización. La canalización aparece en la página Canalización.

  4. Haz clic en Historial.

    Aparecerá una lista del historial de versiones.

  5. Opcional: Para ver una versión anterior de una canalización, haz clic en Ver.

  6. Opcional: Para restaurar una versión anterior de la canalización a la versión más reciente, haz clic en Restaurar.

    Cloud Data Fusion crea una nueva versión del flujo de procesamiento y la abre en la página Flujo de procesamiento. Ahora es la versión más reciente.

Exportar una versión editada de una canalización implementada

Puedes exportar la versión editada de una canalización implementada como un archivo JSON para compartirla con otros desarrolladores, añadirla al control de versiones o moverla de un entorno de desarrollo a un entorno de prueba o de producción. Por ejemplo, después de editar una canalización durante las fases de desarrollo y depuración, exportas el archivo JSON y, a continuación, lo importas y lo implementas en un entorno de producción.

Exportar la última versión

Para exportar la versión más reciente de la canalización, sigue estos pasos:

  1. Abre tu instancia en la interfaz de Cloud Data Fusion.
  2. Haz clic en Lista > Implementado.

  3. Selecciona la canalización que quieras exportar y haz clic en Más > Exportar.

    Se guarda localmente un archivo JSON con las configuraciones de la canalización de la versión más reciente.

Exportar una versión anterior

Para exportar versiones anteriores de la canalización, sigue estos pasos:

  1. Abre tu instancia en la interfaz de Cloud Data Fusion.
  2. Haz clic en Lista > Implementado.
  3. Selecciona la canalización. La versión más reciente se abre en la página Pipelines (Flujos de procesamiento).
  4. Haz clic en Historial.
  5. Seleccione la versión de la canalización que quiera exportar y haga clic en Ver > Acciones > Exportar.

Importar una versión editada de una canalización implementada

Todos los flujos de procesamiento se exportan en el estado Draft. Las versiones editadas de una canalización implementada también se importan en el estado Draft. Para obtener más información, consulta Importar una canalización.

Eliminar una versión editada de una canalización

Cuando eliminas la última versión de una canalización implementada, se eliminan todas las versiones de la canalización. Los borradores de versiones no se eliminan.

En su lugar, la versión de la canalización en borrador tiene el estado Orphaned (Orphaned). Para resolver este estado, implementa la canalización de borrador. Cloud Data Fusion crea una nueva canalización, que es la versión más reciente.

Estados de los flujos de procesamiento editados

Cuando edites las canalizaciones, es posible que aparezcan los siguientes estados en la página Borradores de canalización.

Estado Descripción
En curso Has guardado los cambios en la canalización.
Orphaned Se ha eliminado la última versión de la canalización y los borradores asociados ya no pertenecen a ninguna canalización. Puede que veas este estado si alguien elimina la canalización con el siguiente endpoint: DELETE/v3/namespaces/NAMESPACE_ID/apps/APP_ID .
Obsoleto Se ha implementado una versión más reciente mientras se estaban realizando las modificaciones. Puede que veas este estado si otro desarrollador implementa la canalización antes de que termines de editarla. Es lo mismo que Borrador obsoleto que aparece en la página Canalización.

Cuando editas una canalización, pueden aparecer los siguientes estados en la página Studio.

Estado Descripción
Edición en curso Estás editando un borrador de flujo de procesamiento.
Borrador huérfano Alguien ha implementado una versión más reciente mientras editabas la canalización.

Siguientes pasos