Python Django.core.exceptions.SynchronousOnlyOperation您不能从异步上下文中调用它请使用线程或SYNC_TO_ASYNC

我正在使用Django频道来实现Web套接字.

我想使用ORM Inside consumers.py获得数据库查询.

这是我的代码:

import json
from channels.generic.websocket import AsyncWebsocketConsumer
from .models import Game
from accounts.models import CustomUser as User
from channels.db import database_sync_to_async


class CameraStreamConsumer(AsyncWebsocketConsumer):

    def __init__(self, *args, **kwargs):
        print("initializing")
        self.counter = 0
        super().__init__(*args, **kwargs)

    async def connect(self):
        await self.accept()
        print("accepted connection")

    async def disconnect(self, close_code):
        pass
        print("disconect connection")
    async def receive(self, text_data=None,):
        print(" iam getting data online")
        data = json.loads(text_data)
        

        if data.get('type') == 'started':

            await self.handle_game_started(data)
        
    
    async def get_game(self, game_id):
        game_obj = await database_sync_to_async(Game.objects.get)(id=game_id)
        return game_obj

    async def get_user(self, user_id):
        user_obj = await database_sync_to_async(User.objects.get)(id=user_id)
        return user_obj
    
    async def handle_game_started(self, data):
        game_id = data.get('game_id')
        user_id = data.get('user_id')
        game_obj = await self.get_game(game_id)
        user_obj = await self.get_user(user_id)
        if game_obj and user_obj:
            game_creator = game_obj.creator
            if game_creator == user_obj:
                print("user is creator")
                await self.send(text_data=json.dumps({'message': f'Game {game_id} Started'}))

我得到了这个错误:

django. core. exceptions. SyncousOnlyOperation:你不能从一个execution上下文调用它—使用一个线程或sync_to_execution.

我也试着

from asgiref.sync import sync_to_async

但我还是得到了同样的错误