DataWorks:Apéndice: funciones de DAG

Haga clic en DAG junto a un nodo para abrir su vista de DAG. La interfaz de DAG cuenta con un lienzo central que muestra el grafo de nodos, una lista de nodos a la izquierda para seleccionarlos y controles en la parte superior para funciones como la agregación de nodos, el análisis ascendente y el análisis descendente. A continuación se describen las operaciones disponibles en la vista de DAG. Este tema utiliza una instancia de ejecución automática como ejemplo.

• Agregación de nodos

  Si una instancia de ejecución automática tiene muchos nodos o niveles de dependencia, puede agregar los nodos por dimensiones como el estado del nodo, el espacio de trabajo, el propietario o la prioridad. Así podrá consultar la cantidad de nodos de una dimensión específica, comprender mejor su distribución y gestionar la ejecución de manera más eficaz. Los siguientes ejemplos muestran la visualización cuando los nodos están configurados como Not Aggregate y cuando están aggregated by priority.

  Nota

  Solo es posible agregar nodos por estado dentro del DAG de una instancia. Una instancia puede ser de ejecución automática, de relleno de datos o de prueba.

  • Cuando los nodos no están agregados, cada uno se muestra de forma individual en el DAG. Cada nodo indica su nombre y tipo, como virtual node, ODPS SQL o batch synchronization. Las líneas entre los nodos indican las dependencias. Un mensaje en la parte inferior señala que la vista actual contiene 10 nodos distribuidos en 8 niveles de dependencia.

  • Cuando los nodos se agregan por prioridad, la visualización es la siguiente. Puede identificar rápidamente que el nodo actual tiene 6 nodos secundarios con una prioridad de 1. El DAG agregado muestra la ruta de dependencia: comienza en fanyi_test_root (nodo virtual) en la parte superior, pasa por User Behavior Analysis Case Description (nodo virtual), table_ddl_ods_raw_log_d (ODPS SQL), dos grupos agregados con dos nodos cada uno, luego hacia dws_user_info_all_di (ODPS SQL), ads_user_info_1d (ODPS SQL) y finalmente llega a User Behavior Analysis Result Query (ODPS SQL). Las flechas entre los nodos indican las dependencias de programación. El panel izquierdo enumera todos los nombres de las tareas y permite seleccionar los nodos mediante casillas de verificación.

• Análisis ascendente

  Si un nodo permanece mucho tiempo en espera, ejecute un análisis ascendente. Esta función revela los nodos ascendentes que bloquean el proceso, lo que le permite localizar y resolver rápidamente los errores de ejecución para mejorar la eficiencia.

  Nota

  • La función de análisis ascendente solo está disponible en el DAG de una instancia. Una instancia puede ser de ejecución automática, de relleno de datos o de prueba.

  • El Upstream Analysis solo se aplica a nodos que no se están ejecutando. Se muestra un máximo de seis niveles. Si necesita ver más niveles, haga clic en Continue Analysis en la esquina superior izquierda.

  • El análisis ascendente le ayuda a encontrar rápidamente los nodos antecesores de los que depende el nodo actual y que no se han ejecutado correctamente. Estos nodos pueden estar en los estados Running, Failed, Pending (Time), Pending (Resource) o Frozen. Los nodos antecesores en estos estados bloquean la ejecución descendente.

  Si un nodo de ejemplo lleva mucho tiempo sin ejecutarse, selecciónelo y haga clic en Upstream Analysis en la esquina superior izquierda. El resultado del análisis mostrará que el nodo ascendente que causa el bloqueo es old_work_root. Con esta información, podrá localizar rápidamente el nodo problemático y corregir los errores relacionados.

  Nota

  Pasos siguientes:

  • Una vez localizada la instancia clave, filtre por una dimensión de agregación para consultar el espacio de trabajo o el propietario de dicha instancia que afecta la salida de datos del nodo actual. Esto mejora la eficiencia operativa.

  • Después de identificar la instancia bloqueada, también puede hacer clic derecho sobre ella y seleccionar Run Diagnostics para analizar rápidamente por qué no se ejecutó correctamente. Para obtener más información, consulte Intelligent diagnosis.

  En los resultados del análisis ascendente, old_work_root es un nodo virtual y su nodo dependiente descendente es el nodo sd de tipo ODPS SQL.

