So implementieren Sie Failover und Wiederholungsversuche von Anforderungen in FastAPI

So implementieren Sie die Wiederherstellung und Wiederholung von Anforderungsfehlern in FastAPI

Einführung:
Bei der Entwicklung von Webanwendungen müssen wir häufig mit anderen Diensten kommunizieren. Bei diesen Diensten kann es jedoch zu Ausfällen wie vorübergehenden Netzwerkausfällen oder Antwortzeitüberschreitungen kommen. Um die Zuverlässigkeit unserer Anwendungen zu gewährleisten, müssen wir Fehler beheben und bei Bedarf erneut versuchen. In diesem Artikel erfahren Sie, wie Sie Failover und Wiederholungsversuche von Anfragen in FastAPI implementieren.

FastAPI ist ein modernes Web-Framework auf Python-Basis, das einfache und effiziente Funktionen zur Verarbeitung und Weiterleitung von Anfragen bereitstellt. Es verwendet intern eine asynchrone Methode zur Verarbeitung von Anforderungen, was die Implementierung von Fehlerbehebungen und Wiederholungsversuchen erleichtert.

Implementierungsideen für Fehlerbeseitigung und Wiederholungsversuche:
Bevor wir Fehlerbeseitigungs- und Wiederholungsfunktionen implementieren, müssen wir zunächst einige grundlegende Konzepte verstehen.

1. Leistungsschaltermodus:
   Leistungsschalter ist ein Entwurfsmodus, der die Ausbreitung von Fehlern verhindern kann. Wenn ein Dienst ausfällt, schließt der Leistungsschalter vorübergehend Anfragen an den Dienst für einen bestimmten Zeitraum und gibt die Anfragen direkt zurück. Dies vermeidet eine weitere Belastung des ausgefallenen Dienstes und gibt dem Dienst etwas Zeit zur Wiederherstellung. Wenn innerhalb einer bestimmten Zeitspanne kein Fehler auftritt, stellt sich der Leistungsschalter automatisch wieder her und leitet die Anforderung erneut an den Service weiter.
2. Wiederholungsmechanismus:
   Der Wiederholungsmechanismus besteht darin, dieselbe Anfrage erneut zu senden, wenn die Anfrage fehlschlägt, was normalerweise zu einer gewissen Verzögerungszeit führt. Der Wiederholungsmechanismus kann die Zuverlässigkeit der Anfrage sicherstellen und die Anfrage nach der Wiederherstellung nach einem Fehler erneut senden.

Basierend auf den oben genannten Ideen können wir mithilfe des Leistungsschaltermodus und des Wiederholungsmechanismus eine Wiederherstellung nach Anforderungsfehlern und einen erneuten Versuch erreichen.

Implementierungsschritte:
Das folgende Codebeispiel zeigt, wie Failover und Wiederholungsversuche von Anforderungen in FastAPI implementiert werden:

from fastapi import FastAPI
import requests

app = FastAPI()

@app.get("/retry")
def retry():
    url = "http://example.com/api"  # 要请求的URL
    max_retries = 3  # 最大重试次数
    retry_interval = 1  # 重试间隔时间（秒）

    retries = 0
    while retries <= max_retries:
        try:
            response = requests.get(url)
            return response.json()
        except requests.exceptions.RequestException as error:
            print(f"Request failed: {error}")
            retries += 1
            time.sleep(retry_interval)

    return {"message": "Max retries exceeded"}

@app.get("/circuit-breaker")
def circuit_breaker():
    url = "http://example.com/api"  # 要请求的URL
    breaker = Breaker(url, max_failures=3, reset_timeout=10)

    try:
        response = breaker.execute(requests.get)
        return response.json()
    except BreakerOpenError:
        return {"message": "Service temporarily unavailable"}

class Breaker:
    def __init__(self, url, max_failures, reset_timeout):
        self.url = url
        self.max_failures = max_failures
        self.reset_timeout = reset_timeout
        self.failures = 0
        self.last_failure = None

    def execute(self, func):
        if self.failures >= self.max_failures:
            if self.last_failure and time.time() - self.last_failure < self.reset_timeout:
                raise BreakerOpenError()
            else:
                self.reset()

        try:
            response = func(self.url)
            self.failures = 0
            return response
        except requests.exceptions.RequestException as error:
            print(f"Request failed: {error}")
            self.failures += 1
            self.last_failure = time.time()

    def reset(self):
        self.failures = 0
        self.last_failure = None

class BreakerOpenError(Exception):
    pass

Im obigen Code verwenden wir eine benutzerdefinierte Circuit Breaker-Klasse, indem wir das retry和circuit_breaker两个路由示例来实现请求的故障恢复和重试。retry路由示例使用一个while循环来进行重试，当请求失败时，会等待一段时间后重新发送请求。circuit_breakerRouting-Beispiel verwenden. Nach der maximalen Anzahl von Wenn der Fehler erreicht ist, wird eine benutzerdefinierte BreakerOpenError-Ausnahme ausgelöst.

Fazit:
In diesem Artikel haben wir Möglichkeiten zur Implementierung von Failover und Wiederholungsversuchen von Anfragen in FastAPI kennengelernt. Durch die Verwendung des Schutzschaltermusters und des Wiederholungsmechanismus können wir die Zuverlässigkeit der Anwendung verbessern und nach Ausfällen eine Wiederherstellung durchführen. Gleichzeitig haben wir anhand von Beispielcode demonstriert, wie Fehlerwiederherstellungs- und Wiederholungsfunktionen in FastAPI implementiert werden. Ich hoffe, dieser Artikel ist hilfreich für Sie, vielen Dank fürs Lesen!

Das obige ist der detaillierte Inhalt vonSo implementieren Sie Failover und Wiederholungsversuche von Anforderungen in FastAPI. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!