| | |
| | | async def system_license_sync(db): |
| | | with open(os.path.join(ENV_CONF_PATH, "system.yaml") , 'r', encoding='utf-8') as file: |
| | | # 加载JSON数据 |
| | | config = json.load(file) |
| | | config = yaml.safe_load(file) |
| | | try: |
| | | system = db.query(SystemDataModel).filter_by(id=SYSTEM_ID).first() |
| | | if system: |
| | |
| | | scheduler = BackgroundScheduler() |
| | | scheduler.add_job(sync_agents_v2, 'interval', minutes=60, id="sync_resource_data") |
| | | scheduler.add_job(start_sync_token_task, 'interval', minutes=5, id="sync_token_1") |
| | | scheduler.add_job(sync_resource, 'interval', minutes=5, id="sync_resource_1") |
| | | scheduler.add_job(sync_resource, 'interval', minutes=30, id="sync_resource_1") |
| | | |
| | | scheduler.start() |
| | | |