Configura task

In questa sezione viene descritta la creazione e la configurazione dei task.

Argomenti:

• Informazioni sui task
• Crea un task Python
• Crea task blocco note
• Creare un task job nidificato
• Crea un task If/Else
• Crea un task JAR
• Modifica un task
• Visualizza i log dei task
• Elimina task
• Riparazione esecuzioni job non riuscite

Informazioni sui task

Le attività sono blocchi di codice brevi e funzionali che è possibile suddividere in un flusso nell'ambito di una mansione o promuovere per le mansioni stesse.

Le attività sono gli elementi costitutivi principali di tutti i flussi di lavoro in Oracle AI Data Platform Workbench. Il tipo di task determina il tipo di codice utilizzato. Nell'ambito di un job, è possibile connettere i task per determinarne la sequenza e la priorità quando il job viene eseguito.

Tipo di task	Descrizione
Task blocco note	Task salvato in un blocco note a cui è possibile accedere
Task Python	Attività che utilizza uno snippet del linguaggio di programmazione Python
Condizione If/else	Task che utilizza le condizioni if/else
Task job nidificato	Task che utilizza un job esistente e i relativi task come task nidificato
Task JAR	Un'attività che può eseguire codice Scala o Java compilato in file JAR (Java Archive).

Quando si dispone di più task, è possibile creare set di dipendenze di task in cui l'esito positivo o negativo di un task può attivare task successivi in sequenza. È possibile creare dipendenze solo nei job con più task. Vedere Crea un task blocco note.

I task possono essere eseguiti in parallelo tra loro. È possibile eseguire questa operazione rendendo due o più attività dipendenti dall'esito positivo o negativo di un'altra attività nello stesso flusso di lavoro, in modo che vengano eseguite contemporaneamente.

Le attività possono non riuscire a causa di problemi transitori, come interruzioni di rete, indisponibilità delle risorse o errori temporanei del servizio. In questi casi, il workbench AI Data Platform riprova automaticamente il task in base AI criteri di nuovo tentativo configurati quando il task viene creato. Nell'ambito di questi criteri, è possibile definire:

• Conteggio nuovi tentativi: il numero massimo di nuovi tentativi.
• Intervallo nuovi tentativi: il tempo di attesa tra i nuovi tentativi.

Oltre AI tentativi di task standard, AI Data Platform Workbench supporta anche Riprova al timeout. Se un task supera il relativo limite di tempo di esecuzione a causa di vincoli di risorse o di un'elaborazione lenta e si desidera riprovare solo per questi scenari, è possibile scegliere di attivare automaticamente un nuovo tentativo. Questi criteri per i nuovi tentativi migliorano la resilienza del flusso di lavoro, garantendo che le attività abbiano maggiori possibilità di esecuzione di successo senza intervento manuale.

Quando e come utilizzare i log di computazione

Dovresti controllare i log di computazione se la tua attività non riesce con errori correlati alle risorse o al sistema, come errori di memoria insufficiente o l'uso della CPU che supera i limiti.

Rivedere i log Spark se vengono visualizzati tempi di attesa lunghi, tentativi imprevisti o colli di bottiglia delle prestazioni dei job. Questi log forniscono approfondimenti sui driver e sui nodi di lavoro del cluster di computazione che supporta il task e possono aiutare a identificare l'origine dei possibili problemi.

Per istruzioni su come controllare i log, vedere Monitorare un'esecuzione di job specifica.

Per visualizzare i metadati e i log per l'istanza di computazione associata al job, è necessario disporre dell'autorizzazione RBAC a livello di computazione appropriata. Contattare l'amministratore per ottenere queste autorizzazioni se non si è in grado di visualizzare i log di calcolo. Per ulteriori informazioni, vedere Informazioni sulle autorizzazioni.

Crea un task Python

È possibile creare un task come parte di un job di workflow che utilizza script Python.

