#!/usr/bin/env python3
# coding: utf-8
import json
import paramiko
def ssh2(ip, username, passwd, cmd):"""
    使用ssh连接远程服务器执行命令:param username: 用户名:param passwd: 密码:param cmd: 执行的命令:return:"""
    try:ssh = paramiko.SSHClient()  # 创建一个新的SSHClient实例# 设置host key,如果在"known_hosts"中没有保存相关的信息，SSHClient 默认行为是拒绝连接，会提示yes/nossh.set_missing_host_key_policy(paramiko.AutoAddPolicy())ssh.connect(ip, 22, username, passwd, timeout=1)  # 连接远程服务器,超时时间1秒stdin, stdout, stderr = ssh.exec_command(cmd)  # 执行命令out = stdout.readlines()    # 执行结果,readlines会返回列表ssh.close()  # 关闭ssh连接return outexcept Exception as e:print(e)return False# 服务器列表
ip_list = ["192.168.0.172","192.168.0.173"]
username = "root"
passwd = "root"
cmd = "date +%s"  # 获取时间戳命令result_dic = {}  # 执行结果for ip in ip_list:  # 遍历ip列表if not result_dic.get(ip):# 添加键值对res = ssh2(ip,username,passwd,cmd)if res:res = json.loads(res[0])result_dic[ip] = resprint("添加键值,ip: ", ip,"value: ",res)else:print("ssh连接服务器失败，ip: %s" %ip)print("结果字典",result_dic)# 获取第一个ip以及时间戳
first_ip = ""
first_val = ""for i in result_dic:  # 遍历结果字典# 获取第一个ip以及时间戳first_ip = ires = ssh2(i,username,passwd,cmd)first_val = json.loads(res[0])print("第一个ip: ", i,"value: ",first_val)result_dic.pop(i)  # 删除key,避免下面的for循环重复breakfor ip in result_dic:d_value = int(first_val) - int(result_dic[ip])# 判断差值上下不超过2if d_value <= -2 or d_value >= 2:print("错误, 上下差值超过2 !!!","ip:",ip,"value:",d_value)else:print("正常",ip,"差值为: ",d_value)

#!/usr/bin/env python3
# coding: utf-8
# 验证k8s版本import json
import paramiko
def ssh2(ip, username, passwd, cmd):"""
    使用ssh连接远程服务器执行命令:param username: 用户名:param passwd: 密码:param cmd: 执行的命令:return:"""
    try:ssh = paramiko.SSHClient()  # 创建一个新的SSHClient实例# 设置host key,如果在"known_hosts"中没有保存相关的信息，SSHClient 默认行为是拒绝连接，会提示yes/nossh.set_missing_host_key_policy(paramiko.AutoAddPolicy())ssh.connect(ip, 22, username, passwd, timeout=1)  # 连接远程服务器,超时时间1秒stdin, stdout, stderr = ssh.exec_command(cmd)  # 执行命令out = stdout.readlines()    # 执行结果,readlines会返回列表ssh.close()  # 关闭ssh连接return outexcept Exception as e:print(e)return False# 服务器列表
ip_list = ["192.168.0.172","192.168.0.173"]
username = "root"
passwd = "root"cmd = "kubectl version | awk '{print $5}' | cut -d ':' -f 2 | head -1 | cut -d ',' -f 1"  # 获取时间戳命令
result_dic = {}  # 执行结果for ip in ip_list:  # 遍历ip列表if not result_dic.get(ip):# 添加键值对res = ssh2(ip,username,passwd,cmd)# print("res",res)if res:  # 判断不为Noneres = json.loads(res[0])  # 反序列化第一行结果result_dic[ip] = resprint("添加键值", ip,"value",res)print("结果字典",result_dic)
# 获取第一个ip以及时间戳
first_ip = ""
first_val = ""for i in result_dic:  # 遍历结果字典# 获取第一个ip以及时间戳first_ip = ifirst_val = ssh2(i,username,passwd,cmd)if first_val:first_val = json.loads(first_val[0])print("第一个ip", i, "value", first_val)result_dic.pop(i)  # 删除key，比较下面的for循环重复breakfor ip in result_dic:d_value = result_dic[ip]# print("其他服务器,ip",ip,"value",d_value)# 判断版本是否一致if first_val == d_value:print("正常", ip, "版本是", d_value)else:print("错误, 版本不一致!!!", "ip:", ip, "value:", d_value)

