Asyncio与另一个协同程序同时运行Dash（Flask）服务器

Question

我创建了一个dash应用程序来显示另一个代码正在收集的信息，我希望使用Python中的asyncio模块同时运行这两个应用程序。

我的代码使用异步函数，Dash应用程序（基于Flask）在服务时阻止其他任何东西执行。

我不确定这是否需要打开更多的线程。

这是我当前的代码，它只运行主协程。

async def main():
    some code here...

    while True:
        try:
            await client.handle_message()
        except ConnectionClosedError as error:
            logger.error(error)
    
        for strategy in strategies:
            await asyncio.create_task(...)
            some code here...

async def run_dashboard():
    app = create_app()
    app.run_server('0.0.0.0', 5000, debug=False)


if __name__ == '__main__':
    some code here...

    # Currently just runs the main coroutine
    asyncio.run(main())

如何同时运行main和_dashboard？

Answer 1

在后台线程中运行Run_dashboard。参考文件。

async def run():
    await asyncio.gather(
        asyncio.to_thread(run_dashboard),
        main()
    )

asyncio.run(run())

请注意，asyncio.to_thread是3.9版中的一个新函数。对于早于3.9的python版本，请复制以下代码threads.py。

Answer 2

如果您真的希望它在一个进程中运行，以下方法对我有效：

from functools import partial
from threading import Thread    


partial_run = partial(app.run, host="0.0.0.0", port=5000, debug=True, use_reloader=False)
t = Thread(target=partial_run)
t.start()
asyncio.run(main())

Answer 3

坦率地说，将DASH（烧瓶）与一些异步工作结合在一个过程中是不好的设计，考虑在不同的进程（即应用程序）中运行烧瓶和异步活动。

尽管如此，如果你仍然想在一个进程中运行所有的程序，我可以给你下面的工作示例，请按照评论并询问你是否有任何问题：

from flask import Flask, jsonify
import asyncio
from threading import Thread

# ** Async Part **


async def some_print_task():
    """Some async function"""
    while True:
        await asyncio.sleep(2)
        print("Some Task")


async def another_task():
    """Another async function"""
    while True:
        await asyncio.sleep(3)
        print("Another Task")


async def async_main():
    """Main async function"""
    await asyncio.gather(some_print_task(), another_task())


def async_main_wrapper():
    """Not async Wrapper around async_main to run it as target function of Thread"""
    asyncio.run(async_main())

# *** Flask Part ***:


app = Flask(__name__)


@app.route("/", methods=["GET"])
def index():
    """just some function"""
    return jsonify({"hello": "world"})


if __name__ == '__main__':
    # run all async stuff in another thread
    th = Thread(target=async_main_wrapper)
    th.start()
    # run Flask server
    app.run(host="0.0.0.0", port=9999)
    th.join()