mirrors/ConsulManager
1
0
Fork 0
mirror of https://github.com/starsliao/TenSunS.git synced 2025-12-18 12:03:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

云主机同步jumpserver功能

Browse Source
This commit is contained in:
StarsL.cn
2022-07-17 22:38:23 +08:00
parent c18b14e7ba
commit 0baa27bcd8
9 changed files with 440 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
flask-consul/manager.py
View File

@@ -2,13 +2,16 @@
from flask import Flask
from units import consul_kv
import uuid
skey_path = 'ConsulManager/assets/secret/skey'
if consul_kv.get_kv_dict(skey_path) == {}:
consul_kv.put_kv(skey_path,{'sk':''.join(str(uuid.uuid4()).split('-'))})
from views import login, blackbox, consul, jobs, nodes, selfnode, avd, exp
from views import login, blackbox, consul, jobs, nodes, selfnode, avd, exp, jms
from units.cloud import huaweicloud,alicloud,tencent_cloud
from units.avd import avd_list
from units.jms import sync_jms
app = Flask(__name__)
app.register_blueprint(login.blueprint)
app.register_blueprint(blackbox.blueprint)
@@ -18,18 +21,23 @@ app.register_blueprint(nodes.blueprint)
app.register_blueprint(selfnode.blueprint)
app.register_blueprint(avd.blueprint)
app.register_blueprint(exp.blueprint)
app.register_blueprint(jms.blueprint)
class Config(object):
JOBS = []
SCHEDULER_API_ENABLED = True
ecs_jobs = consul_kv.get_kv_dict('ConsulManager/jobs')
avd_jobs = consul_kv.get_kv_dict('ConsulManager/avd/jobs')
exp_jobs = consul_kv.get_kv_dict('ConsulManager/exp/jobs')
init_jobs = { **ecs_jobs, **avd_jobs, **exp_jobs }
jms_jobs = consul_kv.get_kv_dict('ConsulManager/jms/jobs')
init_jobs = { **ecs_jobs, **avd_jobs, **exp_jobs, **jms_jobs }
if init_jobs is not None:
for k,v in init_jobs.items():
print(f'【初始化任务】{k}:\n {v}', flush=True)
Config.JOBS = init_jobs.values()
app.config.from_object(Config())
if __name__ == "__main__":