Why i can't run a periodic tasks?
proj/settings.py
REDIS_HOST = 'localhost'
REDIS_PORT = '6379'
CELERY_BROKER_URL = 'redis://localhost:6379'
BROKER_URL = 'redis://' + REDIS_HOST + ':' + REDIS_PORT
CELERY_BEAT_SCHEDULE = {
'task-first': {
'task': 'app.tasks.one',
'schedule': timedelta(seconds=1)
},
'task-second': {
'task': 'app.tasks.two',
'schedule': crontab(minute=0, hour='*/3,10-19')
}
}
proj/celery.py
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proj.settings')
app = Celery('proj')
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
proj/__init.py__
from .celery import app as celery_app
__all__ = ['celery_app']
celery -A proj worker -l info
[2019-10-31 16:57:57,906: INFO/MainProcess] Connected to redis://localhost:6379//
[2019-10-31 16:57:57,912: INFO/MainProcess] mingle: searching for neighbors
[2019-10-31 16:57:58,927: INFO/MainProcess] mingle: all alone
[2019-10-31 16:57:58,951: INFO/MainProcess] celery@lexvel-MS-7A72 ready.
Tasks are found
celery -A proj beat -l info
Configuration ->
. broker -> redis://localhost:6379//
. loader -> celery.loaders.app.AppLoader
. scheduler -> celery.beat.PersistentScheduler
. db -> celerybeat-schedule
. logfile -> [stderr]@%INFO
. maxinterval -> 5.00 minutes (300s)
[2019-10-31 16:58:02,851: INFO/MainProcess] beat: Starting...
The celerybeat-shedule
file is created. But besides these lines nothing more is displayed.
tasks
@task()
def one():
print('start 1', datetime.now())
driver = init_driver()
parse(driver)
driver.close()
driver.quit()
@task()
def two():
print('start 2', datetime.now())
driver = init_driver()
parse2(driver)
driver.close()
driver.quit()
print('end 2', datetime.now())
from How can to start tasks with celery-beat?
No comments:
Post a Comment