gpt4 book ai didi

python - 如何配置和运行 celerybeat

转载 作者:行者123 更新时间:2023-11-28 16:47:59 25 4
gpt4 key购买 nike

我刚开始使用 celery ,尝试运行一个周期性任务。

已配置 *rabbitmq** 添加了 celeryconfig.py。

并在tasks.py中加入如下代码:

from celery.decorators import periodic_task
from datetime import timedelta

@periodic_task(run_every=timedelta(seconds=2))
def every_2_seconds():
print("Running periodic task!")

现在,当我在终端中输入“celerybeat”启动 celerybeat 时,它开始运行并显示以下消息

celerybeat 
celerybeat v3.0.3 (Chiastic Slide) is starting.
__ - ... __ - _
Configuration ->
. broker -> amqp://arnold@localhost:5672//
. loader -> celery.loaders.default.Loader
. scheduler -> celery.beat.PersistentScheduler
. db -> celerybeat-schedule
. logfile -> [stderr]@INFO
. maxinterval -> now (0s)
[2012-08-03 14:24:52,202: INFO/MainProcess] Celerybeat: Starting...

every_2_seconds 方法在终端中没有输出。我假设我必须在 celerybeat 命令期间指定要运行的应用程序或任务。该怎么做?

如何指定任务并在每 2 秒后打印一行作为周期性任务?

谢谢。

最佳答案

CELERY_IMPORTS=("tasks",) 添加到您的 celeryconfig.py,然后运行 ​​celerybeat。

关于python - 如何配置和运行 celerybeat,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/11792101/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com