Usare un'attività For each per eseguire un'altra attività in un ciclo

Questo articolo illustra l'uso dell'attività For each con i tuoi processi Lakeflow, inclusi i dettagli sull'aggiunta e la configurazione dell'attività nell'interfaccia utente dei processi. Usare l'attività For each per eseguire un'attività nidificata in un ciclo, passando un set diverso di parametri a ogni iterazione dell'attività.

L'aggiunta dell'attività For each in un lavoro richiede la definizione di due attività: l'attività For each e l'attività nidificata. L'attività nidificata è l'attività da eseguire per ogni iterazione dell'attività For each ed è uno dei tipi standard di Job di Lakeflow. Non è possibile aggiungere un'altra For each attività come attività annidata.

Ad esempio, è possibile usare l'attività For each per eseguire un set comune di trasformazioni in più tabelle, passando un nome di tabella da un elenco di nomi di tabella a ogni iterazione dell'attività.

Le attività annidate che non hanno dipendenze tra loro possono essere eseguite simultaneamente.

Aggiungere attività For each a un processo

È possibile aggiungere un'attività For each quando si crea un processo o si modifica un'attività in un processo esistente. Per configurare un'attività For each:

1. Fare clic su Aggiungi attività.

2. Immettere un nome nel campo Nome attività .

3. Nel menù a discesa Tipo, selezionare Per ogni.

4. Immettere un nome per l’attività nel campo Nome attività.

5. Nella casella di testo Input definire i valori per l'attività su cui eseguire l'iterazione For each come matrice di valori in formato JSON. Per altre informazioni sul passaggio di parametri all'attività nidificata, vedere Quali tipi di parametri è possibile usare con l'attivitàFor each?

6. Per impostare facoltativamente il numero di iterazioni eseguibili in parallelo, immettere un valore di concorrenza per l'attività. Il valore predefinito è 1.

7. Per ricevere notifiche opzionali per l'avvio, l'esito positivo o negativo dell'attività, fare clic su + Aggiungi. Vedere Aggiungere notifiche in un processo.

8. Per completare la configurazione dell'attività For each e aggiungere un'attività nidificata da eseguire per ogni iterazione, fare clic su Aggiungi un'attività per eseguire un ciclo.

9. Selezionare il tipo di attività e le opzioni di configurazione per l'attività nidificata. Le attività annidate sono tipi di attività standard e hanno le stesse opzioni di configurazione. Vedere Configurare e modificare le attività in Processi Lakeflow.

10. Per fare riferimento ai parametri passati dall'attività For each, fare clic su Parametri. Usare il {{input}} riferimento per impostare il valore sul valore della matrice di ogni iterazione o {{input.<key>}} per fare riferimento a singoli campi oggetto quando si esegue l'iterazione su un elenco di oggetti.

    

11. Cliccare Crea task.

Alternare tra l'attività For each e l'attività nidificata

L'attività For each viene visualizzata nell'interfaccia utente Processi come un nodo con il compito annidato all'interno del nodo For each. Per passare dall'attività For each all'attività nidificata, clicca sui corrispondenti nodi.

Quali tipi di parametri è possibile usare con l'attività For each ?

L'attività For each passa parametri a ciascuna iterazione dell'attività nidificata. L'input è una matrice di oggetti e ogni oggetto viene passato a un'iterazione dell'attività annidata. Esistono diversi modi per creare gli input usati dall'attività: matrici in formato JSON, valori delle attività o parametri del processo.

Annotazioni

I parametri sono limitati a 5.000 caratteri direttamente nell'interfaccia utente o a 48 KB se si usano riferimenti al valore dell'attività (dove il valore può essere molto più grande della dimensione della stringa che la descrive) o 10.000 caratteri per il valore dei parametri del processo. Se i parametri richiedono più di 48 KB, è possibile fare riferimento a un file di configurazione più grande. Vedere Usare una tabella di ricerca per matrici di parametri di grandi dimensioni.

Matrice json formattata di valori

Quando si crea o si modifica un'attività, è possibile definire direttamente una matrice di valori per l'attività nidificata, usando la casella di testo Input . Questa può essere una matrice dei tipi di dati seguenti:

• Coppie chiave-valore
• Stringhe, numeri o tipi booleani
• Oggetti JSON arbitrariamente complessi

La casella di testo Input e quindi JSON passato direttamente in questa casella è limitata a 5.000 caratteri.

Riferimenti ai valori dei compiti

È possibile passare i valori di un compito da un compito precedente. Per fare riferimento ai valori delle attività passate, usare la {{tasks.<task_name>.values.<task_value_name>}} sintassi per impostare il valore nella casella di testo Input . Ad esempio, se un'attività denominata generate_countries_list che precede l'attività For each imposta il valore dell'attività seguente:

dbutils.jobs.taskValues.set(key = "countries", value = countries_array)

L'attività For each fa quindi riferimento al valore dell'attività nella casella di testo Input usando la sintassi seguente:

{{tasks.generate_countries_list.values.countries}}.

È possibile inserire fino a 5.000 caratteri nella casella di testo Input, ma i valori rappresentati dai riferimenti possono essere fino a 48 KB. Per altre informazioni sui valori delle attività, vedere Usare i valori delle attività per passare informazioni tra le attività.

Parametri del lavoro

È anche possibile usare i parametri del lavoro come dati di input. Per fare riferimento a un parametro del processo, usare la sintassi seguente nella casella di testo Input: {{job.parameters.<name>}}. Ad esempio: {{job.parameters.countries}}.

È possibile inserire fino a 5.000 caratteri nella casella di testo Input per fare riferimento ai parametri del processo. I valori dei parametri del processo sono limitati a 10 KB. Per maggiori informazioni sui parametri del processo, vedere Configurare i parametri del processo.

Fare riferimento a un'attività For each nelle attività downstream

L'attività For each è l'attività di primo livello e le attività downstream possono specificarla come dipendenza. Le attività a valle non possono dipendere o fare riferimento all'attività nidificata.

Eseguire e monitorare un compito con For each

L'esecuzione di un processo con un'attività For each è identica all'esecuzione di qualsiasi altro processo.

Anche la visualizzazione e la gestione delle esecuzioni dei processi sono identiche a qualsiasi altro processo, ad eccezione della cronologia di esecuzione delle attività per un'attività For each, che viene presentata come tabella di iterazioni delle attività. Vedere Visualizzare la cronologia di esecuzione delle attività per un'attivitàFor each.