Je bouwt een Durable Functions workflow die een lijst van 50.000 afbeeldings-URL's ontvangt en EXIF-metadata voor elke afbeelding parallel moet extraheren, om vervolgens een enkele geaggregeerde lijst terug te geven. De orchestrator moet deterministisch blijven en correct kunnen hervatten na replays of herstarts. Wat moet je doen in de orchestrator-functie om het fan-out/fan-in patroon te implementeren?

De correcte aanpak voor fan-out/fan-in in Durable Functions is het itereren over de input (de URL's), voor elk item een afzonderlijke activiteit (CallActivityAsync) aan te roepen, de resulterende Task-objecten te verzamelen, en vervolgens te wachten op Task.WhenAll(tasks). Dit zorgt voor parallelle uitvoering van de activiteiten en deterministisch gedrag, essentieel voor orchestrators. Task.WhenAll wacht efficiënt tot alle parallelle taken zijn voltooid voordat de resultaten worden geaggregeerd. Parallel.ForEach is niet toegestaan in een orchestrator-functie omdat het niet-deterministisch is en de replay-functionaliteit kan verstoren. Een enkele activiteit voor alle URL's zou de parallelisatie tenietdoen en de uitvoeringstijd verlengen. ContinueAsNew is bedoeld voor lange-termijn orchestraties om de geschiedenis te resetten, niet voor het beheren van parallelle taken binnen een enkele orchestratie.