ASJServer/Controller/CeleryTasks/tasks.py

# @Author    : Rocky
# @File      : tasks.py
# @Time      : 2024/3/12 14:23
import django
django.setup()
import time
from Ansjer.celery import app
from Ansjer.config import LOGGER
from Ansjer.config import CONFIG_INFO
from Model.models import Device_User


@app.task
def hello():
    device_user_qs = Device_User.objects.filter(username='13138137872').values('NickName')
    nickname = device_user_qs[0]['NickName']
    info = 'celery测试日志, CONFIG_INFO:{}, nickname:{}'.format(CONFIG_INFO, nickname)
    LOGGER.info(info)


@app.task
def test(arg):
    time.sleep(10)
    print(arg)


@app.task
def add(x, y):
    print(x + y)