mirror of
https://github.com/jumpserver/jumpserver.git
synced 2025-08-18 06:07:53 +00:00
dafc416783
* perf: 重命名 signal handlers * fix: 修复 ticket processor 问题 * perf: 修改 ticket 处理人api * fix: 修复创建系统账号bug * fix: 升级celery_beat==2.2.1和flower==1.0.0;修改celery进程启动参数先后顺序 * perf: 修改 authentication token * fix: 修复上传权限bug * fix: 登录页面增加i18n切换; * fix: 系统角色删除限制 * perf: 修改一下 permissions tree * perf: 生成 i18n * perf: 修改一点点 Co-authored-by: ibuler <ibuler@qq.com> Co-authored-by: feng626 <1304903146@qq.com> Co-authored-by: Jiangjie.Bai <bugatti_it@163.com>
29 lines
845 B
Python
29 lines
845 B
Python
from django.core.management.base import BaseCommand
|
|
|
|
from assets.signal_handlers.node_assets_mapping import expire_node_assets_mapping_for_memory
|
|
from orgs.caches import OrgResourceStatisticsCache
|
|
from orgs.models import Organization
|
|
|
|
|
|
def expire_node_assets_mapping():
|
|
org_ids = Organization.objects.all().values_list('id', flat=True)
|
|
org_ids = [*org_ids, '00000000-0000-0000-0000-000000000000']
|
|
|
|
for org_id in org_ids:
|
|
expire_node_assets_mapping_for_memory(org_id)
|
|
|
|
|
|
def expire_org_resource_statistics_cache():
|
|
orgs = Organization.objects.all()
|
|
for org in orgs:
|
|
cache = OrgResourceStatisticsCache(org)
|
|
cache.expire()
|
|
|
|
|
|
class Command(BaseCommand):
|
|
help = 'Expire caches'
|
|
|
|
def handle(self, *args, **options):
|
|
expire_node_assets_mapping()
|
|
expire_org_resource_statistics_cache()
|