Планировщик RQ генерирует исключение NoRedisConnectionException - PullRequest
Новая
       29

Планировщик RQ генерирует исключение NoRedisConnectionException

0 голосов
/ 28 мая 2018

Я создаю приложение и пытаюсь настроить запланированные задачи с помощью Redis / python-rq / rq-scheduler.

Я могу настроить очередь просто отлично, например так: 

from redis import Redis
from rq import Queue

rq = Queue(connection=Redis(host=BaseConfig.REDIS_HOST, port=BaseConfig.REDIS_PORT))

def hello_world():
    print("hello world")

@app.route("/queue/test", method=["GET", "POST"])
def test_queue():
    job = rq.enqueue_call(func=hello_world)
    return jsonify(job_id=job.id())

Но теперь, когда я пытаюсь настроить запланированное задание, согласно документации здесь ссылка .Вот так: 

from datetime import timedelta

from redis import Redis
from rq import Queue
from rq_scheduler import Scheduler

rq = Queue(connection=Redis(host=BaseConfig.REDIS_HOST, port=BaseConfig.REDIS_PORT))
rqs = Scheduler(queue=rq)

def hello_world():
    print("hello world")

@app.route("/queue/test", method=["GET", "POST"])
def test_queue():
    job = rqs.enqueue_in(timedelta(seconds=30), func=hello_world)
    return jsonify(job_id=job.id())

Я получаю 

raise NoRedisConnectionException('Could not resolve a Redis connection')                                                                                                                                                                   
rq.connections.NoRedisConnectionException: Could not resolve a Redis connection

Буду признателен за любую помощь.Спасибо.

...