так как в джанго вебсокеты работали в последний раз в 2017, а сейчас нивкакую не работают, я решил обьеденить fastapi и django.
таким образом запуская 2 сервака у меня на странице сайта нормально работает вебсокет.
протестировав вебсокет с передачей рандомных чисел, всё заработало, но потом я решил добавить проверку на пользователя джанго.
импортировав настройки джанго, я запустил приложение, но когда захожу на сайт то в сервере fasapi получаю ошибку:
ERROR: Exception in ASGI application
Traceback (most recent call last):
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\uvicorn\protocols\websockets\websockets_impl.py", line 247, in run_asgi
result = await self.app(self.scope, self.asgi_receive, self.asgi_send)
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\uvicorn\middleware\proxy_headers.py", line 84, in __call__
return await self.app(scope, receive, send)
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\fastapi\applications.py", line 289, in __call__
await super().__call__(scope, receive, send)
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\starlette\applications.py", line 122, in __call__
await self.middleware_stack(scope, receive, send)
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\starlette\middleware\errors.py", line 149, in __call__
await self.app(scope, receive, send)
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\starlette\middleware\exceptions.py", line 79, in __call__
raise exc
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\starlette\middleware\exceptions.py", line 68, in __call__
await self.app(scope, receive, sender)
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\fastapi\middleware\asyncexitstack.py", line 20, in __call__
raise e
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\fastapi\middleware\asyncexitstack.py", line 17, in __call__
await self.app(scope, receive, send)
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\starlette\routing.py", line 718, in __call__
await route.handle(scope, receive, send)
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\starlette\routing.py", line 341, in handle
await self.app(scope, receive, send)
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\starlette\routing.py", line 82, in app
await func(session)
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\fastapi\routing.py", line 324, in app
await dependant.call(**values)
File "G:\RyanovskY\scripts_for_work\virtuoz_project\virtuoz\fastserv.py", line 30, in websocket_endpoint
user = websocket.user
File "C:\Users\Ryan\AppData\Roaming\Python\Python39\site-packages\starlette\requests.py", line 161, in user
assert (
AssertionError: AuthenticationMiddleware must be installed to access request.user
вот само приложение
# fastserv.py
import os
import django
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "virtuoz.settings")
django.setup()
from django.db.models import Q
from main.models import Chat
import asyncio
import requests
import random
import uvicorn
from fastapi import FastAPI, Request
from fastapi import WebSocket
from fastapi.templating import Jinja2Templates
app = FastAPI()
templates = Jinja2Templates(directory="templates")
async def generate_random_numbers(websocket: WebSocket):
while True:
await asyncio.sleep(0.25)
await websocket.send_text(str(random.randint(1, 1000)))
@app.websocket("/ws/random_numbers/")
async def websocket_endpoint(websocket: WebSocket):
await websocket.accept()
user = websocket.user
if user and user.is_authenticated:
print(user)
unread_messages_count = 0
user_chats = Chat.objects.filter(Q(user=user) | Q(with_user=user))
for chat in user_chats:
unread_messages_count += chat.messages.filter(~Q(sender=websocket.user.id), status='False').count()
null = 0
await generate_random_numbers(websocket)
else:
await websocket.close(code=1011)
def get_public_ip():
response = requests.get('https://api.ipify.org?format=json')
if response.status_code == 200:
data = response.json()
return data['ip']
return None
app_str = "fastserv:app"
public_ip = get_public_ip()
host = '0.0.0.0'
port = 5010
if __name__ == '__main__':
print(f"http://{public_ip}:{port}/")
uvicorn.run(app_str, host=host, port=port, log_level="warning", workers=2)
не знаю как решить эту проблему, помогите пожалуйста.
кроме этой страницы fastapi ничего не делал.
