DataStage corridore ottimizzato
Il pipeline runner ottimizzato di DataStage è un motore di esecuzione alternativo progettato per semplificare l'orchestrazione di pipeline nidificate all'interno dell'esecuzione di un singolo processo. Invece di affidarsi alle chiamate API REST, inizia a generare codice Python e direttamente all'interno del runtime del motore. Questo approccio migliora le prestazioni e l'efficienza grazie alla sua architettura leggera.
Impostazione ottimizzata del pipeline runner
- Crea o apri un progetto esistente.
- Nella scheda Gestisci, seleziona la sezione Pipeline dalle opzioni a sinistra.
- Vai alla sezione dedicata al pipeline runner ottimizzato per l' DataStage.
- Selezionare l'opzione Esegui utilizzando il runner pipeline ottimizzato. Fare clic su Salva.
- Apri qualsiasi pipeline da Risorse > Flussi > Pipeline.
- Apri una pipeline esistente. Fai clic sul pulsante Esegui pipeline. Il tuo lavoro viene eseguito come una pipeline ottimizzata.
Monitoraggio dello stato della pipeline
È possibile visualizzare lo stato di compilazione delle pipeline che utilizzano il runner ottimizzato DataStage nella scheda Risorse del progetto. Le pipeline vengono compilate solo dopo aver avviato un'esecuzione dall'interfaccia utente. È possibile visualizzare tre stati: obsoleto, non compilato o compilato correttamente.
Esecuzione di un processo come pipeline ottimizzata utilizzando cpdctl
È possibile eseguire un processo come pipeline ottimizzata utilizzando cpdctl. Per ulteriori informazioni, consulta Eseguire pipeline utilizzando il runner ottimizzato.