尝试使用 celery beat 在 django 中调度一个函数但给出错误

Posted 2023-02-24

【中文标题】尝试使用 celery beat 在 django 中调度一个函数但给出错误

【英文标题】：Tried scheduling a function in django with celery beat but giving error

【发布时间】：2021-01-12 14:54:44

【问题描述】：

试图在 Django 中安排一个函数 print_hello()。但是代码似乎不起作用。

这是 Django 项目布局。仅给出与 celery 相关的文件。

- celery_test
    - celery_test
        - __init__.py
        - celery.py
        - tasks.py

_init_.py 代码：

from .celery import app as celery_app

__all__ = ('celery_app',)

celery.py 代码：

import os
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'celery_test.settings')

app = Celery('celery_test')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.conf.schedule_beat = 
    'print-hello-every-2-seconds': 
        'task': 'tasks.print_hello',
        'schedule': 2,
    ,

app.autodiscover_tasks()

tasks.py 代码：

from celery import shared_task

@shared_task
def print_hello():
    print("Hello celery...")

运行celery -A celery_test worker -l info后，提示显示如下错误。

 -------------- celery@########## v4.4.7 (cliffs)
--- ***** -----
-- ******* ---- Windows-10-10.0.18362-SP0 2020-09-26 19:03:12
- *** --- * ---
- ** ---------- [config]
- ** ---------- .> app:         celery_test:0x2c34a320eb0
- ** ---------- .> transport:   amqp://guest:**@localhost:5672//
- ** ---------- .> results:     disabled://
- *** --- * --- .> concurrency: 4 (prefork)
-- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker)
--- ***** -----
 -------------- [queues]
                .> celery           exchange=celery(direct) key=celery


[tasks]


[2020-09-26 19:03:13,202: INFO/SpawnPoolWorker-1] child process 4856 calling self.run()
[2020-09-26 19:03:13,202: INFO/SpawnPoolWorker-3] child process 784 calling self.run()
[2020-09-26 19:03:13,211: INFO/SpawnPoolWorker-2] child process 8868 calling self.run()
[2020-09-26 19:03:13,220: INFO/SpawnPoolWorker-4] child process 4064 calling self.run()
[2020-09-26 19:03:14,922: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [WinError 10061] No connection could be made because the target machine actively refused it.
Trying again in 2.00 seconds... (1/100)

[2020-09-26 19:03:18,937: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [WinError 10061] No connection could be made because the target machine actively refused it.
Trying again in 4.00 seconds... (2/100)

安装了以下版本。

django 3.1.1
celery 4.4.7
django-celery-beat 2.0.0

已尝试将 celery 降级到 3.1.15。但是 django-celery-beat 2.0.0 不兼容。

【问题讨论】：

这能回答你的问题吗？ Django Celery - Cannot connect to amqp://guest@127.0.0.8000:5672//

@ArakkalAbu 我有类似的问题。但是并没有通过遵循它来解决我的问题。而是使用 redis 作为代理。

【参考方案1】：

你在运行 RabbitMQ 吗？ - Celery broker（也可以选择使用常用的celery broker Redis）。 RabbitMQ 的默认端口是 5672。

参考看看this 您还可以在上面提到的存储库中找到@shared_task 的用法。

【讨论】：

谢谢。解决了我的问题。第一步：pip install celery[redis] 第二步：下载redis.exe并安装。第 3 步：在 settings.py-CELERY_BROKER_URL = 'redis://localhost:6379/0' BROKER_TRANSPORT = 'redis'

中添加以下行