perf: 减少 celery 数量

apps/terminal/api/session.py

@@ -42,10 +42,10 @@ class SessionViewSet(OrgBulkModelViewSet):
         'display': serializers.SessionDisplaySerializer,
     }
     permission_classes = (IsOrgAdminOrAppUser, )
-    filterset_fields = [
-        "user", "asset", "system_user", "remote_addr",
-        "protocol", "terminal", "is_finished", 'login_from',
+    search_fields = [
+        "user", "asset", "system_user", "remote_addr", "protocol", "is_finished", 'login_from',
     ]
+    filterset_fields = search_fields + ['terminal']
     date_range_filter_fields = [
         ('date_start', ('date_from', 'date_to'))
     ]

apps/users/serializers/user.py

@@ -69,7 +69,7 @@ class UserSerializer(CommonBulkSerializerMixin, serializers.ModelSerializer):
         ]
 
         read_only_fields = [
-            'date_joined', 'last_login', 'created_by', 'is_first_login', 'source'
+            'date_joined', 'last_login', 'created_by', 'is_first_login',
         ]
 
         extra_kwargs = {

jms

@@ -227,17 +227,17 @@ def get_start_daphne_kwargs():
 
 def get_start_celery_ansible_kwargs():
     print("\n- Start Celery as Distributed Task Queue: Ansible")
-    return get_start_worker_kwargs('ansible', 4)
+    return get_start_worker_kwargs('ansible', 2)
 
 
 def get_start_celery_default_kwargs():
     print("\n- Start Celery as Distributed Task Queue: Celery")
-    return get_start_worker_kwargs('celery', 4)
+    return get_start_worker_kwargs('celery', 2)
 
 
 def get_start_celery_node_tree_kwargs():
     print("\n- Start Celery as Distributed Task Queue: NodeTree")
-    return get_start_worker_kwargs('node_tree', 2)
+    return get_start_worker_kwargs('node_tree', 1)
 
 
 def get_start_celery_heavy_tasks_kwargs():

requirements/requirements.txt

@@ -98,7 +98,7 @@ ipython
 huaweicloud-sdk-python==1.0.21
 django-redis==4.11.0
 python-redis-lock==3.5.0
-jumpserver-django-oidc-rp==0.3.7.5
+jumpserver-django-oidc-rp==0.3.7.6
 django-mysql==3.9.0
 gmssl==3.2.1
 azure-mgmt-compute==4.6.2