Python中的 ansible 动态Inventory 脚本

更新时间：2020-08-22 02:06:01 作者：startmvc

1.AnsibleInventory 介绍;AnsibleInventory是包含静态Inventory和动态Inventory两部分的，静态Inventory

1.Ansible Inventory 介绍;

Ansible Inventory 是包含静态 Inventory 和动态 Inventory 两部分的，静态 Inventory 指的是在文件中指定的主机和组，动态 Inventory 指通过外部脚本获取主机列表，并按照 ansible 所要求的格式返回给 ansilbe 命令的。这部分一般会结合 CMDB 资管系统、云计算平台等获取主机信息。由于主机资源一般会动态的进行增减，而这些系统一般会智能更新。我们可以通过这些工具提供的 API 或者接入库查询等方式返回主机列表。

2.mysql数据结构如下;

3.本章节演示从mysql数据作为数据源生成动态ansible 主机;


#!/usr/bin/env python36
def commmysql():
 import mysql.connector
 import json
 mydb = mysql.connector.connect(
 host="192.168.1.23", # 数据库主机地址
 user="root", # 数据库用户名
 passwd="123456",
 database="test"
 )
 mycursor = mydb.cursor()
 mycursor.execute(" select host,`group` from ansible_hosts;")
 #mycursor.
 myresult = mycursor.fetchall()
 data = dict()
 #####查询出group分组并去重#############
 groups = list(set([i[1].decode() for i in myresult]))
 data["all"] = {"children": groups}
 data["_meta"] = {"hostvars": {}}
 for group in groups:
 data[group] = dict()
 data[group]["hosts"] = list()
 for x in myresult:
 if x[1].decode("utf-8") == group:
 data[group]["hosts"].append(x[0].decode("utf-8"))
 return json.dumps(data,indent=3)
def main():
 from optparse import OptionParser
 parse = OptionParser()
 parse.add_option("-l", "--list", action="store_true", dest="list", default=False)
 (option, arges) = parse.parse_args()
 if option.list:
 print(commmysql())
 else:
 print("abc")
if __name__ == '__main__':
 from optparse import OptionParser
 parse = OptionParser()
 parse.add_option("-l", "--list", action="store_true", dest="list", default=False)
 (option, arges) = parse.parse_args()
 if option.list:
 print(commmysql())
 else:
 print("test")

4.数据格式结果如下;