zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

任务派发测试

This commit is contained in:
曹前明 2022-07-16 15:22:25 +08:00
parent 8a2b34ded4
commit e9fbc1362f
3 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/system/tasks.py
View File

@ -8,4 +8,4 @@ from django.core.mail import send_mail
@shared_task(base=CustomTask) @shared_task(base=CustomTask)
def show(x=1): def show(x=1):
return 40/x return 40/int(x)

4
apps/utils/serializers.py
View File

@ -52,5 +52,5 @@ class GenerateVoiceSerializer(serializers.Serializer):
class TestTaskSerializer(serializers.Serializer): class TestTaskSerializer(serializers.Serializer):
args = serializers.ListField(child=serializers.CharField(), label='列表参数', required=False, null=True) args = serializers.ListField(child=serializers.CharField(), label='列表参数', required=False, allow_null=True)
kwargs = serializers.JSONField(label="字典参数", required=False, null=True) kwargs = serializers.JSONField(label="字典参数", required=False, allow_null=True)

8
apps/utils/views.py
View File

@ -93,6 +93,8 @@ class TestViewSet(CustomGenericViewSet):
""" """
serializer = TestTaskSerializer(data=request.data) serializer = TestTaskSerializer(data=request.data)
serializer.is_valid(raise_exception=True) serializer.is_valid(raise_exception=True)
vdata = serializer.validated_data() vdata = serializer.validated_data
show.delay(*vdata.get('args', []), **vdata.get('kwargs', {})) ret = {}
return Response() task = show.delay(*vdata.get('args', []), **vdata.get('kwargs', {}))
ret['task_id'] = task.task_id
return Response(ret)