在一个文件中运行两个事件循环

问题描述 投票:0回答:1

我创建了一个网络应用程序,它有两个事件循环。一个用于实际的 Web 应用程序(我使用 Quart 微框架制作),另一个用于 Discord 机器人。

因为我正在运行两个事件循环,所以我为 Discord 机器人创建了一个线程。

当我使用 Python 解释器运行该应用程序时,该应用程序工作正常,但当我使用 Uvicorn 运行 Quart 应用程序时,该应用程序无法工作。

# Application.py
 
import os
import sys
import quart
from quart_discord import DiscordOAuth2Session
from Database import InformationLogManager
from Bot import Main
import threading
import asyncio
import typelog
 
os.environ['OAUTHLIB_INSECURE_TRANSPORT'] = '1'
 
GUILD_ID = 1208428835960520734
ROLE_ID = 1208433206215315558
 
Application = quart.Quart('888KingBotDashboard')
InformationLogManager = InformationLogManager.InformationLogManager() # this is a database
Logger = typelog.get_logger(__name__)
 
Application.config["SECRET_KEY"] = "thebigchickens"
Application.config["DISCORD_CLIENT_ID"] = '1208431980954525746'
Application.config["DISCORD_CLIENT_SECRET"] = 'ghvM9A2128vrz9vEzXrvOxp1ff28FIEC'
Application.config["DISCORD_REDIRECT_URI"] = "http://localhost:8080/callback"
 
DiscordOAuth2Session = DiscordOAuth2Session(Application)
 
@Application.before_serving
async def BeforeFirstRequest():
    BotThread = threading.Thread(target=Main.RunBot) # Runs the Discord bot.
    BotThread.start()
 
@Application.route('/')
async def index():
    return await quart.render_template('index.html')
 
@Application.route('/login')
async def Login():
    return await DiscordOAuth2Session.create_session()
 
@Application.route('/callback')
async def callback():
    try:
        await DiscordOAuth2Session.callback()
    except Exception:
        return quart.redirect(quart.url_for("login"))
 
    User = await DiscordOAuth2Session.fetch_user()
    print(User)
    return await quart.render_template('logged_in_success.html', User = User)
 
@Application.route('/dashboard')
async def dashboard():
    for Guild in await DiscordOAuth2Session.fetch_guilds():
        if Guild.id == GUILD_ID:
            User = await DiscordOAuth2Session.fetch_user()
            if await Main.CheckForRole(GuildId = GUILD_ID, RoleId = ROLE_ID, UserId = User.id):
                InformationLogManager.LogInformation(
                    DiscordUserId = User.id,
                    IPAddress = quart.request.remote_addr,
                    Email = User.email
                )
                return await quart.render_template("dashboard.html", User = User)
            else:
                break
        else:
            continue
    return await quart.render_template("access_denied.html"), 401
Exception in thread Thread-1 (RunBot):
Traceback (most recent call last):
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\disnake\client.py", line 1116, in run
Exception in callback Future.set_result(True)
handle: <TimerHandle when=527018.265 Future.set_result(True)>
Traceback (most recent call last):
  File "C:\Users\junej\AppData\Local\Programs\Python\Python310\lib\asyncio\events.py", line 80, in _run
    self._context.run(self._callback, *self._args)
asyncio.exceptions.InvalidStateError: invalid state
    loop.run_forever()
  File "C:\Users\junej\AppData\Local\Programs\Python\Python310\lib\asyncio\windows_events.py", line 319, in run_forever
INFO:     ASGI 'lifespan' protocol appears unsupported.
    assert self._self_reading_future is None
AssertionError
 
During handling of the above exception, another exception occurred:
 
Traceback (most recent call last):
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\disnake\client.py", line 133, in _cleanup_loop
    _cancel_tasks(loop)
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\disnake\client.py", line 115, in _cancel_tasks
    loop.run_until_complete(asyncio.gather(*tasks, return_exceptions=True))
  File "C:\Users\junej\AppData\Local\Programs\Python\Python310\lib\asyncio\base_events.py", line 617, in run_until_complete
    self._check_running()
  File "C:\Users\junej\AppData\Local\Programs\Python\Python310\lib\asyncio\base_events.py", line 577, in _check_running
asyncio.exceptions.CancelledError
 
During handling of the above exception, another exception occurred:
 
Traceback (most recent call last):
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\uvicorn\server.py", line 79, in serve
    await self.startup(sockets=sockets)
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\uvicorn\server.py", line 161, in startup
    server = await loop.create_server(
  File "C:\Users\junej\AppData\Local\Programs\Python\Python310\lib\asyncio\base_events.py", line 1459, in create_server
    infos = await tasks.gather(*fs)
asyncio.exceptions.CancelledError
 
During handling of the above exception, another exception occurred:
 
Traceback (most recent call last):
  File "C:\Users\junej\AppData\Local\Programs\Python\Python310\lib\runpy.py", line 196, in _run_module_as_main
    return _run_code(code, main_globals, None,
  File "C:\Users\junej\AppData\Local\Programs\Python\Python310\lib\runpy.py", line 86, in _run_code
    exec(code, run_globals)
  File "C:\Users\junej\dev\888BotRestructure\venv\Scripts\uvicorn.exe\__main__.py", line 7, in <module>
    sys.exit(main())
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\click\core.py", line 1157, in __call__
    return self.main(*args, **kwargs)
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\click\core.py", line 1078, in main
    rv = self.invoke(ctx)
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\click\core.py", line 1434, in invoke
    return ctx.invoke(self.callback, **ctx.params)
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\click\core.py", line 783, in invoke
    return __callback(*args, **kwargs)
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\uvicorn\main.py", line 418, in main
    run(
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\uvicorn\main.py", line 587, in run
    server.run()
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\uvicorn\server.py", line 62, in run
    Client.run("MTIwODQzMTk4MDk1NDUyNTc0Ng.GJL1Ys.WJk760ouaguhQ818OJMu8z9GvKDOzFAA0pBxuk")
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\disnake\client.py", line 1122, in run
    _cleanup_loop(loop)
  File "C:\Users\junej\dev\888BotRestructure\venv\lib\site-packages\disnake\client.py", line 137, in _cleanup_loop
    loop.close()
  File "C:\Users\junej\AppData\Local\Programs\Python\Python310\lib\asyncio\proactor_events.py", line 676, in close
    raise RuntimeError("Cannot close a running event loop")
RuntimeError: Cannot close a running event loop
 
python flask discord uvicorn quart
1个回答
0
投票

更新,我解决了问题。

本质上我所做的是使用

asyncio.get_event_loop
来获取由 Uvicorn 服务器生成的当前事件循环。这返回了一个
ProactorEventLoop
对象,然后我使用它的
create_task
方法来运行机器人。

这是我所做的更新:

ApplicationEventLoop: asyncio.windows_events.ProactorEventLoop = asyncio.get_event_loop() 
ApplicationEventLoop.create_task(Main.RunBot())
© www.soinside.com 2019 - 2024. All rights reserved.