Con l'introduzione di Azure Durable Functions è stata introdotta una nuova funzionalità che permette di gestire le esecuzioni delle nostre Azure Functions.
L'Azure Durable Functions è basata su Durable Task Framework (https://github.com/Azure/durabletask), una libreria open source su GitHub per la creazione di oggetti di gestione del flusso di più elementi serverless.
Azure Durable Functions fanno molto di più che gestire semplici catene di azioni; possono anche utilizzare qualsiasi operatore di controllo del flusso, operatori condizionali, cicli e persino la gestione degli errori. Per gestire il flusso della nostra applicazione dobbiamo utilizzare i due oggetti forniti dal sistema, ovvero, DurableOrchestrationContext e DurableOrchestrationClient.
L'orchestrator context viene utilizzato per richiamare o schedulare l'esecuzione di una funzione, un evento o un sotto orchestrator.
Consente il passaggio di parametri e la restituzione dell'output della funzione. Non dispone di metodi di dialogo o gestione con altre functions. Per il suo utilizzo all'interno della funzione è necessario aggiungere nella firma del metodo il seguente segmento di codice:
[OrchestrationTrigger]DurableOrchestrationContext orchestrationContext
Con l'orchestrator context possiamo leggere delle variabili in ingresso alla funzione, oppure chiamare una nuova funzione ed infine attendere un evento. Di seguito riportiamo i tre esempi:
var inputParameter = orchestrationContext.GetInput<List<string>>() var funcResult = await context.CallActivityAsync<List<string>>("F1", inputParameter); var eventResult = await orchestrationContext.WaitForExternalEvent<string>("eventName");
Rispetto alla DurableOrchestrationContext che abbiamo appena descritto, il DurableOrchestratorClient può essere utilizzato per gestire le funzioni, il loro stato e il loro ciclo di vita. Per il suo utilizzo all'interno della funzione è necessario aggiungere nella firma del metodo il seguente segmento di codice:
[OrchestrationClient]DurableOrchestrationClient orchestrationClient
Il client può quindi avviare una nuova istanza di una functions ma allo stesso tempo la può terminare. La lettura dello stato di una funzione e il sollevamento di eventi completano le funzioni che si hanno a disposizioni nell'oggetto DurableOrchestratorClient.
string instanceId = await orchestrationClient.StartNewAsync(functionName, eventData); await orchestrationClient.TerminateAsync(instanceId, terminationReason); var status = await orchestrationClient.GetStatusAsync(instanceId); await orchestrationClient.RaiseEventAsync(instanceId, eventName, eventData);
L'utilizzo delle durable functions ci consente di togliere ulteriore complessità al codice e di dialogare con altre functions. La gestione del flusso di esecuzione del codice ora è molto più snello e il sistema ci fornisce molte funzionalità per la gestione dello stato e la collaborazione tra più funzioni.
Commenti
Per inserire un commento, devi avere un account.
Fai il login e torna a questa pagina, oppure registrati alla nostra community.
Approfondimenti
Copiare automaticamente le secret tra più repository di GitHub
Utilizzare ChatGPT con Azure OpenAI
Utilizzare i nuovi piani dedicati di Azure Container Apps
Organizzare il codice JavaScript utilizzando i moduli
GitHub <3 .NET
Pubblicare la documentazione di un repository con GitHub Pages
Migrare un repository git da Azure DevOps a GitHub
Eseguire attività basate su eventi con Azure Container Jobs
.NET Conference Italia 2023
Accesso sicuro ai secrets attraverso i file in Azure Container Apps
Utilizzare la session affinity con Azure Container Apps
Eseguire query verso tipi non mappati in Entity Framework Core