python redis-queue: простой пример из документации не работает - PullRequest
Новая
       27

python redis-queue: простой пример из документации не работает

0 голосов
/ 01 декабря 2018

У меня есть два файла, буквально скопированные из http://python -rq.org / docs / :

app.py 

    from rq import Queue
    from redis import Redis
    from somewhere import count_words_at_url
    import time

    # Tell RQ what Redis connection to use
    redis_conn = Redis()
    q = Queue(connection=redis_conn)  # no args implies the default queue

    print(redis_conn)
    # Delay execution of count_words_at_url('http://nvie.com')
    job = q.enqueue(count_words_at_url, 'http://nvie.com')
    print(job.result)   # => None

    # Now, wait a while, until the worker is finished
    time.sleep(10)
    print(job.result)   # => 889

where.py 

import requests
def count_words_at_url(url):
    print("hello?")
    resp = requests.get(url)
    return len(resp.text.split())

Я запустил app.py, и я получил 2 значения None, в отличие от 889, которое я должен получить в соответствии с документами.

Я не уверен, что понимаю, почему это происходит.Мой тайм-аут составляет 10 секунд, и он длиннее, чем в документе, поэтому я ожидал, что работа закончится.

Что я делаю не так?

1 Ответ

0 голосов
/ 02 декабря 2018

  1. Работает ли сервер Redis?

    Состояние службы Redis-сервера

  2. Работает ли rq worker?

    rq info

если работающий не работает, то 

rq worker # run this under the same directory of your project
18:44:54 RQ worker 'rq:worker:ubuntu.45276' started, version 0.12.0
18:44:54 *** Listening on default...
18:44:54 Cleaning registries for queue: default

заменить count_words_at_url на более простую функцию, такую ​​как

def just_mock (url): time.sleep (5) вернуть "количество слов для {} is ??". Формат (url)

...