Flask非同步操作例項

後端**如下：

from concurrent.futures import threadpoolexecutor

'/upload_file'
, methods=
['post'])
defmain()
: executor = threadpoolexecutor(1)
### 引數表示最大的執行緒數
executor.submit(test, args)
#其中test為非同步函式,args為非同步函式的引數
return
'ok'

def

test
(args)
:'''
非同步執行函式
'''from config import config
from flask import flask
from flask_sqlalchemy import sqlalchemy
"report"
)'test'])
...#這裡即可對資料庫進行增刪改查操作

class

testconfig
(config)
:"""
設定多資料庫訪問，預設訪問sqlalchemy_database_uri的資料庫
在建資料表模型的時候指定__bind_key__ = 'test'時，則表會被建到report的資料庫中
"""debug =
true
# sqlalchemy_echo = true
# sqlalchemy_commit_on_teardown = true
celery_broker_url =
'redis://localhost:6379/0'
celery_backend_url =
'redis://localhost:6379/0'
sqlalchemy_database_uri =
"mysql+pymysql://root:123456@localhost:3306/database"
sqlalchemy_binds =
config =

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

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

flask實現非同步任務

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

flask開啟非同步任務

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