使用python脚本一个简单的搭建ansible集群

1.环境说明：

角色主机名ip地址
控制主机server192.168.174.150
受控主机/被管节点client1192.168.174.151
受控主机/被管节点client2192.168.174.152

2.安装python和pip包

yum install -y epel-release
yum install -y python python-pip

3.pip安装依赖库

pip install pexpect     # 此库用相当于linux中的expect命令

4.完整脚本：

# coding=UTF-8
import sys,os,pexpect,subprocesshost_controller="192.168.174.150"                            # 控制节点IP地址
host_addresses=["192.168.174.151","192.168.174.152"]           # 客户端们的IP地址
host_domains=["client1","client2"]                          # 客户端们的域名
host_username="root"                                         # ssh连接的用户，控制端的用户为root
host_passwd="123456"                                         # ssh连接的用户密码
ansible_hostGroup="clients"# 本地创建ssh公钥
if os.path.exists("/root/.ssh/id_rsa.pub") == True:print("\033[32m"+"ssh公钥已创建"+"\033[0m")                # 输出绿色字体
else:print("\033[32m"+"ssh公钥未创建，开始创建"+"\033[0m")child = pexpect.spawn('ssh-keygen -t rsa -b 1024')child.expect('Enter file in which to save the key')child.sendline('')child.expect('Enter passphrase')child.sendline('')child.expect('Enter same passphrase again')child.sendline('')child.expect(pexpect.EOF)               # 用于等待子进程的结束print(child.before.decode())            # 等待命令执行完毕并打印输出信息print("\033[32m" + "ssh公钥已创建" + "\033[0m")print("\n")# 向被控主机添加公钥的方法
def add_ssh_public_key_client(address,username,password):print("\033[32m"+"{}正在被添加公钥".format(address)+"\033[0m")# BatchMode=yes：表示使SSH在连接过程中不会提示输入密码，而直接尝试免密连接，-o ConnectTimeout=5：表示限制连接超时时间为5秒public_key_flag=os.system("ssh {}@{} -o BatchMode=yes -o ConnectTimeout=5 'exit'".format(username,address))if public_key_flag== 0:print("\033[32m" + "{}已经可以ssh连接".format(address) + "\033[0m")returnchild = pexpect.spawn('ssh-copy-id -i /root/.ssh/id_rsa.pub {}@{}'.format(username,address))try:child.expect('Are you sure you want to continue connecting')except pexpect.TIMEOUT:       # 如果try块中的咨询超时5秒没有出现就会出现异常pexpect.TIMEOUTprint("\033[32m"+"{}已经不是首次ssh连接了".format(address)+"\033[0m")else:                         # 是否回答咨询yeschild.sendline('yes')finally:child.expect('password')child.sendline(password)child.expect(pexpect.EOF)               # 用于等待子进程的结束print(child.before.decode())            # 等待命令执行完毕并打印输出信息
# 测试ssh连接的方法
def test_ssh_connection(all_flag,address,username):print("\033[32m" + "{}测试是否可以ssh连接".format(address) + "\033[0m")flag=os.system('ssh {}@{} -o ConnectTimeout=5 "exit"'.format(username,address))if flag==0:print("\033[32m" + "Success: {}可以ssh免密连接".format(address) + "\033[0m")else:print("\033[1;31m" + "Failed: {}ssh免密连接失败".format(address) + "\033[0m")     # 输出红色字体all_flag=1return all_flag# 本地的密钥开始加入被控制主机
for i in range(0, len(host_addresses)):add_ssh_public_key_client(host_addresses[i],host_username,host_passwd)print("\n")
# 测试ssh连接
for i in range(0, len(host_addresses)):final_flag=test_ssh_connection(0,host_addresses[i],host_username)
if final_flag ==1:sys.exit("ssh测试失败，请检查!")
else:print("\033[32m" + "Success: 全部可以ssh免密连接" + "\033[0m")
print("\n")# 配置防火墙和selinux
os.system("systemctl stop firewalld;systemctl disable firewalld")
os.system("sed -i 's/SELINUX=.*/SELINUX=disabled/' /etc/selinux/config")
for i in range(0, len(host_addresses)):print("\033[32m" + "{}正在配置防火墙和selinux".format(host_addresses[i]) + "\033[0m")fir_flag=os.system('ssh {}@{} "systemctl stop firewalld;systemctl disable firewalld"'.format(host_username,host_addresses[i]))if fir_flag!=0:print("\033[1;31m" + "Failed: 防火墙修改失败" + "\033[0m")sys.exit("请检查!")sel_flag=os.system("ssh {}@{} 'sed -i 's/SELINUX=.*/SELINUX=disabled/' /etc/selinux/config'".format(host_username,host_addresses[i]))if sel_flag!=0:print("\033[1;31m" + "Failed: selinux修改失败" + "\033[0m")sys.exit("请检查!")
print("\n")# 配置域名映射
print("\033[32m" + "本地开始配置域名映射" + "\033[0m")
with open("/etc/hosts","a") as f:for i in range(0, len(host_addresses)):f.write("{} {}\n".format(host_addresses[i],host_domains[i]))# 使用域名首次ssh连接
# 首次域名ssh连接的方法
def first_domain_name_con(domain,username,password):print("\033[32m"+"{}首次ssh连接".format(domain)+"\033[0m")# BatchMode=yes：表示使SSH在连接过程中不会提示输入密码，而直接尝试免密连接，-o ConnectTimeout=5：表示限制连接超时时间为5秒os.system("ssh -o BatchMode=yes -o ConnectTimeout=5 {}@{} 'exit' &> /dev/null".format(username, domain))first_domain_flag = os.system("ssh -o BatchMode=yes -o ConnectTimeout=5 {}@{} 'exit'".format(username, domain))if first_domain_flag == 0:print("\033[32m" + "{}已经可以ssh连接".format(domain) + "\033[0m")returnchild = pexpect.spawn('ssh {}@{} "exit"'.format(username,domain))try:connecting_tuple = child.expect('Are you sure you want to continue connecting')except pexpect.TIMEOUT:print("\033[32m"+"{}已经不是首次ssh连接了".format(domain)+"\033[0m")else:child.sendline('yes')child.expect(pexpect.EOF)               # 用于等待子进程的结束print(child.before.decode())            # 等待命令执行完毕并打印输出信息for i in range(0, len(host_addresses)):first_domain_name_con(host_domains[i],host_username,host_passwd)print("\n")# 配置chrony服务器
print("\033[32m" + "本地配置chrony" + "\033[0m")
chrony_flag = result=os.system("yum install -y chrony")
if chrony_flag != 0:print("\033[1;31m" + "Failed: 本地chrony安装失败" + "\033[0m")sys.exit("请检查!")
os.system("sed -i 's/#allow 192.168.0.0\/16/allow 192.168.174.0\/24/' /etc/chrony.conf")
os.system("sed -i 's/#local stratum 10/local stratum 10/' /etc/chrony.conf")
os.system("systemctl restart chronyd && systemctl enable chronyd &> /dev/null")
os.system("sleep 5")
os.system("timedatectl set-ntp true")
for i in range(0, len(host_addresses)):print("\033[32m" + "{}配置chrony".format(host_addresses[i]) + "\033[0m")chrony_flag = os.system("ssh {}@{} 'yum install -y chrony'".format(host_username,host_addresses[i]))if chrony_flag != 0:print("\033[1;31m" + "Failed: {}chrony安装失败".format(host_addresses[i]) + "\033[0m")sys.exit("请检查!")sed_chrony_delete = "sed -i '{}' /etc/chrony.conf".format('/^server/d')sed_chrony_add = "sed -i '{}' /etc/chrony.conf".format("2a\server {} iburst".format(host_controller))chrony_service="systemctl restart chronyd && systemctl enable chronyd &> /dev/null"chrony_time="chronyc sources -v | sed -n '{}'".format("/^\^\* {}/p".format(host_controller))os.system('ssh {}@{} "{}"'.format(host_username,host_addresses[i],sed_chrony_delete))os.system('ssh {}@{} "{}"'.format(host_username,host_addresses[i],sed_chrony_add))os.system('ssh {}@{} "{}"'.format(host_username,host_addresses[i],chrony_service))os.system('ssh {}@{} "timedatectl set-ntp true"'.format(host_username, host_addresses[i]))os.system("sleep 5")chrony_output = subprocess.check_output('ssh {}@{} "{}"'.format(host_username,host_addresses[i],chrony_time) ,shell=True)# 输出结果print(chrony_output)if chrony_output == "" or chrony_output is None:print("\033[1;31m" + "Failed: {}时间同步失败".format(host_addresses[i]) + "\033[0m")sys.exit("请检查!")
print("\n")# 安装ansbile
print("\033[32m" + "本地安装ansible软件" + "\033[0m")
os.system("yum install -y epel-release && yum install -y ansible")
try:ansible_output = subprocess.check_output("ansible --version", shell=True)
except subprocess.CalledProcessError:print("\033[1;31m" + "Failed: 本地安装ansible失败" + "\033[0m")sys.exit("请检查!")
finally:print("\033[32m" + "安装的ansible软件版本如下: " + "\033[0m")print(ansible_output)# /etc/ansible/hosts文件中添加主机租
print("\033[32m" + "修改配置文件/etc/ansible/hosts" + "\033[0m")
with open('/etc/ansible/hosts','a') as f:f.write("["+ansible_hostGroup+"]"+"\n")for i in range(0, len(host_domains)):f.write(host_domains[i] + "\n")# 测试
print("\033[32m" + "测试ansible命令" + "\033[0m")
try:ansible_hoc_output = subprocess.check_output("ansible clients -a uptime", shell=True)
except subprocess.CalledProcessError:print("\033[1;31m" + "Failed: 测试失败无法使用ansible命令" + "\033[0m")sys.exit("请检查!")
finally:print("\033[32m" + "测试结果如下" + "\033[0m")print("\033[1;33;40m"+ansible_hoc_output+"\033[0m")

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/206256.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