1. Nella home page, fare clic su Flusso di lavoro.
2. Fare clic sul job per il quale si desidera eseguire un task.
3. Fare clic su Aggiungi task.
4. Immettere un nome di task.
5. Per Tipo di task selezionare Python.
6. Fare clic su Sfoglia e passare allo script Python che si desidera aggiungere come task. Fare clic su Seleziona.
7. Selezionare un cluster di computazione per il task Python, se non è già collegato.
8. Selezionare il numero di nuovi tentativi che un task deve tentare in caso di errore. Se si selezionano più di 0, è necessario specificare anche il tempo di attesa dell'esecuzione del job tra i nuovi tentativi e se i nuovi tentativi devono essere eseguiti al timeout.
   
   

   

   
   
9. Da Dipende da, selezionare i task da cui si desidera rendere dipendente il task. Selezionare la risposta condizionale a tale dipendenza dall'elenco a discesa Esegui se.
10. Aggiungere parametri aggiuntivi specificando la chiave e il valore. Fare clic su Aggiungi parametro per fornire più parametri.

Crea task blocco note

I task vengono creati utilizzando i notebook creati nel workbench di AI Data Platform.

1. Nella home page, fare clic su Flusso di lavoro.
2. Fare clic sul job per il quale si desidera eseguire un task.
3. Fare clic su Aggiungi task.
4. Immettere un nome di task.
5. Per Tipo di task, selezionare Notebook.
6. Fare clic su Sfoglia e passare al blocco appunti che si desidera aggiungere come task. Fare clic su Seleziona.
7. Selezionare un cluster di computazione per il task notebook, se non è già collegato.
8. Selezionare il numero di nuovi tentativi che un task deve tentare in caso di errore. Se si selezionano più di 0, è inoltre necessario specificare il tempo di attesa dell'esecuzione del job tra i nuovi tentativi e se i nuovi tentativi devono essere eseguiti al timeout.
   
   

   

   
   
9. Da Dipende da, selezionare i task da cui si desidera rendere dipendente il task. Selezionare la risposta condizionale a tale dipendenza dall'elenco a discesa Esegui se.
10. Aggiungere parametri aggiuntivi specificando la chiave e il valore. Fare clic su Aggiungi parametro per fornire più parametri.

Creare un task job nidificato

È possibile utilizzare un altro job del workflow e i relativi task contenuti come task nidificato all'interno di un altro workflow.

1. Nella home page, fare clic su Flusso di lavoro.
2. Fare clic sul job per il quale si desidera eseguire un task.
3. Fare clic su Aggiungi task.
4. Immettere un nome di task.
5. Per Tipo di task selezionare Task job nidificato.
6. Dall'elenco a discesa Job selezionare un job esistente da cui si desidera creare un task.
7. Selezionare il numero di nuovi tentativi che un task deve tentare in caso di errore. Se si selezionano più di 0, è necessario specificare anche il tempo di attesa dell'esecuzione del job tra i nuovi tentativi e se i nuovi tentativi devono essere eseguiti al timeout.
   
   

   

   
   
8. Da Dipende da, selezionare i task da cui si desidera rendere dipendente il task. Selezionare la risposta condizionale a tale dipendenza dall'elenco a discesa Esegui se.
9. Aggiungere parametri aggiuntivi specificando la chiave e il valore. Fare clic su Aggiungi parametro per fornire più parametri.

Crea un task If/Else

È possibile creare un task che utilizza condizioni if/else basate sui dati del catalogo per determinare se il task viene attivato.

1. Nella home page, fare clic su Flusso di lavoro.
2. Fare clic sul job per il quale si desidera eseguire un task.
3. Fare clic su Aggiungi task.
4. Immettere un nome di task.
5. Per Tipo di task selezionare If/Else.
6. Immettere le condizioni che determinano se il task viene attivato. Fare clic su Aggiungi per impostare più condizioni.
7. Immettere l'espressione della condizione.
8. Selezionare il numero di nuovi tentativi che un task deve tentare in caso di errore. Se si selezionano più di 0, è necessario specificare anche il tempo di attesa dell'esecuzione del job tra i nuovi tentativi e se i nuovi tentativi devono essere eseguiti al timeout.
   
   

   

   
   
