小编Par*_*dya的帖子

我使用 celery 进行异步 ML 模型训练。如果我发出任务请求 2-3 次（不确定），则会以工作人员身份收到消息：热关闭（主进程），然后在几个小时内无法发送请求。有时它会自动启动。

我的芹菜代码是这样的。

celery = Celery(app.name, broker='redis://localhost:6379/0')
@celery.task

我也尝试过这个：

@celery.task(CELERY_ACKS_LATE = True)

我已经尝试过设置并发= 1

celery worker -A classify_model.celery --loglevel=info -Q random-tasks --concurrency=1

我收到的错误是

worker:warm shutdown(Main Process)

我有这样的 pandas 数据框：

Employee_id  timestamp
   1        2017-06-21 04:47:45
   1        2017-06-21 04:48:45
   1        2017-06-21 04:49:45

对于每位员工，如果他/她在办公室，我每 1 分钟就会收到 ping 信息。我有大约 2000 个员工的 ping，我需要如下输出：

Employee_id    date           Total_work_hour
     1      2018-06-21               8
     1      2018-06-22               7
     2      2018-06-21               6
     2      2018-06-22               8

为全体 2000 名员工