rq_redis_queue_async_function_enqueue_quickstart.py

1import requests
2from redis import Redis
3from rq import Queue
4
5# 1. Setup the connection and the queue
6redis_conn = Redis()
7q = Queue(connection=redis_conn)
8
9# 2. Define the function you want to run asynchronously
10def count_words_at_url(url):
11    resp = requests.get(url)
12    return len(resp.text.split())
13
14# 3. Enqueue the function call
15job = q.enqueue(count_words_at_url, 'http://nvie.com')
16
17# 4. Check the results (usually done later)
18print(job.result)   # => None (the job has not finished yet)
19
20# To see the result, you must wait for the worker to finish:
21# import time
22# time.sleep(2)
23# print(job.result)