赵走x博客
网站访问量：151418
首页
书籍
软件
工具
古诗词
搜索
登录
celery 启动显示警告信息“...whether broker connection retries are made during startup in Celery 6.0 and above...”
Celery周期执行实例
Celery周期执行实例
资源编号:569970
热度：122
Celery beat worker
新建python文件celery_test.py ``` from datetime import timedelta from celery import Celery celery_broker = 'redis://127.0.0.1/1' celery_backend = 'redis://127.0.0.1/2' CELERY_IMPORTS = ( 'celery_test', ) celery_app = Celery('celery', broker=celery_broker, backend=celery_backend, include=CELERY_IMPORTS) @celery_app.task def celery_mark(): print("---3-3--", flush=True) # @celery_app.on_after_finalize.connect @celery_app.on_after_configure.connect def setup_periodic_tasks(sender, **kwargs): sender.add_periodic_task( # crontab(minute=1, hour=0), # crontab(minute='*/1'), schedule=timedelta(seconds=5), sig=celery_mark.s(), ) ``` ### 运行 ``` celery -A celery_test beat -l info & celery -A celery_test worker -l info ```
