Planification des tâches un peu avancée avec AP Schuler

Planification des tâches un peu avancée avec AP Schuler

Raison, but et motif

• J'ai atteint la limite d'exécution d'une tâche environ une fois toutes les 10 minutes avec cron.
• __ Si le processus précédent prend plus de 10 minutes, plusieurs démarrages se produiront. __ Je veux éviter cela.
• Je pensais pouvoir utiliser un mécanisme de locking, mais je ne veux pas le mettre dans le code du travail.
• Il est ennuyeux que le travail dépende du mécanisme de verrouillage de la cible.
• __ Le test est difficile et provoque des bogues. __
• Puisqu'il s'agit d'un travail python en cours d'exécution, y a-t-il quelque chose d'écrit en python si possible?

Recherche d'un planificateur de travaux pouvant empêcher plusieurs démarrages

• Il y avait AP Shceduler!
• Implémenté en python.
• Empêche le démarrage multiple.
• Vous pouvez également spécifier l'autorisation de démarrage multiple et combien OK.
• La planification des tâches de type cron est possible.
• Il peut être démarré une fois à une heure spécifiée comme la commande at.
• La planification des tâches en quelques secondes, qui est plus fine que cron, est également possible.
• Cliquez ici pour le document original
• http://pythonhosted.org/APScheduler/index.html

Installation

Avec pip ou easy_install.

$ easy_install apscheduler
Ou
$ pip install apscheduler

Écrivons un planificateur de tâches

• Essayez d'implémenter un planificateur du type qui commence par spécifier le nombre de secondes dans l'intervalle.

import apscheduler.scheduler as ApSched

def job_function():
    print "Hello World"

sched = ApSched.Scheduler(standalone=True,coalesce=True)
sched.add_interval_job(job_function, seconds=10)
sched.start()

L'option autonome est False par défaut. S'il est défini sur True, le planificateur lui-même fonctionnera démoniaque.

Le résultat de l'essayer avec ipython.

In [18]: 2013-11-26 16:12:32.680493
Hello World
In [18]: 2013-11-26 16:12:42.680962
Hello World
In [18]: 2013-11-26 16:12:52.680975
Hello World

De plus, le temps d'intervalle est calculé en omettant correctement le temps d'exécution du programme.

Expérience pour empêcher l'activation multiple

from apscheduler.scheduler import Scheduler
import datetime
import time

def job_function_13sec():
    print datetime.datetime.today()
    time.sleep(13)
    print "Hello World"

sched = Scheduler(standalone=True,coalesce=True)
sched.add_interval_job(job_function_13sec, seconds=10)
sched.start()

résultat.

In [46]: sched.start()
2013-11-26 16:36:10.818178
WARNING:apscheduler.scheduler:Execution of job "job_function_13sec (trigger: interval[0:00:10], next run at: 2013-11-26 16:36:30.817553)" skipped: maximum number of running instances reached (1)
Hello World
2013-11-26 16:36:30.818776
WARNING:apscheduler.scheduler:Execution of job "job_function_13sec (trigger: interval[0:00:10], next run at: 2013-11-26 16:36:40.817553)" skipped: maximum number of running instances reached (1)
Hello World
2013-11-26 16:36:50.818992
WARNING:apscheduler.scheduler:Execution of job "job_function_13sec (trigger: interval[0:00:10], next run at: 2013-11-26 16:37:10.817553)" skipped: maximum number of running instances reached (1)
Hello World
2013-11-26 16:37:10.818815
WARNING:apscheduler.scheduler:Execution of job "job_function_13sec (trigger: interval[0:00:10], next run at: 2013-11-26 16:37:30.817553)" skipped: maximum number of running instances reached (1)
Hello World
2013-11-26 16:37:30.818828

En tant qu'option de travail __ Par défaut, max_run est 1__, ce qui empêche les lancements multiples.

ensuite

• Transformé en démon avec supervisord pour fonctionner tout le temps comme cron.
• http://qiita.com/yushin/items/15f4f90c5663710dbd56
• Soyez assuré que le processus redémarrera automatiquement même s'il meurt.
• Mais je veux sauter le mail s'il plante ... Sensationnel. Il semble que vous puissiez utiliser des fonctions telles que les écouteurs d'événements.