import?djcelery
from?datetime?import?timedelta
djcelery.setup_loader()




CELERY_IMPORTS=(
????'apptest.tasks',
)

CELERY_QUEUES={
????#定時(shí)任務(wù)隊(duì)列配置
????'beat_tasks':{
????????'exchange':'beat_tasks',
????????'exchange_type':'direct',
????????'binding_key':'beat_tasks'
????},
????#?普通任務(wù)隊(duì)列配置
????'work_queue':?{
????????'exchange':?'work_queue',
????????'exchange_type':?'direct',
????????'binding_key':?'work_queue'
????}
}


CELERY_DEFAULT_QUEUE?=?'work_queue'
#?celery?配置

#?有些情況下防止死鎖
CELERYD_FORCE_EXECV?=?True

#?設(shè)置并發(fā)的worker數(shù)量
CELERYD_CONCURRENCY?=?4

#?允許重試
CELERY_ACKS_LATE?=?True

#?每個(gè)worker最多允許執(zhí)行100個(gè)任務(wù)被銷毀，可以防止內(nèi)存泄漏
CELERY_MAX_TASKS_PER_CHILD?=?100


#?單個(gè)任務(wù)的最大運(yùn)行時(shí)間
CELERYD_TASK_TIME_LIMIT?=?12?*?30



CELERYBEAT_SCHEDULE?=?{
????'tasks1':
????????{
????????????'task':'course-task',
????????????'schedule':timedelta(seconds=5),
????????????'args':(2,8),
????????????'options':{
????????????????'queue':'beat_tasks'
????????????}

????????}
????#每天10點(diǎn)執(zhí)行
????#?'task2':
????#?????{
????#?????????'task':?'celery_app.task2.mutiply',
????#?????????'schedule':?crontab(hour=15,minute=15),
????#?????????'args':?(4,?5)
????#?????}

}

但是日志沒有運(yùn)行到beat

celery beat v3.1.26.post2 (Cipater) is starting.

__? ? -? ? ... __? ?-? ? ? ? _

Configuration ->

? ? . broker -> amqp://guest:**@localhost:5672//

? ? . loader -> celery.loaders.default.Loader

? ? . scheduler -> celery.beat.PersistentScheduler

? ? . db -> celerybeat-schedule

? ? . logfile -> [stderr]@%INFO

? ? . maxinterval -> now (0s)

[2021-03-27 15:48:48,978: INFO/MainProcess] beat: Starting...