在Python flask中尝试异步和并发-这是正确的方法吗?

问题描述

尝试使用异步和并发优化Webhook-理想情况下,应该是每次接收到Webhook警报时都创建一个线程/进程/任务,并且该线程应能够同时处理来自多个用户的警报。应用

我试图添加asyncio和并发,不知道它是否正确,因为我在运行时无法调用异步应用程序,该如何测试呢?

    from flask import Flask,request,abort
    import actions,auth,flask,ast,threading,time,asyncio
    from concurrent.futures import ThreadPoolExecutor
    executor = ThreadPoolExecutor(5)

    app = Flask(__name__)
    @app.route('/')
    def root():
    return 'online'

    @app.route('/webhook',methods=['POST'])
    async def webhook():
       executor.request = app.current_request
       try:
    def run_loop():
        app_print.run()
        
        print("Task #1 started!")
        sleep(10)
        print("Task #1 is done!")

    time.sleep(1)
    app_print.disconnect()
        except:
    traceback.print_exc(file=sys.stdout)    
        return '',200

    if __name__ == '__main__':
        app.run()

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)