namespace

app.py

@@ -1,4 +1,4 @@
-from flask import Flask, request, render_template, send_file, jsonify, send_from_directory
+from flask import Flask, request, render_template, send_file, jsonify, send_from_directory, session
 from flask_socketio import SocketIO, join_room, leave_room, close_room, rooms, disconnect
 from flask_cors import CORS
 from flask_limiter import Limiter
@@ -59,7 +59,7 @@ def update_queue_status(message):
 
 def process_task(task):
     try:
-        client_id = request.sid
+        client_id = session.get("sid")
         task.is_processing = True
         # ファイルデータをPIL Imageに変換
         image = Image.open(io.BytesIO(task.file_data))
@@ -118,6 +118,7 @@ connected_clients = 0
 tasks_per_client = {}
 @socketio.on('connect', namespace='/')
 def handle_connect(auth):
+    session["sid"] = request.sid
     client_id = request.sid  # クライアントIDを取得
     join_room(client_id)  # クライアントを自身のルームに入れる
     global connected_clients
@@ -148,7 +149,7 @@ def submit_task():
 
     # クライアントIPアドレスを取得
     client_ip = get_remote_address()
-    client_id = request.sid  # クライアントIDを取得
+    client_id = session.get("sid")
     
     # 同一IPからの同時タスク数を制限
     if tasks_per_client.get(client_ip, 0) >= 2: