django tasks manager

Django任务管理器

超级简单的Django＆Celery集成 - 该库由Appseed积极支持。

特征：

• 创建/撤销Celery Tasks
• View LOGS和输出
• Minimal Configuration
• 可用任务（作为开始样本提供）
  • users_in_db() - 列出所有注册用户
  • execute_script() - 让用户执行CELERY_SCRIPTS_DIR中定义的脚本（CFG参数）
    • check-db-health.py（样本）

如何使用它

通过PIP安装软件包

$ pip install django-tasks-manager
// OR
$ pip install git+https://github.com/app-generator/django-tasks-manager.git

包括新路由

 # core/urls.py

from django . urls import path , include     # <-- UPDATE: Add 'include' HELPER

urlpatterns = [
    ...
    
    path ( "" , include ( "django_tm.urls" )),  # <-- New Routes

    ...
]

创建Scrips＆Logs Directories-推荐的位置在项目的根源中：

$ mkdir celery_scripts # Used in Settings -> CELERY_SCRIPTS_DIR
$ mkdir celery_logs    # Used in Settings -> CELERY_SCRIPTS_DIR

• 确保执行应用程序的用户具有写入权限。
• 在脚本目录中复制示例脚本。
• 所有脚本都将在UI中可用，可以由经理执行。

更新配置添加os对象导入

 import os # <-- NEW

更新配置：包括新应用程序

 INSTALLED_APPS = [
    ...                  
    'django_tm' ,              # Django Tasks Manager   # <-- NEW
    'django_celery_results' ,  # Django Celery Results  # <-- NEW
]

更新配置：包括新模板

 TEMPLATE_DIR_TASKS = os . path . join ( BASE_DIR , "django_tm/templates" )     # <-- NEW

TEMPLATES = [
    {
        'BACKEND' : 'django.template.backends.django.DjangoTemplates' ,   
        'DIRS' : [ TEMPLATE_DIR_TASKS ],                                  # <-- Updated 
        'APP_DIRS' : True ,
    },
]

更新配置：新芹菜部分

 #############################################################
# Celery configurations
# https://docs.celeryq.dev/en/stable/django/first-steps-with-django.html

# !!!
# BASE_DIR points to the ROOT of the project
# Note: make sure you have 'os' object imported
# !!!

# !!!
# BASE_DIR = os.path.dirname(os.path.dirname(__file__))
# !!! 

# Working Directories required write permission
CELERY_SCRIPTS_DIR        = os . path . join ( BASE_DIR , "celery_scripts" )
CELERY_LOGS_DIR           = os . path . join ( BASE_DIR , "celery_logs"    )

CELERY_BROKER_URL         = os . environ . get ( "CELERY_BROKER" , "redis://localhost:6379" )
CELERY_RESULT_BACKEND     = os . environ . get ( "CELERY_BROKER" , "redis://localhost:6379" )

CELERY_TASK_TRACK_STARTED = True
CELERY_TASK_TIME_LIMIT    = 30 * 60
CELERY_CACHE_BACKEND      = "django-cache"
CELERY_RESULT_BACKEND     = "django-db"
CELERY_RESULT_EXTENDED    = True
CELERY_RESULT_EXPIRES     = 60 * 60 * 24 * 30 # Results expire after 1 month
CELERY_ACCEPT_CONTENT     = [ "json" ]
CELERY_TASK_SERIALIZER    = 'json'
CELERY_RESULT_SERIALIZER  = 'json'

#############################################################
#############################################################

启动应用程序

$ # Set up the database
$ python manage.py makemigrations
$ python manage.py migrate
$
$ # Create the superuser
$ python manage.py createsuperuser
$
$ # Start the application (development mode)
$ python manage.py runserver # default port 8000

• 身份验证为superuser
• 访问Tasks页面： http://127.0.0.1:8000/tasks 8000/tasks

启动芹菜经理（另一个终端）和更新环境

使用manage.py中提供的值导出DJANGO_SETTINGS_MODULE

$ export DJANGO_SETTINGS_MODULE=cfg.settings  

使用的值应从manage.py中获取：

 def main ():
    
    """Run administrative tasks."""
    os . environ . setdefault ( "DJANGO_SETTINGS_MODULE" , "cfg.settings" )  # <-- VALUE to be exported

    try :
        from django . core . management import execute_from_command_line
    except ImportError as exc :
        ...

注意：端口6379 （默认）预计Redis服务器。如果redis在其他PORT上运行，请更新配置： CELERY_BROKER_URL和CELERY_RESULT_BACKEND 。

$ celery --app=django_tm.celery.app worker --loglevel=info 

屏幕

View all tasks

View Task LOG

链接和资源

• 通过电子邮件和不和谐免费支持
• Django Tasks Manager- free sample ，解释：
  • Project Creation （添加最小文件）
  • Install和生成Django核心
  • 安装Django-TM （此软件包）
  • Update Configuration
  • Start the app
  • 使用Tasks Manager

---

Django Tasks Manager- Appseed提供的开源库