So verwenden Sie Push-Benachrichtigungen in FastAPI, um Daten in Echtzeit zu aktualisieren-Python-Tutorial-php.cn

So verwenden Sie Push-Benachrichtigungen in FastAPI, um Daten in Echtzeit zu aktualisieren

Einführung:
Mit der kontinuierlichen Entwicklung des Internets werden Datenaktualisierungen in Echtzeit immer wichtiger. In Anwendungsszenarien wie Echtzeithandel, Echtzeitüberwachung und Echtzeitspiele müssen wir beispielsweise Daten zeitnah aktualisieren, um die genauesten Informationen und die beste Benutzererfahrung bereitzustellen. FastAPI ist ein modernes Python-basiertes Webframework, das eine einfache und effiziente Möglichkeit bietet, leistungsstarke Webanwendungen zu erstellen. In diesem Artikel wird erläutert, wie Sie mit FastAPI Push-Benachrichtigungen implementieren, um Daten in Echtzeit zu aktualisieren.

Schritt 1: Vorbereitung
Zuerst müssen wir FastAPI und die entsprechenden abhängigen Bibliotheken installieren. Es kann mit dem folgenden Befehl installiert werden:

pip install fastapi
pip install uvicorn

Nach dem Login kopieren

Als nächstes müssen wir eine Python-Datei erstellen und sie main.py nennen. Wir werden unsere FastAPI-Anwendung darin schreiben. main.py。我们将在其中编写我们的FastAPI应用程序。

步骤二：编写推送通知逻辑
我们将使用WebSocket来实现推送通知的功能。WebSocket是一种在客户端和服务器之间实现全双工通信的协议。在FastAPI中，可以使用第三方库fastapi-websocket来轻松地为我们的应用程序添加WebSocket支持。可以使用以下命令来安装该库：

pip install fastapi-websocket

Nach dem Login kopieren

在main.py中，我们首先导入所需的模块：

from fastapi import FastAPI, WebSocket
from fastapi.responses import HTMLResponse
from fastapi.staticfiles import StaticFiles
from fastapi.templating import Jinja2Templates
from fastapi import WebSocket, WebSocketDisconnect

from fastapi_websocket_pubsub import PubSubEndpoint
from fastapi_websocket_pubsub import PubSubWebSocketEndpoint

Nach dem Login kopieren

然后，我们创建一个FastAPI应用程序：

app = FastAPI()
app.mount("/static", StaticFiles(directory="static"), name="static")

templates = Jinja2Templates(directory="templates")

Nach dem Login kopieren

接下来，我们需要定义WebSocket的逻辑。我们将创建一个WebSocket的子类，并在其中实现推送通知的功能：

class NotificationsWebSocket(WebSocketEndpoint):
async def on_receive(self, websocket: WebSocket, data: str):
    # 在这里实现推送通知的逻辑
    # 可以根据需要订阅特定的主题或频道

async def on_connect(self, websocket: WebSocket):
    await websocket.accept()

async def on_disconnect(self, websocket: WebSocket, close_code: int):
    await self.pubsub.unsubscribe(self.room_name, websocket)

app.add_websocket_route("/ws", NotificationsWebSocket)

Nach dem Login kopieren

在on_receive方法中，我们可以根据需要订阅特定的主题或频道，并通过WebSocket将新数据发送给客户端。在FastAPI应用程序中，我们可以使用PubSubEndpoint来管理订阅和发布的逻辑。可以使用以下命令来安装fastapi_websocket_pubsub库：

pip install fastapi_websocket_pubsub

Nach dem Login kopieren

在main.py中，我们导入PubSubEndpoint并创建一个实例：

from fastapi_websocket_pubsub import PubSubEndpoint

pubsub = PubSubEndpoint()

Nach dem Login kopieren

然后，我们将pubsub实例传递给WebSocket的子类，以便在其中使用推送通知的功能：

class NotificationsWebSocket(WebSocketEndpoint):
    async def on_receive(self, websocket: WebSocket, data: str):
        # 在这里实现推送通知的逻辑
        await self.pubsub.publish(self.room_name, data)

    async def on_connect(self, websocket: WebSocket):
        await self.pubsub.subscribe(self.room_name, websocket)
        await websocket.accept()

    async def on_disconnect(self, websocket: WebSocket, close_code: int):
        await self.pubsub.unsubscribe(self.room_name, websocket)

Nach dem Login kopieren

步骤三：创建前端页面
我们还需要创建一个前端页面，以便用户可以通过浏览器访问我们的应用程序。可以创建一个名为index.html的文件，并将其放在名为templates的文件夹中。在index.html中，我们可以使用WebSocket来订阅推送通知，并在接收到新数据时更新页面。以下是一个简单的示例：

<!DOCTYPE html>
<html>
<head>
    <title>Notifications</title>
