redis celery 不能用红提

njthzxwz  于 2023-04-10  发布在  Redis
关注(0)|答案(2)|浏览(160)

第一次尝试启动Celery,但出现如下错误,我已经安装了redis,它的启动很好,但不知何故django似乎有问题,

File "<frozen importlib._bootstrap_external>", line 848, in exec_module
  File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
  File "/home/atif/Documents/celery_test/celery-env/lib/python3.8/site-packages/kombu/transport/redis.py", line 263, in <module>
    class PrefixedStrictRedis(GlobalKeyPrefixMixin, redis.Redis):
AttributeError: 'NoneType' object has no attribute 'Redis'

Celery.py

from django.conf import settings
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'celery_test.settings')


    app = Celery('celery_test',)
    
    app.config_from_object('django.conf:settings')
    
    # Load task modules from all registered Django apps.
    app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
    
    
    @app.task(bind=True)
    def debug_task(self):
        print(f'Request: {self.request!r}')

设置

#celery stuff ---------------
BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = 'Asia/Kolkata'

celery_module/tasks.py

from celery import Celery

app = Celery('tasks',)

@app.task
def add(x, y):
    return x + y
nr9pn0ug

nr9pn0ug1#

尝试在虚拟环境中安装Redis

pip install Redis
qoefvg9y

qoefvg9y2#

使用全局安装redis

pip install redis

或(如果使用pipenv

在我的例子中,错误发生在运行时没有使用环境中的redis

python -m celery -A *django_app* worker

如果你使用pipenv来管理你的python环境,你可以运行上面的命令:

pipenv run python -m celery -A *django_app* worker

相关问题