**Celery Introductie

Webapplicaties kunnen soms taken hebben die veel tijd in beslag nemen, zoals het verwerken van grote bestanden, het versturen van e-mails of het draaien van complexe berekeningen. Als deze taken direct in de webserver worden uitgevoerd, blokkeren ze de verwerking van andere verzoeken, wat de gebruikerservaring negatief beïnvloedt. Celery is een gedistribueerde task queue die dit probleem oplost door taken op de achtergrond, asynchroon uit te voeren. Dit zorgt ervoor dat je Flask applicatie snel en responsief blijft.

Celery werkt met een broker (zoals RabbitMQ of Redis) die de taken beheert en doorstuurt naar worker processen. Deze workers voeren de taken uit en melden de resultaten terug.

Om Celery te gebruiken, moet je het installeren en configureren. We gebruiken hier Redis als broker, maar RabbitMQ is ook een populaire keuze.

1. Installatie: Installeer Celery en Redis (of je gekozen broker) met pip:

pip install celery redis

1. Flask Applicatie Setup: Maak een nieuw Flask project (of gebruik een bestaand project).

2. Celery Config: Maak een celery.py bestand in de root van je project met de volgende configuratie:

from celery import Celery

app = Celery('myapp', broker='redis://localhost:6379/0') # Vervang 'myapp' met je applicatie naam

# Optionele configuratie instellingen
app.conf.update(
    CELERY_TASK_SERIALIZER='json',
    CELERY_RESULT_SERIALIZER='json',
    CELERY_ACCEPT_CONTENT=['json'],
    CELERY_TIMEZONE='Europe/Amsterdam',
    CELERY_ENABLE_UTC=True,
)

Vervang 'myapp' door de naam van je Flask applicatie. De broker parameter geeft aan waar je Celery broker draait (in dit geval Redis op localhost:6379). De configuratie instellingen optimaliseren de serialisatie en tijdzone.

1. Gebruik Celery in Je Flask App: Importeer in je app.py (of main Flask bestand) de Celery app:

from flask import Flask
from .celery import app as celery_app  # Importeer de celery app

app = Flask(__name__)

#... je andere Flask routes en code...

Een Celery taak is in feite een Python functie die asynchroon wordt uitgevoerd. Je defineert ze met de @app.task decorator (waarbij app verwijst naar je Celery applicatie).

from celery import shared_task

# Flask code is niet relevant in dit voorbeeld,

@shared_task
def add(x, y):
    return x + y

# Flask code...

Om deze taak uit te voeren, roep je ze aan vanuit je Flask applicatie:

from flask import Flask, render_template, request
from .celery import app

app = Flask(__name__)

@app.route('/add')
def add_numbers():
    x = int(request.args.get('x', 0))
    y = int(request.args.get('y', 0))
    result = add.delay(x, y) # Voer de taak asynchroon uit
    return f'De som van {x} en {y} wordt berekend. Task ID: {result.id}' # Geef de Task ID terug

In dit voorbeeld gebruikt add.delay(x, y) Celery om de add functie asynchroon uit te voeren. De resultaten zijn niet direct beschikbaar, maar de result.id is de identificatie van de Celery task. Dit kan gebruikt worden om de status te checken (zie volgende sectie).

Nadat je een taak hebt uitgevoerd, kun je de resultaten en status monitoren. Celery biedt functies om de status van taken op te vragen en de resultaten te verkrijgen.

from celery.result import AsyncResult
from flask import Flask, render_template, request
from .celery import app

app = Flask(__name__)

@app.route('/result/<task_id>')
def task_status(task_id):
    result = AsyncResult(task_id, app=app)
    if result.ready():
        return f'Taak is voltooid. Resultaat: {result.get()}'
    else:
        return f'Taak nog in uitvoering. Status: {result.status}'

#... de andere routes

In dit voorbeeld gebruikt /result/<task_id> de AsyncResult klasse om de status van een taak op te vragen, op basis van de Task ID die eerder werd teruggegeven. result.ready() checkt of de taak voltooid is. result.get() haalt het resultaat op als de taak voltooid is. result.status geeft de status terug (PENDING, STARTED, SUCCESS, FAILURE, etc.).