celery worker节点和celery beat启动配置

2024-05-20 19:53:50 发布

您现在位置:Python中文网/ 问答频道 /正文

我有一个芹菜工人,负责执行一系列数据加载任务。我使用以下方法启动工作节点:

celery -A ingest_tasks worker -Q ingest --loglevel=INFO --concurrency=3 -f /var/log/celery/ingest_tasks.log

我有另一个应用程序,我想设置为芹菜节拍,定期从不同的位置抓取文件。因为我的第二个应用程序不在worker节点下,所以我应该可以这样开始节拍,对吗?你知道吗

celery -A file_mover beat -s /my/path/celerybeat-schedule

我以前从没用过芹菜。从阅读的文件,他们似乎相当直接。不过,我想确保这是正确的。你知道吗


Tags: 文件数据方法infolog应用程序节点tasks