在生产中收到了未注册的KeyError类型的任务

Question

我有芹菜定期任务，这些任务在此之后向我发送电子邮件。

它在本地计算机上工作完美，但在上失败了do ubuntu Server 带有错误：
Received unregistered task of type KeyError('periodic_tasks.send_email_task',)。

我的 equicic_tasks.py 文件看起来像这样：

app = Celery('periodic_tasks', broker='')
logger = get_task_logger(__name__)
@app.task(soft_time_limit=2000, max_retries=2)
def send_email_task(task_db_id):
    db = DBMethods()
    client_listings = dw.generate_client_listings(db)
    current_task = db.get_scheduled_task_data(task_db_id)
    query = current_task.get('task_params').get('query')
    days_stay = current_task.get('task_params').get('days_stay')
    proxy = current_task.get('task_params').get('proxy')
    adults_count = int(current_task.get('task_params').get('adults_count'))
    pets_count = int(current_task.get('task_params').get('pets_count'))
    to_email = current_task.get('task_params').get('to_email')
    cc_email = current_task.get('task_params').get('cc_email')
    additional_text = current_task.get('task_params').get('additional_text')
    task_id = str(send_email_task.request.id),
    task_data = {
        "task_id": task_id,
        "task_name": "send_email_task",
        "task_args": [client_listings, query, proxy, days_stay, adults_count, pets_count,
                                 to_email, cc_email, additional_text],
        "task_start_at": datetime.now(),
        "task_status": 0
    }
    db.start_scheduled_task(task_data)
    try:
        logger.info(email_worker_new(db, client_listings, query, proxy, days_stay, adults_count, pets_count,
                                 to_email, cc_email, additional_text))
        db.finish_scheduled_task(task_id, 1, datetime.now(), 'success')
    except SoftTimeLimitExceeded:
        db.finish_scheduled_task(task_id, 9, datetime.now(), 'timeout')
app.conf.beat_schedule = {
    "send-email-001-task": {
        "task": "periodic_tasks.send_email_task",
        "schedule": crontab(minute="0", hour="*/2"),
        "args": ('email_001', )
    },
}

用命令运行芹菜- celery -A periodic_tasks worker -B --loglevel=info in sustersord

请帮助我。我在生产上做错了什么？

Answer 1

这是一个典型的"问题"。

- 您需要将最新代码重新发送给所有运行芹菜工人的机器，因此他们已经注册了新任务。

您需要一个良好的部署策略。您可以做的最简单的事情是构建一个包装所有芹菜任务的Python轮，并在所有运行芹菜的机器上进行pip install -U your-project。自然，您也需要重新启动芹菜...

一旦您的新代码出现了，并且您的芹菜工人正在启动并运行，您可以检查是否通过运行celery -A periodic_tasks inspect registered注册新任务。您应该在此列表中看到您的新任务。