提前谢谢，我正试着用芹菜块做一小块家常菜。我无法解决我的问题，我已经花了4个小时想弄清楚出了什么问题，但我说不出来。今天早上一切都很好，但现在我在提交表格时面临着无限负荷。
首先，我在arch上，使用每个包的最后一个版本，这是我从终端收到的代码和消息：
配置：
demo/settings/base.py:
INSTALLED_APPS = [
'users.apps.UsersConfig',
'django.contrib.admin',
'django.contrib.auth',
'django.contrib.contenttypes',
'django.contrib.sessions',
'django.contrib.messages',
'django.contrib.staticfiles',
'core',
'books',
'django_celery_results',]
CELERY_RESULT_BACKEND = 'django-db'
CELERY_BROKER_URL = f'redis://{config("REDIS_HOST")}:{config("REDIS_PORT")}/{config("REDIS_CELERY_DB")}'
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.sqlite3',
'NAME': os.path.join(BASE_DIR, 'db_celery__.sqlite3'),
}
}
.env:
REDIS_HOST=localhost
REDIS_PORT=6379
REDIS_CELERY_DB=0
我的模型书籍/模型：
from django.db import models
from PIL import Image
from django import forms
from demo import tasks
def resize_model(booquin):
img = Image.open(bouquin.cover.path)
if img.height > 300 or img.width > 300:
output_size = (300, 300)
img.thumbnail(output_size)
img.save(bouquin.cover.path)
bouquin.save()
class Bouquin(models.Model):
titre = models.CharField(max_length=200)
cover = models.ImageField(upload_to="cover")
def __str__(self):
return self.titre
class Bouquin_Form(forms.ModelForm):
def save(self, commit=True):
book = super().save(commit)
tasks.resize_book_celery.apply_async((book.id,))
return book
class Meta:
model = Bouquin
fields = ["titre", "cover"]
我的demo/tasks.py(我把模型和f表单混合在同一个文件中，因为这只是为了测试目的(
from celery import shared_task
from books import models
@shared_task
def resize_book_celery(book_id: int):
models.resize_model(models.Bouquin.objects.get(id=book_id))
我的演示/celery.py：
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'demo.settings.base')
app = Celery('demo')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()
最后是我的观点：books/views.py
from django.shortcuts import render, reverse, redirect
from .models import Bouquin, Bouquin_Form
from django.contrib import messages
def create_book(request):
book_listing = Bouquin.objects.all()
if request.method == 'POST':
form = Bouquin_Form(request.POST, request.FILES)
if form.is_valid():
form.save()
return redirect("create-book")
else:
form = Bouquin_Form()
context = {"book_listing": book_listing, "form": form}
return render(request, "demo/book_listing.html", context)
我在shell中运行的内容：(sudo systemctl start redis(然后celeb-一个演示工作者-l debug
输出：
-------------- celery@laptop v4.4.6 (cliffs)
--- ***** -----
-- ******* ---- Linux-5.7.9-arch1-1-x86_64-with-glibc2.2.5 2020-07-20 17:23:51
- *** --- * ---
- ** ---------- [config]
- ** ---------- .> app: demo:0x7f0d73fd67c0
- ** ---------- .> transport: redis://localhost:6379/0
- ** ---------- .> results: disabled://
- *** --- * --- .> concurrency: 4 (prefork)
-- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker)
--- ***** -----
-------------- [queues]
.> celery exchange=celery(direct) key=celery
芹菜花-演示
[I 200720 17:26:27 command:138] Visit me at http://localhost:5555
[I 200720 17:26:27 command:145] Broker: redis://localhost:6379/0
[I 200720 17:26:27 command:146] Registered tasks:
['celery.accumulate',
'celery.backend_cleanup',
'celery.chain',
'celery.chord',
'celery.chord_unlock',
'celery.chunks',
'celery.group',
'celery.map',
'celery.starmap',
'demo.tasks.resize_book_celery']
当我提交表格时，我收到了一条无休止的加载错误消息，在flower的仪表板上什么都没有得到。今天早上它运行得很好，我最初以为我在保存时把代码搞砸了，但我在不同的虚拟环境中从头开始重写了两次，得到了相同的结果，我还从arch存储库重新安装了redis。由于我对celener/redis了解不多，我当时认为有一些任务在队列中等待阻止其他任务，所以我键入了一些命令来清除，但没有任何帮助，如果你有线索，请提前感谢！！
我已经用这样一个超基本的函数进行了测试：
@task
def time_celery(x):
return x ** 2
defmultiplication_view(请求(：
result = time_celery.delay(2) context = {"result": result} return render(request, "demo/multiplications.html", context)
我得到了同样的无休止的加载，所以我认为redis肯定有问题，我想我会把我的计算机恢复到今天早上抛出的rsync 状态
切换到rabbitmq，它似乎完美地工作，cele_BROKER_URL='amqp://localhost'+像这里解释的那样启用服务器https://wiki.archlinux.org/index.php/RabbitMQ#Installation
要删除所有Redis数据库的所有数据/键，请使用FLUSALL命令。开放式终端和类型
redis-cli FLUSHALL
我认为这个问题是针对redis的。