0 / 0

Eseguire i flussi in sequenza con Pipeline di orchestrazione in DataStage

Ultimo aggiornamento: 12 mar 2025
Orchestrazione dei flussi con Orchestration Pipelines in DataStage

Con Pipeline di orchestrazione, è possibile creare una pipeline per orchestrare l'esecuzione di DataStage in sequenza e secondo condizioni a scelta.

Tavolozza e area di disegno in Orchestration Pipelines

Per eseguire DataStage in una pipeline, puoi creare una nuova pipeline e aggiungere componenti per eseguire un flusso selezionato. È anche possibile importare un file ISX esistente per migrare un lavoro di sequenza DataStage esistente.

Componenti

Un flusso pipeline è costituito da oggetti nodo. Utilizzare questi componenti per eseguire i job DataStage nell'ordine desiderato, definire le azioni da intraprendere in base all'esito positivo del job, eseguire script, inviare notifiche ed eseguire sezioni in loop. I componenti e le caratteristiche più rilevanti per DataStage sono elencati in Componenti della pipeline per DataStage.

È possibile specificare condizioni sulle connessioni tra i componenti della pipeline per stabilire quando un flusso passerà al nodo successivo. Per ulteriori informazioni, vedi Aggiunta di condizioni a una pipeline. Per definire una condizione complessa, scrivere un'espressione in Expression Builder.

È inoltre possibile scrivere espressioni per definire le variabili utente condivise tra nodi o per definire un input per un nodo se il componente include l'opzione Immetti espressione . Expression Builder utilizza la sintassi CEL e dispone di un certo numero di funzioni integrate. Per fare riferimento a un componente della pipeline come a una variabile all'interno di un'espressione, copia l' ID nodo dalle proprietà del nodo o utilizza tasks. per compilare automaticamente l'ID nodo del nodo precedente nel flusso.

Serie di parametri

Puoi aggiungere oggetti globali come serie di parametri a un flusso della pipeline facendo clic sull'icona Oggetti globali . È inoltre possibile modificare la serie di parametri per un job DataStage in una pipeline. Fare clic su Modifica serie di parametri per questo job nel pannello delle proprietà di un nodo di job DataStage per selezionare la serie di valori da utilizzare per il job e modificare i valori. Fare clic sull'icona del link per scollegare un valore di parametro dalla serie di origini e specificare un altro valore. Assegnare un valore di parametro a Configurazione job predefinita per utilizzare i valori predefiniti dal job DataStage . È anche possibile specificare i valori dei parametri come stringhe o espressioni, selezionarli da un altro nodo o assegnarli da PROJDEF o i parametri della pipeline. Quando l'origine è una serie di parametri, è possibile scegliere una serie di valori differente. Se la serie di parametri esiste nella pipeline, puoi selezionare Value set from pipeline parameters. I job di sequenza in DataStage tradizionale con il valore impostato del parametro "As - pre - defined" o "Assign pipeline parameter set" vengono migrati a Value set from pipeline parameters.

È anche possibile selezionare Modifica parametri locali per modificare i parametri locali per un lavoro. Selezionare Configurazione lavoro predefinita per utilizzare i valori del lavoro predefiniti o Parametri pipeline per assegnare valori se gli stessi parametri sono definiti nella pipeline.

Migrazione

La migrazione richiede che le espressioni DataStage siano tradotte in espressioni CEL. Per ulteriori informazioni su CEL e sul costruttore di espressioni, vedere Espressioni CEL e limitazioni in DataStage. Per ulteriori informazioni su altri requisiti e limitazioni della migrazione, consulta Migrazione e creazione di flussi di pipeline per DataStage.