Example project showing how to dynamically add and remove periodic tasks in Celery and Django. It is using PeriodicTask class from django-celery-beat package.
This example repository is very simple demo of uptime monitoring service. User can add server address and interval at which server uptime status will be checked. Tasks can be dynamically added or removed.
You can read more about dynamic periodic tasks in the article.
sequenceDiagram
actor U as User
participant S as Server
participant DB as Database
participant B as Celery Beat
participant W as Celery Worker
U->>S: Create monitor
Note right of S: Create objects in DB
S->>DB: Create Monitor object
S->>DB: Create IntervalSchedule object
S->>DB: Create Periodictack object
loop every beat period
DB->>B: Get info about periodic tasks
end
loop Every interval period
B->>W: Create task
Note right of W: Execute task
W->>DB: Save task result (request data)
end