celery beat包升级

This commit is contained in:
曹前明 2022-07-16 14:19:01 +08:00
parent 14473de9de
commit edaf09994f
2 changed files with 12 additions and 1 deletions

View File

@ -2,6 +2,7 @@
import os import os
import cv2 import cv2
from django.http import HttpResponse from django.http import HttpResponse
from apps.system.tasks import show
from apps.utils.errors import SIGN_MAKE_FAIL from apps.utils.errors import SIGN_MAKE_FAIL
from apps.utils.sms import send_sms from apps.utils.sms import send_sms
from apps.utils.speech import generate_voice from apps.utils.speech import generate_voice
@ -14,6 +15,7 @@ from apps.utils.mixins import CustomCreateModelMixin
from apps.utils.serializers import GenSignatureSerializer, GenerateVoiceSerializer, SendSmsSerializer from apps.utils.serializers import GenSignatureSerializer, GenerateVoiceSerializer, SendSmsSerializer
from rest_framework.views import APIView from rest_framework.views import APIView
from rest_framework.decorators import action from rest_framework.decorators import action
from rest_framework.serializers import Serializer
class SignatureViewSet(CustomCreateModelMixin, CustomGenericViewSet): class SignatureViewSet(CustomCreateModelMixin, CustomGenericViewSet):
@ -82,3 +84,12 @@ class TestViewSet(CustomGenericViewSet):
vdata = serializer.validated_data vdata = serializer.validated_data
res = generate_voice(**vdata) res = generate_voice(**vdata)
return Response(res) return Response(res)
@action(methods=['get'], detail=False, serializer_class=Serializer)
def task(self, request, pk=None):
"""任务派发测试
任务派发测试
"""
show()
return Response()

View File

@ -1,6 +1,6 @@
celery==5.2.3 celery==5.2.3
Django==3.2.12 Django==3.2.12
django-celery-beat==2.2.1 django-celery-beat==2.3.0
django-celery-results==2.4.0 django-celery-results==2.4.0
django-cors-headers==3.11.0 django-cors-headers==3.11.0
django-filter==21.1 django-filter==21.1