您好，我是 Redis 和 Redis 隊列的新手，我正在嘗試使用 Flask-RQ2 庫來執(zhí)行一個函數(shù)，但是當我將我的函數(shù)添加到隊列中時，我的函數(shù)沒有執(zhí)行查看Flask-RQ2它包含一個可調(diào)用的，所以為什么是我的功能未執(zhí)行from flask import Flaskfrom flask_rq2 import RQapp = Flask(__name__)app.config['RQ_REDIS_URL'] = 'redis://127.0.0.1:6379/0'rq = RQ(app)@rq.jobdef foo(a,b): print(a+b) return a + b;@app.route('/')def index(): job = foo.queue(5,9) print(foo.queue(8,8)) return 'Job queued!'if __name__ == "__main__": app.run(port=5000, debug=True)這是 Redis 的輸出1570238667.183464 [0 127.0.0.1:64377] "MULTI"1570238667.183506 [0 127.0.0.1:64377] "SADD" "rq:queues" "rq:queue:default"1570238667.183522 [0 127.0.0.1:64377] "HSET" "rq:job:db248b95-64bd-4300-b562-4781a7136e3c" "status" "queued"1570238667.183547 [0 127.0.0.1:64377] "HMSET" "rq:job:db248b95-64bd-4300-b562-4781a7136e3c" "created_at" "2019-10-05T01:24:27.181463Z" "data" "x\x9ck`\x99*\xc3\x00\x01\x1a=<\xf1\xf1\xb9\x89\x99y\xf1\xf1zi\xf9\xf9S\xfc\xbcY\xbd9\xdb\xa6\xd4N)\x99\xa2\a\x00\xbbl\x0bp" "origin" "default" "description" "__main__.foo(5, 9)" "enqueued_at" "2019-10-05T01:24:27.182076Z" "timeout" "180" "result_ttl" "500" "status" "queued"1570238667.183641 [0 127.0.0.1:64377] "RPUSH" "rq:queue:default" "db248b95-64bd-4300-b562-4781a7136e3c"1570238667.183672 [0 127.0.0.1:64377] "EXEC"
FLASK-RQ2 如何使用作業(yè)裝飾器調(diào)用函數(shù)
慕蓋茨4494581
2022-06-14 15:30:26
