Python Reddis Queue ValueError:Fungsi dari modul __main__ tidak dapat diproses oleh pekerja

Bagi kode yang diberikan menjadi dua file:count_words.py :

import requests

def count_words_at_url(url):
    resp = requests.get(url)
    return len(resp.text.split())

dan main.py (di mana Anda akan mengimpor fungsi yang diperlukan):

from rq import Connection, Queue
from redis import Redis
from count_words import count_words_at_url # added import!
redis_conn = Redis()
q = Queue(connection=redis_conn)
job = q.enqueue(count_words_at_url, 'http://nvie.com')
print job

Saya selalu memisahkan tugas dari logika yang menjalankan tugas tersebut ke file yang berbeda. Itu hanya organisasi yang lebih baik. Perhatikan juga bahwa Anda dapat menentukan kelas tugas dan mengimpor/menjadwalkan tugas dari kelas itu alih-alih struktur (yang terlalu disederhanakan) yang saya sarankan di atas. Ini akan membuat Anda maju.. Juga lihat di sini untuk mengonfirmasi bahwa Anda bukan orang pertama yang kesulitan dengan contoh ini. RQ bagus setelah Anda menguasainya.