KeyError: 'Session not found' #1213
Replies: 4 comments 22 replies
-
|
On my windows PC its working |
Beta Was this translation helpful? Give feedback.
-
Beta Was this translation helpful? Give feedback.
-
|
The code that you provided is incomplete, so I cannot debug it. I need a complete server and a complete client. As a side note, I do not know what |
Beta Was this translation helpful? Give feedback.
-
|
Can I contact you via messengers? It's just that the code is private |
Beta Was this translation helpful? Give feedback.
-
|
I don't want your real code, I want a simplified version that shows how to reproduce this issue. In a lot of cases working on the simplified example will lead you to discover the issue on your own. |
Beta Was this translation helpful? Give feedback.
-
|
Just the same, I gave a simplified example above and it works, but the real code does not. There are no cardinal differences. The situation is specific, I repeat, it works on WINDOWS, not on LINUX (Debian 11) (I'm talking about the real code, the example works on both systems) |
Beta Was this translation helpful? Give feedback.
-
|
When I say "simplified" I do not mean that you write something new and hope for the best. What I mean is that you start from your real code and start removing things until the project is simple enough that it can be shared completely. |
Beta Was this translation helpful? Give feedback.
-
|
Example from real code: #auth_handler.py
import logging
from fastapi.encoders import jsonable_encoder
from app.auth import sms
from app.auth.exceptions import SMSCodeSendError
from app.auth.models.limits import Limit
from app.auth.utils.sms_api import SMSBaseException
from app.main import sio
from app.ws.models import WSResponse
logger = logging.getLogger("gunicorn.error")
async def on_auth(sid, data: dict) -> dict:
logger.info(sid)
session: dict = await sio.get_session(sid)
if not session: await sio.save_session(sid, {})
if not data.get("phone"):
return jsonable_encoder(
WSResponse(
status=400,
type="error",
data={"details": "Incorrect data"}
)
)
if "token" in session:
return jsonable_encoder(
WSResponse(
status=403,
type="error",
data={"details": "You are already logged in"}
)
)
if not session.get("can_send", True):
return jsonable_encoder(
WSResponse(
status=403,
type="error",
data={"details": "You cannot resend the code using this function. Use auth_retry!"}
)
)
try:
code = await sms.send_code(data["phone"])
except SMSBaseException as e:
return jsonable_encoder(
WSResponse(
status=503,
type="error",
data={"details": f"SMS Service Error. {str(e)}"}
)
)
except SMSCodeSendError:
return jsonable_encoder(
WSResponse(
status=403,
type="error",
data={"details": "You cannot resend the code using this function. Use auth_retry!"}
)
)
await sio.save_session(sid, {"phone": data["phone"], "can_send": False})
limit = Limit(phone=data["phone"])
await limit.create()
return jsonable_encoder(
WSResponse(
status=200,
type="auth",
data=code
)
)#base_handler.py
from app.auth import tokens
from app.main import logger, sio
from app.ws.models import WSResponse
async def on_connect(sid, data: dict, auth: dict = None):
logger.info(f"Session: {sid} connected")
print(f"Session: {sid} connected")
logger.info(f"{sio.namespaces=}, {sio.namespace_handlers}")
#logger.info(f"EID: {sio.manager.eio_sid_from_sid(sid, '/')}")
#logger.info(f"EIO Sessions: {sio.eio.sockets}")
#logger.info(await sio.eio.get_session(sio.manager.eio_sid_from_sid(sid, '/')))
print(sio.eio.sockets)
if auth and not auth.get("token"):
await sio.emit(
"auth",
WSResponse(
status=400,
type="error",
data={"details": "Incorrect auth! "
"If you are logging in for the first time, log in using the auth method"}
).dict(),
to=sid
)
return
if auth:
auth_data = await tokens.authenticate(auth["token"])
if not auth_data:
await sio.emit(
"auth",
WSResponse(
status=403,
type="error",
data={"details": "Invalid token!"}
).dict(),
to=sid
)
return
sio.enter_room(sid, room=auth_data["user"].id)
await sio.save_session(sid, {"token": auth["token"], "phone": auth_data["user"].phone, "can_send": False})
logger.info(f"Session {sid} authenticated")
await sio.emit(
"auth",
WSResponse(
status=200,
type="info",
data=auth_data
).dict(),
to=sid
)
async def on_disconnect(sid):
logger.info(f"Session {sid} disconnected")#main.py
import asyncio
import importlib
import logging
import os
import sys
from inspect import getmembers, isfunction
from apscheduler.schedulers.asyncio import AsyncIOScheduler
from apscheduler.triggers.interval import IntervalTrigger
from fastapi import FastAPI
import socketio
import app.auth.sms as sms
import app.database as db
from app.admin.statistic.user import router as user_stat_router
from app.auth.models.auth import Tokens
from app.auth.models.limits import Limit
from app.auth.models.user import User, UserAuthCode
from app.chat.models import Message
from app.payments.models import Tariff, Order
from app.payments.router import router as payment_router
app = FastAPI()
sio = socketio.AsyncServer(async_mode="asgi", cors_allowed_origins="*")
sio_app = socketio.ASGIApp(sio, other_asgi_app=app)
app.mount("/ws", sio_app)
logger = logging.getLogger("gunicorn.error")
app.include_router(user_stat_router)
app.include_router(payment_router)
for root, dirs, files in os.walk("ws"):
for file in files:
if file.split('_')[-1][:-3] == "handler":
module = importlib.import_module(root.replace("/", ".") + '.' + file[:-3])
for handler in getmembers(module, isfunction):
if not handler[0].startswith("on_"): continue
sio.on(event=handler[0][3:], handler=handler[1])
@app.on_event("startup")
async def startup():
if sys.platform == "win32": asyncio.set_event_loop(asyncio.ProactorEventLoop())
await db.init_db([UserAuthCode, User, Message, Tokens, Limit, Tariff, Order])
scheduler = AsyncIOScheduler()
scheduler.add_job(sms.check_codes, trigger=IntervalTrigger(seconds=5))
scheduler.add_job(sms.check_limit, trigger=IntervalTrigger(seconds=5))
scheduler.start() |
Beta Was this translation helpful? Give feedback.
-
|
As I said before, I can't see anything wrong with your code. That doesn't mean that the code is correct, just that from looking at it I cannot tell what's wrong. |
Beta Was this translation helpful? Give feedback.
-
|
I conducted an experiment and wrote connecthandler in main.py , no KeyError error occurred, the session and sid were preserved. The problem seems to be in the import system, although everything is done according to the documentation. #main.py
. . .
@sio.on("connect")
async def connect(sid, *_, **__):
print(f"{sid=}")
print(await sio.get_session(sid)) <-- Its working
. . . |
Beta Was this translation helpful? Give feedback.
-
|
It turns out very interesting. Here is an example output from #main.py
. . .
logger.info(sio.namespaces)
logger.info(sio.manager.rooms)
logger.info(sio.eio.sockets)
. . .
'''
Output:
[2023-07-13 23:21:21 +0300] [1978] [INFO] ['/']
[2023-07-13 23:21:21 +0300] [1978] [INFO] {'/': {None: bidict({'M-z4T2HyPbvsYyRuAAAD': '3SokT9sETCR2CNogAAAC'}), 'M-z4T2HyPbvsYyRuAAAD': bidict({'M-z4T2HyPbvsYyRuAAAD': '3SokT9sETCR2CNogAAAC'})}}
[2023-07-13 23:21:21 +0300] [1978] [INFO] {'3SokT9sETCR2CNogAAAC': <engineio.asyncio_socket.AsyncSocket object at 0x7f911ee11510>}
'''#auth_handler.py
. . .
logger.info(sio.namespaces)
logger.info(sio.manager.rooms)
logger.info(sio.eio.sockets)
. . .
'''
Output:
[2023-07-13 23:21:24 +0300] [1978] [INFO] ['/']
[2023-07-13 23:21:24 +0300] [1978] [INFO] {}
[2023-07-13 23:21:24 +0300] [1978] [INFO] {}
''' |
Beta Was this translation helpful? Give feedback.
-
|
Could you be printing two different objects here? It does not look like this is the same object printed in two different places, right? |
Beta Was this translation helpful? Give feedback.
-
|
Yes, you're right. These are different objects, but how could this happen if there is only one ad? #main.py
sio = socketio.AsyncServer()
. . .
logger.info(id(sio)) -> 140026598352912
. . .#auth_handler.py
from main import sio
. . .
logger.info(id(sio)) -> 140026598649744
. . . |
Beta Was this translation helpful? Give feedback.
-
|
The problem is solved, I just put the sio declaration in a separate file #server.py
import socketio
sio = socketio.AsyncServer()#main.py
from server import sio
for root, dirs, files in os.walk("ws"):
for file in files:
if file.split('_')[-1][:-3] == "handler":
module = importlib.import_module(root.replace("/", ".") + '.' + file[:-3])
for handler in getmembers(module, isfunction):
if not handler[0].startswith("on_"): continue
sio.on(event=handler[0][3:], handler=handler[1])#auth_handler.py
from server import sio
async def on_auth(sid, data):
. . . |
Beta Was this translation helpful? Give feedback.
-
Hello. I have error:
This is a very strange behavior, because other methods that do not use get_session and save_session work
I running on: Linux, Gunicorn, Nginx Proxy
Gunicorn:
Nginx:
Beta Was this translation helpful? Give feedback.
All reactions