Как FLASK-RQ2 вызывает функцию с помощью декоратора задания - PullRequest
0 голосов
/ 04 октября 2019

Здравствуйте, я новичок в Redis и очереди Redis. Я пытаюсь использовать библиотеку Flask-RQ2 для выполнения функции, но моя функция не выполняется, когда я добавляю свою функцию в очередь. Глядя на Flask-RQ2 он включает вызываемый модуль, так почему моя функция не выполняется

from flask import Flask
from flask_rq2 import RQ

app = Flask(__name__)
app.config['RQ_REDIS_URL'] = 'redis://127.0.0.1:6379/0'

rq = RQ(app)


@rq.job
def 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"
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...