• Análisis descendente

  De forma predeterminada, la vista de DAG muestra tres niveles: el nodo actual, sus nodos antecesores inmediatos (un nivel hacia arriba) y sus nodos descendientes inmediatos (un nivel hacia abajo). Cuando una instancia de ejecución automática tiene muchos nodos o niveles, resulta difícil visualizar todo el alcance del impacto. Utilice la función de análisis descendente para filtrar por criterios como el estado del nodo, el espacio de trabajo, el propietario o la prioridad. De este modo, podrá contar los nodos en distintos niveles o el total de nodos en todos los niveles para una dimensión específica.

  Nota

  • Vista combinada o por capas en estado agregado: al hacer clic en Downstream Analysis, los nodos se agregan por propietario de forma predeterminada y se calcula el número total de nodos de esa dimensión en todos los niveles.

  • Vista agrupada sin agregación: si hay más de 10 nodos descendientes, se muestran en grupos de forma predeterminada. Esta vista facilita comprender el impacto empresarial de los nodos.

  • Vista desagrupada: en la vista no agregada, haga clic en Ungroup para expandir los nodos agrupados. Esto le permite ver las relaciones ascendentes y descendentes de todos los nodos.

  • La vista Layer de un Downstream Analysis muestra un máximo de seis niveles. Para ver más niveles, haga clic en Continue Analysis en la esquina superior izquierda.

  El siguiente ejemplo muestra los resultados de ejecutar un Downstream Analysis en el nodo tag:

  • Vista combinada: combina los nodos descendientes analizados según la dimensión de agregación actual. En un estado no agregado, los nodos descendientes se muestran en grupos. En este ejemplo se utiliza el método Merge y los nodos están aggregated by workspace. Todos los nodos descendientes se fusionan en una sola capa, donde se muestra la cantidad de nodos que pertenecen a distintos espacios de trabajo. Al hacer clic en el botón Merged en la vista de DAG, el resultado del análisis descendente del nodo tag se muestra en modo combinado. Los siete nodos descendientes aparecen en grupos agregados, y cada grupo contiene un número distinto de nodos descendientes. La barra de estado en la parte inferior indica que actualmente se muestran 42 nodos y 5 niveles.

  • Vista por capas: muestra los nodos descendientes analizados por nivel de dependencia según la dimensión de agregación actual. En este ejemplo se utiliza el método Layer y los nodos están aggregated by workspace, lo que muestra la cantidad de nodos en distintos espacios de trabajo y niveles. Al seleccionar la vista DAG y hacer clic en el botón Layered, los nodos descendientes se organizan de arriba hacia abajo por nivel. Cada nivel indica la cantidad de nodos que contiene, y la parte inferior de la página muestra el total de nodos y niveles mostrados (por ejemplo, "42 nodes and 5 levels are displayed").

• Estilos de visualización del DAG

  Haga clic en los íconos de función en la esquina superior derecha de la vista de DAG para ajustar su estilo de visualización. Por ejemplo, use Toggle Full Screen View o Fit Screen.

  Los siguientes ejemplos muestran el DAG de los nodos descendientes de un nodo en las vistas Ungroup y Group.

  • DAG Ungroup: esta vista le ayuda a comprender claramente las relaciones ascendentes y descendentes de todos los nodos. En el modo desagrupado, cada nodo descendiente se muestra como una tarjeta individual organizada por nivel de dependencia, con un total de 15 nodos y 2 niveles. Haga clic en el ícono Snapshot de la barra de herramientas derecha para guardar el DAG actual como imagen.

  • DAG Group: esta vista muestra los nodos descendientes de forma ordenada, con cinco nodos por fila, lo que facilita ver rápidamente el número total de nodos descendientes.