Comment utiliser Python Flask pour créer des applications API efficaces et implémenter des tâches en arrière-plan

WBOY
Libérer: 2023-05-08 17:49:16
avant
1111 Les gens l'ont consulté

En Python, il existe plusieurs solutions pour implémenter des tâches en arrière-plan, comme Celery ou Redis Queue, qui sont de bons moyens d'implémenter un système de file d'attente de tâches. Mais utiliser les deux est fastidieux. Imaginez un scénario dans lequel nous utilisons Flask pour créer une API permettant d'appeler des tâches en arrière-plan à partir d'un terminal et d'arrêter les tâches en arrière-plan à l'aide d'un autre terminal.

Création d'une API simple à l'aide de Flask, avec deux méthodes principales, une pour démarrer la tâche en arrière-plan et l'autre pour l'arrêter.

Pour gérer le cycle de vie des tâches, nous utilisons des Event Objects, qui est un simple mécanisme de communication inter-thread. Event Objects,这是一种简单的线程间通信机制。

如下所示是所需导入的库、线程事件声明和后台任务方法:

from time import sleep
from flask import Flask
from flask_cors import CORS
import threading
thread_event = threading.Event()
def backgroundTask():
    while thread_event.is_set():
        print('Background task running!')
        sleep(5)
Copier après la connexion

这里的关键是is_set()方法,它将返回内部线程事件标志的值:truefalse

首先,使用set()方法把标志设置为true,它将启动一个线程,并连续运行backgroundTask方法。

@app.route("/start", methods=["POST"])
def startBackgroundTask():
    try:
        thread_event.set()
        thread = threading.Thread(target=backgroundTask)
        thread.start()
        return "Background task started!"
    except Exception as error:
        return str(error)
Copier après la connexion

如果要停止任务,调用clear()方法将标志设置为false

Comme indiqué ci-dessous, vous trouverez les bibliothèques importées, les déclarations d'événements de thread et les méthodes de tâches en arrière-plan requises : 🎜
@app.route("/stop", methods=["POST"])
def stopBackgroundTask():
    try:
        thread_event.clear()
        return "Background task stopped!"
    except Exception as error:
        return str(error)
Copier après la connexion
🎜La clé ici est la méthode is_set(), qui renverra la valeur de l'indicateur d'événement du thread interne : true ou false. 🎜🎜Tout d'abord, utilisez la méthode set() pour définir l'indicateur sur true, ce qui démarrera un thread et exécutera la méthode backgroundTask en continu. 🎜rrreee🎜Si vous souhaitez arrêter la tâche, appelez la méthode clear() pour définir l'indicateur sur false afin d'arrêter le thread en cours d'exécution. 🎜rrreee

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Étiquettes associées:
source:yisu.com
Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn
Tutoriels populaires
Plus>
Derniers téléchargements
Plus>
effets Web
Code source du site Web
Matériel du site Web
Modèle frontal