</head>
<body>
    <h1>Notifications</h1>
    <ul id="messages"></ul>

    <script>
    const socket = new WebSocket("ws://localhost:8000/ws");
    
    socket.onopen = () => {
        console.log("WebSocket connection is open.");
    };
    
    socket.onmessage = (event) => {
        const message = document.createElement("li");
        message.textContent = event.data;
        document.getElementById("messages").appendChild(message);
    };
    
    socket.onclose = () => {
        console.log("WebSocket connection is closed.");
    };
    
    </script>
</body>
</html>

Nach dem Login kopieren

步骤四：启动应用程序
在main.py的末尾，我们需要添加以下代码以启动FastAPI应用程序：

if __name__ == "__main__":
    import uvicorn
    uvicorn.run(app, host="0.0.0.0", port=8000)

Nach dem Login kopieren

现在，我们可以使用以下命令启动我们的FastAPI应用程序：

python main.py

Nach dem Login kopieren

完成！现在，我们可以通过浏览器访问http://localhost:8000

Schritt 2: Push-Benachrichtigungslogik schreiben

Wir werden WebSocket verwenden, um die Push-Benachrichtigungsfunktion zu implementieren. WebSocket ist ein Protokoll, das eine Vollduplex-Kommunikation zwischen Client und Server ermöglicht. In FastAPI können wir die Drittanbieterbibliothek fastapi-websocket verwenden, um unserer Anwendung ganz einfach WebSocket-Unterstützung hinzuzufügen. Die Bibliothek kann mit dem folgenden Befehl installiert werden:
rrreee

In main.py importieren wir zunächst die erforderlichen Module: 🎜rrreee🎜Dann erstellen wir eine FastAPI-Anwendung: 🎜rrreee🎜Als nächstes benötigen wir um die Logik von WebSocket zu definieren. Wir erstellen eine Unterklasse von WebSocket und implementieren darin die Push-Benachrichtigungsfunktion: 🎜rrreee🎜In der on_receive-Methode können wir nach Bedarf bestimmte Themen oder Kanäle abonnieren und neue Daten über WebSocket an den Client senden . In FastAPI-Anwendungen können wir PubSubEndpoint verwenden, um die Abonnement- und Veröffentlichungslogik zu verwalten. Die fastapi_websocket_pubsub-Bibliothek kann mit dem folgenden Befehl installiert werden: 🎜rrreee🎜In main.py importieren wir PubSubEndpoint und erstellen eine Instanz: 🎜rrreee🎜Dann übergeben wir den Pubsub Instanz Geben Sie eine Unterklasse von WebSocket an, um die Funktionalität von Push-Benachrichtigungen darin zu nutzen: 🎜rrreee🎜Schritt drei: Erstellen Sie eine Front-End-Seite🎜 Wir müssen auch eine Front-End-Seite erstellen, damit Benutzer über den Browser auf unsere Anwendung zugreifen können. Sie können eine Datei namens index.html erstellen und diese in einem Ordner namens templates ablegen. In index.html können wir WebSocket verwenden, um Push-Benachrichtigungen zu abonnieren und die Seite zu aktualisieren, wenn neue Daten empfangen werden. Hier ist ein einfaches Beispiel: 🎜rrreee🎜 Schritt 4: Starten Sie die Anwendung 🎜 Am Ende von main.py müssen wir den folgenden Code hinzufügen, um die FastAPI-Anwendung zu starten: 🎜rrreee🎜Nun, wir kann verwendet werden. Der folgende Befehl startet unsere FastAPI-Anwendung: 🎜rrreee🎜Fertig! Jetzt können wir über den Browser http://localhost:8000 aufrufen, um die Push-Benachrichtigungsfunktion anzuzeigen. Wenn neue Daten übertragen werden, wird die Seite automatisch aktualisiert, um die neuesten Informationen anzuzeigen. 🎜🎜Fazit: 🎜In diesem Artikel wird erläutert, wie Sie Push-Benachrichtigungen in FastAPI verwenden, um Daten in Echtzeit zu aktualisieren. Durch die Verwendung von WebSocket- und PubSubEndpoint-Bibliotheken können wir Push-Benachrichtigungsfunktionen einfach implementieren. Diese Methode zur Aktualisierung von Daten in Echtzeit kann auf viele Anwendungsszenarien angewendet werden, z. B. auf Echtzeithandel, Echtzeitüberwachung und Echtzeitspiele. Ich hoffe, dass dieser Artikel für Sie hilfreich sein kann, und ich wünsche Ihnen, dass Sie FastAPI verwenden können, um effizientere Webanwendungen in Echtzeit zu erstellen. 🎜

Das obige ist der detaillierte Inhalt vonSo verwenden Sie Push-Benachrichtigungen in FastAPI, um Daten in Echtzeit zu aktualisieren. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!