zoukankan      html  css  js  c++  java
  • celery.exceptions.NotRegistered: 'tasks.add' + celery delay 坑 + python manage.py check 查看状态

    0.查看celery的worker状态 (worker==node)

    (base) D:djangotestmyrecrument>celery -A myrecrument  status
    2021-01-23 00:12:53,091 job.views    68 INFO     i am in view
    celery@DESKTOP-OTOBB8E: OK
    
    1 node online.
    参考:https://www.cnblogs.com/shanchuan/p/12818117.html

    1.检查已经注册的task

     D:djangotestmyrecrumentmycelery> celery -A tasks inspect registered

    2. D:djangotestmyrecrument>  python manage.py check   检查django项目语法

    3.celery delay 坑

    def notify_interviewer(modeladmin,request,queryset):
        logger.info('i enter notify_interviewer...begin')
        candidates = ' '
        for obj in queryset:
            candidates = obj.username + ';' + candidates
        #dingtalk.send(candidates)
        
        send_dingtalk_message.delay(candidates)
        logger.info('i enter notify_interviewer...after delay')

    项目目录 __init__.py 忘了添加以下内容,造成task.delay卡主

    from __future__ import absolute_import, unicode_literals
    
    # This will make sure the app is always imported when
    # Django starts so that shared_task will use this app.
    from .celery import app as celery_app  #少了这一点,delay就卡住发送不了消息
    
    __all__ = ('celery_app',)
    用一个例子来演示会更加清晰
  • 相关阅读:
    9
    8
    7
    6
    5
    第四周
    作业14-数据库
    作业13-网络
    作业12-流与文件
    作业11-多线程
  • 原文地址:https://www.cnblogs.com/hixiaowei/p/14309756.html
Copyright © 2011-2022 走看看