最近在開發同步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...