Python | Durable Functions
This sample demonstrates the fan-out/fan-in pattern using Azure Durable Functions with Python. It processes a batch of work items in parallel and aggregates the results — a fundamental pattern for parallel data processing.
The orchestration:
- Generates a list of work items
- Fans out by scheduling parallel activity executions for each item
- Waits for all activities to complete
- Aggregates and returns the combined results
-
Start the emulator:
docker run -d -p 8080:8080 -p 8082:8082 mcr.microsoft.com/dts/dts-emulator:latest
-
Set up and run:
python -m venv venv source venv/bin/activate pip install -r requirements.txt func start -
Trigger the orchestration:
curl -X POST http://localhost:7071/api/StartFanOutFanIn
-
View in dashboard: http://localhost:8082