9. Da Dipende da, selezionare i task da cui si desidera rendere dipendente il task. Selezionare la risposta condizionale a tale dipendenza dall'elenco a discesa Esegui se.
10. Aggiungere parametri aggiuntivi specificando la chiave e il valore. Fare clic su Aggiungi parametro per fornire più parametri.

Crea un task JAR

È possibile creare task che eseguono codice Scala o Java compilato in file JAR (Java Archive).

Nota

I file di libreria dipendenti devono utilizzare versioni JDK, Scala o Spark compatibili con il runtime cluster di Oracle AI Data Platform Workbench al momento della creazione per evitare un comportamento imprevisto.

1. Nella home page, fare clic su Flusso di lavoro.
2. Fare clic sul job per il quale si desidera eseguire un task.
3. Fare clic su Aggiungi task.
4. Immettere un nome di task.
5. Per Tipo di task selezionare Task JAR.
6. Per Nome classe principale specificare il nome completo della classe contenente il metodo principale che si desidera eseguire. Ad esempio, ProcessTransaction. Questa classe deve essere inclusa in uno dei file aggiunti come libreria dipendente.
7. Per le librerie dipendenti, fare clic su Aggiungi.
8. Selezionare un'origine per i file della libreria dipendente. Deve essere inclusa almeno una libreria contenente il metodo della classe principale indicato in precedenza.
   • Per Area di lavoro o Volume, sfogliare l'area di lavoro o il volume del workbench AI Data Platform, selezionare il file o i file che si desidera aggiungere come libreria e fare clic su Aggiungi.
   • Per Carica file nell'area di lavoro, cercare nel computer locale il file o i file da caricare come libreria e fare clic su Aggiungi.
9. In Argomenti riga di comando, fornire gli argomenti delimitati da spazi che si desidera passare alla classe principale.
10. Selezionare il numero di nuovi tentativi che un task deve tentare in caso di errore. Se si selezionano più di 0, è necessario specificare anche il tempo di attesa dell'esecuzione del job tra i nuovi tentativi e se i nuovi tentativi devono essere eseguiti al timeout.
    
    

    

    
    
11. Da Dipende da, selezionare i task da cui si desidera rendere dipendente il task. Selezionare la risposta condizionale a tale dipendenza dall'elenco a discesa Esegui se.
12. Aggiungere parametri aggiuntivi specificando la chiave e il valore. Fare clic su Aggiungi parametro per fornire più parametri.

Modifica un task

È possibile modificare gli attributi esistenti di un task, ad esempio nome, tipo e parametri, per modificare il funzionamento del job.

1. Nella home page, fare clic su Flusso di lavoro.
2. Fare clic sul job per il quale si desidera configurare i task.
3. Nella scheda Task fare clic sul task che si desidera modificare.
4. Nel riquadro Dettagli task a destra, modificare gli attributi del task in base alle esigenze. Le modifiche vengono salvate automaticamente.

Visualizza i log dei task

È possibile visualizzare i log di esecuzione di singoli task in un job.

1. Nella home page, fare clic su Flussi di lavoro.
2. Fare clic su Esecuzioni job.
3. Fare clic sul job per il quale si desidera visualizzare i log dei task.
4. Fare clic sui nodi del task per visualizzare i log relativi al task.

Elimina task

È possibile eliminare un task rimuovendo il nodo del task da un job.

1. Nella home page, fare clic su Flusso di lavoro.
2. Fare clic sul job dal quale si desidera eliminare i task.
3. Nel nodo del task fare clic su Azioni, quindi su Rimuovi nodo.
4. Fare clic su Elimina.