#!/usr/bin/env python3
# coding: utf-8
# 检测redis集群import paramikodef ssh2(ip, username, passwd, cmd):"""
    使用ssh连接远程服务器执行命令:param username: 用户名:param passwd: 密码:param cmd: 执行的命令:return:"""
    try:ssh = paramiko.SSHClient()  # 创建一个新的SSHClient实例# 设置host key,如果在"known_hosts"中没有保存相关的信息，SSHClient 默认行为是拒绝连接，会提示yes/nossh.set_missing_host_key_policy(paramiko.AutoAddPolicy())ssh.connect(ip, 22, username, passwd, timeout=1)  # 连接远程服务器,超时时间1秒stdin, stdout, stderr = ssh.exec_command(cmd)  # 执行命令out = stdout.readlines()    # 执行结果,readlines会返回列表ssh.close()  # 关闭ssh连接return outexcept Exception as e:print(e)return False# 服务器列表
redis_apps = ["192.168.0.168","192.168.0.172"]username = "root"
passwd = "root"
port = "6379"
cmd1 = "cluster nodes"  # cluster nodes状态
cmd2 = "config get appendonly"  # AOF状态result_dic = {}  # 执行结果for ip in redis_apps:  # 遍历ip列表if not result_dic.get(ip):result_dic[ip] = {}# nodesif not result_dic[ip].get('nodes'):# 添加键值对，统一由192.168.0.167这台服务器执行redis-cli，因为它安装了redis-clires = ssh2("192.168.0.167",username,passwd,"redis-cli -c -h {} -p {} {}".format(ip,port,cmd1))result_dic[ip]['nodes'] = resprint("添加键值,ip: ", ip,"value: ",res)# aofif not result_dic[ip].get('aof'):# 添加键值对res = ssh2("192.168.0.167",username,passwd,"redis-cli -c -h {} -p {} {}".format(ip,port,cmd2))# print(res,type(res))res = res[1].split("\n")[0]  # 获取选项值result_dic[ip]['aof'] = resprint("添加键值,ip: ", ip,"value: ",res)print("结果字典",result_dic)# 标志位
flag_nodes = True
for i in result_dic:for j in result_dic[i]['nodes']:  # 遍历结果列表if "fail" in j:  # 判断是否有fail状态print("状态异常: ",j)flag_nodes = False# 判断标志位
if flag_nodes:print("redis cluster nodes 状态正常")
else:print("redis cluster nodes 状态异常")# 输出aof状态
print("redis aof状态如下: ")
for i in result_dic:print("ip: {} 状态: {}".format(i,result_dic[i]['aof']))

#!/usr/bin/env python3
# coding: utf-8
# 检测etcd状态import json
import requestsetcd_list = ["192.168.0.169","192.168.0.168","192.168.0.167"]for ip in etcd_list:# 访问api接口，查看版本response=requests.get('http://%s:2380/version' %ip)# print(response.content)res = (response.content).decode('utf-8')res_dict = json.loads(res)# print(res_dict,type(res_dict))print("ip: {} etcd版本为: {}".format(ip,res_dict['etcdserver']))

#!/usr/bin/env python3
# coding: utf-8import pymysqlconn = pymysql.connect(host="192.168.0.179",  # mysql ip地址user="root",passwd="root",port=3306  # mysql 端口号,注意：必须是int类型
)cur = conn.cursor()  # 创建游标# 查询当前MySQL本次启动后的运行统计时间
cur.execute('show status like "uptime"')data_all = cur.fetchall()  # 获取执行的返回结果
print(data_all)

#!/usr/bin/env python3
# coding: utf-8import paramikodef ssh2(ip, username, passwd, cmd):"""
    使用ssh连接远程服务器执行命令:param username: 用户名:param passwd: 密码:param cmd: 执行的命令:return:"""
    try:ssh = paramiko.SSHClient()  # 创建一个新的SSHClient实例# 设置host key,如果在"known_hosts"中没有保存相关的信息，SSHClient 默认行为是拒绝连接，会提示yes/nossh.set_missing_host_key_policy(paramiko.AutoAddPolicy())ssh.connect(ip, 22, username, passwd, timeout=1)  # 连接远程服务器,超时时间1秒stdin, stdout, stderr = ssh.exec_command(cmd)  # 执行命令out = stdout.readlines()    # 执行结果,readlines会返回列表ssh.close()  # 关闭ssh连接return outexcept Exception as e:print(e)return Falsesvr_list = ["192.168.0.181"]
username = "root"
passwd = "root"
cmd = "ceph osd tree"  # 查看节点信息for ip in svr_list:res = ssh2(ip,username,passwd,cmd)print(ip,"节点信息如下：")print("".join(res))

#!/usr/bin/env python3
# coding: utf-8
# 注意：需要手动创建topic才行执行此脚本import time
from kafka import KafkaProducer
from kafka import KafkaConsumerclass KafkaClient(object):  # kafka客户端程序def __init__(self, kafka_server, port, topic,content,username,password):self.kafka_server = kafka_server  # kafka服务器ip地址self.port = port  # kafka端口self.topic = topic  # topic名self.content = content  # 发送内容self.username = usernameself.password = passworddef producer(self):"""生产者模式:return: object"""# 连接kafka服务器,比如['192.138.150.193:9092']producer = KafkaProducer(bootstrap_servers=['%s:%s' % (self.kafka_server, self.port)],security_protocol="SASL_PLAINTEXT",  # 指定SASL安全协议sasl_mechanism='PLAIN',  # 配置SASL机制sasl_plain_username=self.username,  # 认证用户名sasl_plain_password=self.password,  # 密码
                                 )producer.send(self.topic, self.content)  # 发送消息,必须是二进制producer.flush()  # flush确保所有meg都传送给broker
        producer.close()return producerdef consumer(self):"""消费者模式:return: object"""# 连接kafka,指定组为test_groupconsumer = KafkaConsumer(topic, group_id='test_group', bootstrap_servers=['%s:%s' % (kafka_server, port)],sasl_mechanism="PLAIN",security_protocol='SASL_PLAINTEXT',sasl_plain_username=self.username,sasl_plain_password=self.password,)return consumer# for msg in consumer:#     recv = "%s:%d:%d: key=%s value=%s" % (msg.topic, msg.partition, msg.offset, msg.key, msg.value)#     print(recv)def main(self):startime = time.time()  # 开始时间
client = KafkaClient(self.kafka_server, self.port, self.topic, self.content,self.username,self.password)  # 实例化客户端client.producer()  # 执行生产者print('执行生产者')consumer = client.consumer()  # 执行消费者print('执行消费者')print('等待结果....')flag = Falsefor msg in consumer:# recv = "%s:%d:%d: key=%s value=%s" % (msg.topic, msg.partition, msg.offset, msg.key, msg.value)# 判断生产的消息和消费的消息是否一致print(msg.value)# print(self.content)if msg.value == self.content:flag = Truebreakconsumer.close()  # 关闭消费者对象endtime = time.time()  # 结束时间if flag:# %.2f %(xx) 表示保留小数点2位return "kafka验证消息成功,花费时间", '%.2f 秒' % (endtime - startime)else:return "kafka验证消息失败,花费时间", '%.2f 秒' % (endtime - startime)if __name__ == '__main__':kafka_server = "kafka-1.default.svc.cluster.local"port = "9092"topic = "test"# 测试消息content = "hello honey".encode('utf-8')username = "admin"password = "admin"client = KafkaClient(kafka_server,port,topic,content,username,password)  # 实例化客户端print(client.main())