安排任务在特定时间每天运行一次|芹菜

发布于 2025-01-30 04:05:23 字数 683 浏览 3 评论 0原文

以16H UTC 每天运行两个任务

我想安排

from celery.schedules import crontab


CELERY_IMPORTS = ('api.tasks')
CELERY_TASK_RESULT_EXPIRES = 30
CELERY_TIMEZONE = 'UTC'

CELERYBEAT_SCHEDULE = {
    'book-task': {
        'task': 'api.tasks.get_data',
        # At 16h UTC everyday
        'schedule': crontab(hour=16),
        'args': ({'book'}),
    },
    'pencils-task': {
        'task': 'api.tasks.get_data',
        # At 16h UTC everyday
        'schedule': crontab(hour=16),
        'args': ({'pencil'}),
    }
}

。 -pool = Solo 在运行芹菜节拍-A app.celery启动芹菜节目后运行芹菜工人。

使用上面的配置，我每分钟开始执行两个任务，从16H UTC开始。我的配置有什么问题以及如何修复？

原文

I want to schedule running two tasks at 16h UTC once per day.

To do so, I've implemented this celery config:

from celery.schedules import crontab


CELERY_IMPORTS = ('api.tasks')
CELERY_TASK_RESULT_EXPIRES = 30
CELERY_TIMEZONE = 'UTC'

CELERYBEAT_SCHEDULE = {
    'book-task': {
        'task': 'api.tasks.get_data',
        # At 16h UTC everyday
        'schedule': crontab(hour=16),
        'args': ({'book'}),
    },
    'pencils-task': {
        'task': 'api.tasks.get_data',
        # At 16h UTC everyday
        'schedule': crontab(hour=16),
        'args': ({'pencil'}),
    }
}

I run celery worker -A app.celery --loglevel=info --pool=solo to run the celery worker after running celery beat -A app.celery to launch celery beat.

With the config above, I have my two tasks running every minute starting 16h UTC. What is wrong with my config and how to fix ?

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

你穿错了嫁妆 2025-02-06 04:05:23

您需要在crontab中指定minute，而不是通过minute表示使用默认值*使用每分钟运行该作业。

通过minute = 0在小时开始时运行

from celery.schedules import crontab


CELERY_IMPORTS = ('api.tasks')
CELERY_TASK_RESULT_EXPIRES = 30
CELERY_TIMEZONE = 'UTC'

CELERYBEAT_SCHEDULE = {
    'book-task': {
        'task': 'api.tasks.get_data',
        # At 16h UTC everyday
        'schedule': crontab(minute=0, hour=16),
        'args': ({'book'}),
    },
    'pencils-task': {
        'task': 'api.tasks.get_data',
        # At 16h UTC everyday
        'schedule': crontab(minute=0, hour=16),
        'args': ({'pencil'}),
    }
}

You need to specify minute in your crontab, not passing minute means the default value * is used which runs the job every minute.

Pass minute=0 to run at the start of the hour

from celery.schedules import crontab


CELERY_IMPORTS = ('api.tasks')
CELERY_TASK_RESULT_EXPIRES = 30
CELERY_TIMEZONE = 'UTC'

CELERYBEAT_SCHEDULE = {
    'book-task': {
        'task': 'api.tasks.get_data',
        # At 16h UTC everyday
        'schedule': crontab(minute=0, hour=16),
        'args': ({'book'}),
    },
    'pencils-task': {
        'task': 'api.tasks.get_data',
        # At 16h UTC everyday
        'schedule': crontab(minute=0, hour=16),
        'args': ({'pencil'}),
    }
}

回复收藏 0 原文

~没有更多了~