# 2. 依赖安装
$ yum install -y python3 python3-pip git
$ pip3 install ansible flask redis pymysql

# 3. 代码获取
$ git clone https://github.com/fgedu/tidb-batch-ops.git
$ cd tidb-batch-ops

# 4. 配置数据库
$ mysql -u root -p -e “create database tidb_ops; grant all privileges on tidb_ops.* to ‘tidb_ops’@’localhost’ identified by ‘password’;”

# 5. 配置Redis
$ systemctl start redis
$ redis-cli config set requirepass “password”

# 6. 配置Ansible
$ cat > /etc/ansible/hosts << EOF [tidb_servers] 192.168.1.100 ansible_user=root ansible_password=password 192.168.1.101 ansible_user=root ansible_password=password 192.168.1.102 ansible_user=root ansible_password=password EOF # 7. 配置平台 $ cp config.example.py config.py $ vim config.py # 修改数据库连接、Redis连接等配置

# 2. 启动后端服务
$ python3 app.py &

# 3. 启动前端服务
$ cd frontend
$ npm install
$ npm run build
$ serve -s build -l 8080 &

# 4. 访问平台
# 浏览器访问 http://localhost:8080

# 1. 集群列表管理
# 后端API
@app.route(‘/api/clusters’, methods=[‘GET’])
def get_clusters():
clusters = Cluster.query.all()
return jsonify([cluster.to_dict() for cluster in clusters])

# 2. 集群状态监控
@app.route(‘/api/clusters//status’, methods=[‘GET’])
def get_cluster_status(cluster_id):
cluster = Cluster.query.get(cluster_id)
status = cluster.get_status()
return jsonify(status)

# 3. 集群操作
@app.route(‘/api/clusters//action’, methods=[‘POST’])
def cluster_action(cluster_id):
action = request.json.get(‘action’)
cluster = Cluster.query.get(cluster_id)
result = cluster.execute_action(action)
return jsonify(result)

# 4. 集群扩缩容
@app.route(‘/api/clusters//scale’, methods=[‘POST’])
def cluster_scale(cluster_id):
scale_type = request.json.get(‘scale_type’) # add or remove
node_type = request.json.get(‘node_type’) # tidb, tikv, pd
count = request.json.get(‘count’)
cluster = Cluster.query.get(cluster_id)
result = cluster.scale(scale_type, node_type, count)
return jsonify(result)

# 1. 批量命令执行
@app.route(‘/api/batch/execute’, methods=[‘POST’])
def batch_execute():
hosts = request.json.get(‘hosts’)
command = request.json.get(‘command’)
result = execute_command(hosts, command)
return jsonify(result)

# 2. 脚本管理
@app.route(‘/api/scripts’, methods=[‘GET’])
def get_scripts():
scripts = Script.query.all()
return jsonify([script.to_dict() for script in scripts])

@app.route(‘/api/scripts’, methods=[‘POST’])
def add_script():
name = request.json.get(‘name’)
content = request.json.get(‘content’)
script = Script(name=name, content=content)
db.session.add(script)
db.session.commit()
return jsonify(script.to_dict())

# 3. 执行结果分析
@app.route(‘/api/executions//result’, methods=[‘GET’])
def get_execution_result(execution_id):
execution = Execution.query.get(execution_id)
result = execution.get_result()
return jsonify(result)

# 4. 执行历史记录
@app.route(‘/api/executions’, methods=[‘GET’])
def get_executions():
executions = Execution.query.order_by(Execution.created_at.desc()).all()
return jsonify([execution.to_dict() for execution in executions])

# 1. 集群状态监控
@app.route(‘/api/monitoring/clusters/‘, methods=[‘GET’])
def get_cluster_monitoring(cluster_id):
cluster = Cluster.query.get(cluster_id)
metrics = cluster.get_metrics()
return jsonify(metrics)

# 2. 性能指标监控
@app.route(‘/api/monitoring/metrics’, methods=[‘GET’])
def get_metrics():
metrics = get_system_metrics()
return jsonify(metrics)

# 3. 告警配置
@app.route(‘/api/alerts’, methods=[‘GET’])
def get_alerts():
alerts = Alert.query.all()
return jsonify([alert.to_dict() for alert in alerts])

@app.route(‘/api/alerts’, methods=[‘POST’])
def add_alert():
name = request.json.get(‘name’)
condition = request.json.get(‘condition’)
threshold = request.json.get(‘threshold’)
alert = Alert(name=name, condition=condition, threshold=threshold)
db.session.add(alert)
db.session.commit()
return jsonify(alert.to_dict())

# 4. 告警历史记录
@app.route(‘/api/alerts/history’, methods=[‘GET’])
def get_alert_history():
history = AlertHistory.query.order_by(AlertHistory.created_at.desc()).all()
return jsonify([h.to_dict() for h in history])

# 1. 功能测试
# 测试集群管理功能
$ curl -X GET http://localhost:5000/api/clusters
$ curl -X POST http://localhost:5000/api/clusters/1/action -d ‘{“action”: “start”}’

# 测试批量执行功能
$ curl -X POST http://localhost:5000/api/batch/execute -d ‘{“hosts”: [“192.168.1.100”, “192.168.1.101”], “command”: “df -h”}’

# 测试监控告警功能
$ curl -X GET http://localhost:5000/api/monitoring/clusters/1
$ curl -X POST http://localhost:5000/api/alerts -d ‘{“name”: “磁盘空间告警”, “condition”: “disk_usage > 80”, “threshold”: 80}’

# 2. 性能测试
# 测试批量执行性能
$ time curl -X POST http://localhost:5000/api/batch/execute -d ‘{“hosts”: [“192.168.1.100”, “192.168.1.101”, “192.168.1.102”], “command”: “uptime”}’

# 测试API响应时间
$ ab -n 100 -c 10 http://localhost:5000/api/clusters

# 3. 安全测试
# 测试权限控制
$ curl -X GET http://localhost:5000/api/clusters -H “Authorization: Bearer invalid_token”

# 测试SQL注入
$ curl -X GET “http://localhost:5000/api/clusters?name=’ OR 1=1 –”

# 测试XSS攻击
$ curl -X POST http://localhost:5000/api/scripts -d ‘{“name”: “test”, “content”: “”}’