0 / 0

Migración y construcción de flujos de conducto para DataStage

Última actualización: 10 jul 2025
Migración y construcción de flujos de interconexión para DataStage

Los pasos y limitaciones siguientes se aplican a los flujos y trabajos de secuencia migrados que se construyen directamente con el lienzo de interconexión.

Para obtener una lista de los problemas generales de las canalizaciones, consulte Problemas conocidos y limitaciones de DataStage.

Flujos migrados

Para obtener más información sobre cada componente, consulte Componentes de canalización para DataStage.

Esperar un archivo
Vuelva a seleccionar o configure manualmente la vía de acceso del archivo. Como nodo ayudante para el bucle cruzado, el valor de tiempo de espera predeterminado es 23:59:59. Actualice manualmente el valor o establézcalo en 00:00:00 para que no haya tiempo de espera.
Esperar a todos
Sustituye la condición Secuenciador (todos) y anidada.
Esperar a cualquiera
Sustituye Sequencer (cualquiera).
Finalizar interconexión
Sustituye a Terminator.
El texto del mensaje final no está soportado.
Terminar bucle
Controla el estado del bucle y lo marca como completo o fallido. Si el nodo del bucle tiene el resultado control_break_node_id después de que termine, el bucle termina y no se completan todas las iteraciones. El nodo Terminar bucle se añade si sólo hay un enlace de condición al nodo Terminar bucle desde el nodo padre. Para el nodo de bucle Terminar, sólo uno de los enlaces de condición del nodo padre puede ser verdadero.
Bucle en secuencia
Sustituye el bucle de inicio/finalización.
Ejecutar trabajo de DataStage
Sustituye a la actividad Job para los trabajos paralelos.
El tipo de lista se correlaciona con Enum. La vía de acceso se correlaciona con el tipo de archivo. Para obtener más información, consulte Configuración de objetos globales para Orchestration Pipelines.
Ejecutar trabajo de canalizaciones
Sustituye a la actividad Trabajo para los trabajos de secuencia. Para obtener información, consulte la tarea Ejecutar pipelines.
Ejecutar script Bash
Debe sustituir las comillas simples alrededor de las variables de entorno por comillas dobles para que no se traten como literales de serie.

En DataStage, el montaje de volúmenes para copiar los scripts o archivos para pipeline en el nodo Bash no está soportado. Para hacer referencia a los archivos en el nodo Bash, consulte Hacer referencia a archivos en el nodo Bash ( DataStage ).

Establecer variables de usuario
Sustituye la variable de usuario. Las variables de usuario se definen a nivel global. Para obtener más información, consulte Configuración de objetos globales para Orchestration Pipelines.
Manejo de errores
Sustituye el manejador de excepciones.
Utilice error.status y error.status_message para obtener la información del nodo que ha fallado. Utilice ds.GetErrorSource() y ds.GetErrorNumber() para obtener el origen de error y el número de error.

Establecer y obtener estado de usuario

Para establecer el estado del usuario en un trabajo DataStage, puede llamar a la función incorporada SetUserStatus desde el generador de expresiones en la etapa Transformer. Cuando se va a Triggers en el Transformador y se llama a SetUserStatus, no se puede utilizar en derivaciones de columnas de entrada.

Para obtener el estado en una canalización que llama al trabajo DataStage con un nodo de trabajo Ejecutar DataStage, puede utilizar la función incorporada ds.GetUserStatus(tasks.<node name>) con el nombre del nodo de trabajo Run DataStage. También puede acceder a él en los resultados del trabajo con tasks. < nombre nodo > .user_status. Para establecer el estado de usuario en un conducto, debe añadirlo como una variable con el nodo Establecer variables de usuario y seleccionar Hacer que el valor de variable de usuario esté disponible como resultado de un conducto, lo que lo convierte en un parámetro de salida al que pueden acceder otras interconexiones. Otra interconexión puede utilizar un nodo Ejecutar trabajo de interconexión para llamar a la interconexión que establece el estado de usuario y, a continuación, obtener el estado de usuario utilizando tasks. < nombre de nodo >.results.output_parameters. < nombre de parámetro de estado de usuario >.

Si SetUserStatus se llama en una canalización hija, migración crea una variable de usuario global llamada user_status y selecciona la opción Hacer que el valor de la variable de usuario esté disponible como resultado de la canalización. En la canalización padre, también sustituye la expresión que obtiene el estado de la canalización hija, .$UserStatus, por tasks.results.output_parameters.user_status.

Flujos construidos

Ejecutar trabajo de DataStage
La variable de entorno DSJobRunEnvironmentName especifica el entorno de ejecución para DataStage trabajos. Puede agregar la variable de entorno DSJobRunEnvironmentName al nodo de trabajo Ejecutar DataStage para anular el entorno de ejecución predeterminado que se establece a nivel de proyecto o de trabajo para una ejecución específica.
Por ejemplo, si desea ejecutar un trabajo específico en el entorno de ejecución de ds-px-large , puede anular el entorno de ejecución predeterminado de ds-px-small que se establece a nivel de proyecto o de trabajo. En la pestaña Input del nodo de trabajo Run DataStage, agregue DSJobRunEnvironmentName como variable de entorno en la sección Environment variables y establezca su valor en ds-px-large.
Si agrega una variable de entorno en la sección Variables de entorno del nodo de trabajo Ejecutar DataStage, y la misma variable de entorno ya está configurada en el DataStage nivel de flujo, el valor que se pasa desde el nodo de trabajo Ejecutar DataStage tiene prioridad.
Ejecutar script Bash
Las sentencias echo deben utilizar comillas dobles para acceder al valor de una variable. Por ejemplo, echo "variablename" sustituirá "variablename" por el valor de la variable. echo 'variablename' sólo hará eco del nombre de la variable.