Une petite erreur dans un code par contre je pense :

@periodic_task(run_every=crontab(hour='5,13,23', minute=30, day_of_week='monday')

Je vois ici deux parenthèses ouvrantes et une fermante :'(.

Juste pour les noobs comme moi, et qui utilisent abondement Python 3.6 – comme fourni out-of-the-box par Arch Linux, voici une légère ré-écriture du script tasks.py :

import urllib.request

from collections import Counter

from celery import Celery

celery = Celery('tasks', broker='redis://localhost', backend='redis://localhost')

@celery.task
def ecount(url):
    with urllib.request.urlopen(url) as res:
        html = res.read()
    html = html.decode('utf-8')
    return Counter(html)['e']

Voilà. Je sais pas si c’est très utile, mais si ça peut aider les bleus comme moi…

–> pour

Après, la vie privée des libs, qui se mets au dessus, qui expose quoi… cela ne nous, regarde pas ;-)

Je laisse ça la… Pour le partage.

J’aimerai créer une tache qui soit exécuté par plusieurs workers ayant différente app. Est ce que c’est possible ?

j’ai une tache périodique qui poll des events d’un service. Je voudrais stocker chaque event dans une queue par type d’event.

Ensuite que chaque worker se bind a une queue d’un type d’event qui l’intéresse et execute son code en fonction.

Vue que la fonction/app a exécuter est dans le message, je ne vois pas comment je peux faire ça.

Si vous avez une idée, je suis preneur.

Merci

F.

Tu ne crois pas si bien dire, on s’est tous les deux inscrit à l’école de massage thai pour une 30aine d’heures de cours. On va devenir experts en passage de massage \o/