Maison >développement back-end >Tutoriel Python >Comment installer et utiliser le module tiers apscheduler en Python ?

Comment installer et utiliser le module tiers apscheduler en Python ?

王林avant: 2023-05-08 10:04:171625parcourir

module apscheduler

Installer le module apscheduler

pip install apscheduler

introduction du module apscheduler

APScheduler (Advanced Python Scheduler) est un framework de planification de tâches planifiées Python léger (bibliothèque Python).

APScheduler dispose de trois systèmes de planification intégrés, qui incluent :

planification de style cron (heures de début/fin facultatives)
Exécution basée sur des intervalles (exécuter des tâches à intervalles réguliers, heures de début/fin facultatives selon eh bien) )
Exécution de tâche différée unique (exécuter le travail une fois à une date/heure spécifiée)

Tâches de stockage back-end prises en charge

APScheduler peut arbitrairement mélanger et faire correspondre les systèmes de planification et les backends de stockage de tâches, lorsque pris en charge Les tâches de stockage back-end incluent :

Memory
SQLAlchemy
MongoDB
Redis
RethinkDB
ZooKee par

APScheduler a quatre composants

Les déclencheurs contiennent une planification logique, et chaque tâche a son propre déclencheur pour déterminer la prochaine durée d'exécution. Hormis leur propre configuration initiale, les déclencheurs sont totalement apatrides. Les magasins d'emplois (magasins d'emplois) stockent les tâches planifiées. Le magasin d'emplois par défaut enregistre simplement le travail dans la mémoire, et les autres magasins d'emplois enregistrent le travail dans la base de données. Lorsqu'une tâche est enregistrée dans un magasin de tâches persistant, les données de la tâche sont sérialisées et désérialisées lors du chargement. Le stockage des tâches ne peut pas partager le planificateur.
Les exécuteurs gèrent l'exécution des tâches. Ils le font généralement en soumettant des objets appelables spécifiés à un thread ou à un pool de processus dans la tâche. Une fois le travail terminé, l'exécuteur en informera le planificateur.
planificateurs (planificateurs) La configuration du stockage des tâches et des exécuteurs peut être effectuée dans le planificateur, comme l'ajout, la modification et la suppression de tâches. Différents planificateurs peuvent être sélectionnés en fonction de différents scénarios d'application. Il existe 7 options disponibles : BlockingScheduler, BackgroundScheduler, AsyncIOScheduler, GeventScheduler, TornadoScheduler, TwistedScheduler et QtScheduler.
Introduction à chaque composant

Lorsque vous planifiez une tâche, vous devez sélectionner un déclencheur pour la tâche afin de décrire le moment où la tâche est déclenchée. APScheduler a trois types de déclencheurs intégrés :

date. : Date spécifiée une fois ;

intervalle : à quelle fréquence d'exécution dans une certaine plage de temps ;
cron : compatible avec le format crontab Linux, le plus puissant.
date est le type de planification le plus basique, et le travail ne sera exécuté qu'une seule fois. Ses paramètres sont les suivants :

(datetime|str) – La date ou l'heure d'exécution du travail

2.timezone

(datetime.tzinfo|str) – stockage

si votre application recréera des tâches à chaque démarrage, utilisez donc le magasin de tâches par défaut (MemoryJobStore), mais si vous devez conserver la tâche même si le planificateur redémarre ou si l'application plante, vous devez utiliser Select la mémoire de travail spécifique en fonction de votre environnement d'application. Par exemple : utilisez Mongo ou SQLAlchemy JobStore (utilisé pour prendre en charge la plupart des SGBDR)

Executor

Le choix de l'exécuteur dépend du framework ci-dessus que vous utilisez. Dans la plupart des cas, l'utilisation de ThreadPoolExecutor par défaut peut déjà répondre à vos besoins. Si votre application implique des

opérations gourmandes en CPU

, vous pouvez envisager d'utiliser ProcessPoolExecutor pour utiliser plus de cœurs de CPU. Vous pouvez également utiliser les deux en même temps, en utilisant ProcessPoolExecutor comme deuxième exécuteur. "Choisissez le bon planificateur" app Utilisé lors de l'exécution.

AsyncIOScheduler : Utilisé lorsque votre programme utilise asyncio (un framework asynchrone).

GeventScheduler : utilisé lorsque votre programme utilise gevent (un framework de concurrence Python hautes performances).

TornadoScheduler : Utilisé lorsque votre programme est basé sur Tornado (un framework web).

TwistedScheduler : À utiliser lorsque votre programme utilise Twisted (un framework asynchrone)
QtScheduler : Peut être utilisé si votre application est une application Qt.
apscheduler module utilise
pour ajouter des tâches
Il existe deux façons d'ajouter une nouvelle tâche :

add_job pour ajouter une tâche

# -*- coding:utf-8 -*-
from apscheduler.schedulers.blocking import BlockingScheduler
import datetime

def my_job1():
    print(&#39;my_job1 is running, Now is %s&#39; % datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S"))

def my_job2():
    print(&#39;my_job2 is running, Now is %s&#39; % datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S"))

sched = BlockingScheduler()
# 每隔5秒运行一次my_job1
sched.add_job(my_job1, &#39;interval&#39;, seconds=5, id=&#39;my_job1&#39;)
# 每隔5秒运行一次my_job2
sched.add_job(my_job2, &#39;cron&#39;, second=&#39;*/5&#39;, id=&#39;my_job2&#39;)
sched.start()

mode décorateur pour ajouter une tâche ;

# -*- coding:utf-8 -*-
from apscheduler.schedulers.blocking import BlockingScheduler
import datetime

sched = BlockingScheduler()

# 每隔5秒运行一次my_job1
@sched.scheduled_job(&#39;interval&#39;, seconds=5, id=&#39;my_job1&#39;)
def my_job1():
    print(&#39;my_job1 is running, Now is %s&#39; % datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S"))

# 每隔5秒运行一次my_job2
@sched.scheduled_job(&#39;cron&#39;, second=&#39;*/5&#39;, id=&#39;my_job2&#39;)
def my_job2():
    print(&#39;my_job2 is running, Now is %s&#39; % datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S"))

sched.start()