redis-学习笔记(hash)

redis-学习笔记(hash)

Redis 自身已经是 键值对 结构了 Redis 自身的键值对就是通过 哈希 的方式来组织的 把 key 这一层组织完成后, 到了 value 这一层, 还可以用 哈希类型 来组织 (简单的说就是哈希里面套哈希 [数组里面套数组 -> 二维数组] ) [ field value ] hset key field value [ field va…
阅读更多...
【Spring】Spring 微服务中的数据分区和分片

【Spring】Spring 微服务中的数据分区和分片

文章目录 前言数据分区简介分区的本质分区类型为什么分区很重要？分片简介了解分片分片的机制为什么选择分片？在 Spring 微服务中实现分区和分片用于分区的 Spring Data JPA挑战与最佳实践分区和分片时的注意事项选择正确的键重新分片和重新分区基础设施和…
阅读更多...
【Java 基础】23 国际化

【Java 基础】23 国际化

文章目录 1.概念2.原理1）Locale2）ResourceBundle3）MessageFormat 3.例子1）准备资源文件2）加载资源文件3）格式化消息（非必须） 总结 在全球化的今天，开发支持多语言的应用变…
阅读更多...
STM32F1的TIM输出比较（PWM）

STM32F1的TIM输出比较（PWM）

目录 1. OC（Output Compare）输出比较 2. PWM简介 3. 输出比较通道(高级) 4. 输出比较通道(通用) 5. PWM基本结构 6. 配置介绍 6.1 输出比较模块配置 6.2 给输出比较结构体赋一个默认值 6.3 配置强制输出模式 6.4 配置CRR寄存器的预装…
阅读更多...
【文件上传系列】No.1 大文件分片、进度图展示（原生前端 + Node 后端 Koa）

【文件上传系列】No.1 大文件分片、进度图展示（原生前端 + Node 后端 Koa）

分片（500MB）进度效果展示 效果展示，一个分片是 500MB 的 分片（10MB）进度效果展示 大文件分片上传效果展示 前端 思路 前端的思路：将大文件切分成多个小文件，然后并发给后端。 页面构建 先在页…
阅读更多...
低代码与MES：智能制造的新篇章

低代码与MES：智能制造的新篇章

一、引言 随着工业4.0和智能制造的兴起，企业对于生产过程的数字化、智能化需求日益迫切。制造执行系统（MES）作为连接计划层与控制层的关键信息系统，在提升生产效率、优化资源配置、保障产品质量等方面发挥着重要作用。然而&#…
阅读更多...
AIGC实战——WGAN(Wasserstein GAN)

AIGC实战——WGAN(Wasserstein GAN)

AIGC实战——WGAN 0. 前言1. WGAN-GP1.1 Wasserstein 损失1.2 Lipschitz 约束1.3 强制 Lipschitz 约束1.4 梯度惩罚损失1.5 训练 WGAN-GP 2. GAN 与 WGAN-GP 的关键区别3. WGAN-GP 模型分析小结系列链接 0. 前言 原始的生成对抗网络 (Generative Adversarial Network, GAN) 在…
阅读更多...
深入探索C语言中的二叉树：数据结构之旅

深入探索C语言中的二叉树：数据结构之旅

引言 在计算机科学领域，数据结构是基础中的基础。在众多数据结构中，二叉树因其在各种操作中的高效性而脱颖而出。二叉树是一种特殊的树形结构，每个节点最多有两个子节点：左子节点和右子节点。这种结构使得搜索、插入、删除等操作…
阅读更多...
【React Hooks】useReducer()

【React Hooks】useReducer()

useReducer 的三个参数是可选的，默认就是initialState，如果在调用的时候传递第三个参数那么他就会改变为你传递的参数，实际开发不建议这样写。会增加代码的不可读性。 使用方法： 必须将 useReducer 的第一个参数（函数…
阅读更多...
MySQL - 并发控制与事务的隔离级别

MySQL - 并发控制与事务的隔离级别

目录 第1关：并发控制与事务的隔离级别 第2关：读脏 第3关：不可重复读 第4关：幻读 第5关：主动加锁保证可重复读 第6关：可串行化 第1关：并发控制与事务的隔离级别 任务描述 本关任务&#…
阅读更多...
JS/jQuery 获取 HTTPRequest 请求标头?

JS/jQuery 获取 HTTPRequest 请求标头?

场景：在jquery封装的ajax请求中，默认是异步请求。 需要定一个秘钥进行解密，所以只能存放在请求头中。然后需要值的时候去请求头中读取。 注意：dataType设置，根据请求参数的格式设置，如果是加密字符串&…
阅读更多...
(C#)使用sharpcompress压缩解压文件(.rar,.zip,tar.bz2,.7z,.tar.gz)

(C#)使用sharpcompress压缩解压文件(.rar,.zip,tar.bz2,.7z,.tar.gz)

sharpcompress安装方法 使用Nuget搜索sharpcompress,点击安装即可 1、.rar文件解压代码(不支持rar压缩) using (Stream stream File.OpenRead("C:\Code\sharpcompress.rar")) {var reader ReaderFactory.Open(stream);while (reader.MoveToNextEntry()){if (!re…
阅读更多...
linux初级学习

linux初级学习

(420条消息) 红帽认证-RHCSA_rhcsa红帽认证_yyyzf的博客-CSDN博客 OS：用户和机器的接口，UI:CMD,GUI shell: 通用格式 命令 选项（调控功能） 参数（操作对象）参数 省略参数对象一般使用当前目录作为参数对…
阅读更多...
WordPress禁止显示指定类别的文章

WordPress禁止显示指定类别的文章

使用wordpress禁止输出指定类别的文章可以给get_posts()函数传个数组参数&#xff0c;如下&#xff1a; <div class"widget" id"diary1"> <h3>随机呈现</h3> <ul> <?php $argsarray( numberposts>16, category>-9,-12, …
阅读更多...
vue3日常知识点学习归纳

vue3日常知识点学习归纳

1&#xff0c;父子组件传递&#xff1a; 父组件传递参数 <template><div><!-- 子组件 参数&#xff1a;num 、nums --><child :num"nums.num" :doubleNum"nums.doubleNum" increase"handleIncrease"></child>&l…
阅读更多...
JAVA全栈开发 day19_JDBC

JAVA全栈开发 day19_JDBC

一、JDBC 1.JDBC概述 1.1什么是jdbc Java DataBase Connectivity是一种用于执行SQL语句的Java API&#xff0c;它由一组用Java语言编写的类和接口组成。通过这些类和接口&#xff0c;JDBC把SQL语句发送给不同类型的数据库进行处理并接收处理结果。 1.2jdbc的作用 提供java…
阅读更多...
非常抱歉的通知

非常抱歉的通知

非常感谢有这么多的同志向我提问一些问题&#xff0c;也非常感谢很多的同志可以看我的学习文章&#xff0c;这次大概有四五个月没有上csdn&#xff0c;看到了许多同志的疑问和慰问&#xff0c;我也很感动&#xff0c;但是由于我自己以及其他的原因&#xff0c;我现在打算以考编…
阅读更多...
【目标检测从零开始】torch搭建yolov3模型

【目标检测从零开始】torch搭建yolov3模型

用torch从0简单实现一个的yolov3模型&#xff0c;主要分为Backbone、Neck、Head三部分 目录 Backbone&#xff1a;DarkNet53结构简介代码实现Step1&#xff1a;导入相关库Step2&#xff1a;搭建基本的Conv-BN-LeakyReLUStep3&#xff1a;组成残差连接块Step4&#xff1a;搭建Da…
阅读更多...
思维模型 色彩心理效应

思维模型 色彩心理效应

本系列文章 主要是 分享 思维模型&#xff0c;涉及各个领域&#xff0c;重在提升认知色彩影响情绪。 1 色彩心理效应的应用 1.1 色彩心理效应在营销中的应用 1 可口可乐公司的“红色”营销 可口可乐公司是全球最著名的饮料品牌之一&#xff0c;其标志性的红色包装已经成为了…
阅读更多...
Constraining Async Clock Domain Crossing

Constraining Async Clock Domain Crossing

Constraining Async Clock Domain Crossing 我们在normal STA中只会去check 同步clock之间的timing，但是design中往往会存在很多CDC paths，这些paths需要被正确约束才能保证design function正确，那么怎么去约束这些CDC paths呢？ 以下面的design为例，如下图所示 这里clk…
阅读更多...
最新文章

Copyright @ 2022~2023