flask實現非同步任務

2021-08-28 13:57:17 字數 503 閱讀 4817

最近在開發同步mysql資料到redis的介面,因為資料同步涉及各種增刪查改,如果用同步實現,可能回造成連線超時、堵塞,所以,使用python實現非同步任務。

from flask import flask

import time

from concurrent.futures import threadpoolexecutor

executor = threadpoolexecutor(1)

def update_redis():

executor.submit(do_update)

return 'ok'

def do_update():

time.sleep(3)

print('start update')

if __name__ == '__main__':

這樣便能快速告訴介面呼叫者你已經知道需要同步資料,同時在後台進行所需要的操作,不至於因為等待而造成的無謂的阻塞以及超時

flask非同步操作 flask實現非同步任務

最近在開發同步mysql資料到redis的介面,因為資料同步涉及各種增刪查改,如果用同步實現,可能回造成連線超時 堵塞,所以,使用python實現非同步任務。實現 from flask import flask import time from concurrent.futures import t...

flask開啟非同步任務

from concurrent.futures import threadpoolexecutor executor threadpoolexecutor max workers 5 deffunc1 引數1 引數2 需要非同步的函式 pass defview executor.submit fun...

flask 實現非同步非阻塞 gevent

我們都知道,flask不支援非同步非阻塞的請求,我們可以建立乙個新專案去測試一下,推薦大家使用pycharm去開發我們的flask 使用特別的方便。rom flask import flask import time def hello world time.sleep 10 return hell...