问题描述
尝试使用异步和并发优化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 (将#修改为@)