ansible通过cmdb资产接口动态创建hosts列表

rfyiamcool 2023-03-28 原文

前言：

在自动化、批量化操作主机的时候，有时候咱们需要定义主机组。比如，saltstack的group组，及salt -N参数，在ansible下的自己搞定ansible的主机组。有些麻烦，要知道，你既然选择了用saltstack、ansible这类的集群操作工具，如果你再选择把几十个多到几百个手动地，一个个地把主机组及相关联的主机写入配置，是不是显得很1+1。

这里简单说下我的一些个方法，首先可以避免这些个配置的写入，在产生minion的id的时候，就给他一个完美又规范的主机域名。比如，bj-zw-nginx，很容易定位到北京，兆维，nginx机组。其实主要你的主机域名相当的规范了，啥都好办了。如果一些难搞的主机，非要自定义group，可以通过cmdb资产接口，来取值，然后复写到配置文件里面，这个方法很有效，在没有了解到ansible有动态inventory的功能前，我一直在用这个方法，间隔性的会从cmdb接口拿到最新的主机及配置信息，复写到类hosts文件里面。

其实我上面说的功能，已经算是可以实现动态的hosts功能，看了沈灿和金山小伙的晓聪的讨论，才知道有个叫 Dynamic Inventory 的东西，这个功能其实是我上面讲解第二个方法的集成版，他省略了这一步，直接调用一个有inventory功能的脚本，然后取出相关的主机list，然后执行。

（这里打个广告，这两天通过朋友了解了猎豹那边的技术氛围，还不错，人虽然不多，因为是面向国外业务的团队，能力真心牛叉，那边运维研发的水平最少不比我差，欢迎牛人去猎豹面试，祝好运！！！）

好了，正题！

原文：http://rfyiamcool.blog.51cto.com/1030776/1416808

我觉得官网有些太实在了，一些例子说的简单点就行，好让我们自己去扩展思维。官网一上来就是cobbler和ec2的实例，谁看都有点麻。。。我是真麻。

模拟从cmdb资产接口获取数据，然后返回json的脚本 getcmdb.py的内容

#!/usr/bin/python
#xiaorui.cc
import argparse
import ConfigParser
import os
import re
from time import time
import xmlrpclib

try:
    import json
except ImportError:
    import simplejson as json

def good():
    parser = argparse.ArgumentParser(description='Produce an Ansible Inventory file based on Cobbler')
    parser.add_argument('--list', action='store_true', default=True, help='List instances (default: True)')
    parser.add_argument('--host', action='store', help='Get all the variables about a specific instance')
    
    print json.dumps({"web":{"hosts":["10.10.10.66"]}})


class CobblerInventory(object):
#原文：http://rfyiamcool.blog.51cto.com/1030776/1416808
    def __init__(self):
        """ Main execution path """
        self.conn = None

        self.inventory = dict()  # A list of groups and the hosts in that group
        self.cache = dict()  # Details about hosts in the inventory

        # Read settings and parse CLI arguments
        self.parse_cli_args()

        # Cache
        if self.args.refresh_cache:
            self.update_cache()
        elif not self.is_cache_valid():
            self.update_cache()
        else:
            self.load_inventory_from_cache()
            self.load_cache_from_cache()

        data_to_print = ""

        # Data to print
        if self.args.host:
            data_to_print = self.get_host_info()

        elif self.args.list:
            # Display list of instances for inventory
            data_to_print = self.json_format_dict(self.inventory, True)

        else:  # default action with no options
            data_to_print = self.json_format_dict(self.inventory, True)

        print data_to_print

    def _connect(self):
        if not self.conn:
            self.conn = xmlrpclib.Server(self.cobbler_host, allow_none=True)

    ............尼玛太多了。
    def json_format_dict(self, data, pretty=False):
        """ Converts a dict to a JSON object and dumps it as a formatted string """

        if pretty:
            return json.dumps(data, sort_keys=True, indent=2)
        else:
            return json.dumps(data)

good()

脚本后面都是官网的cobbler的，大家可以直接摘出来。只需要上面的good函数就可以了。

不仅可以返回hosts的主机列表，还可以获取vars的变量，然后引用。我这边用了最简单的例子，直接echo ` vars `。一般来说，可以用 -m template模块，来推送配置。其实我个人觉得 inventory动态信息和自定义模块的facts在某种程度有些功能重复了。就我个人的看法，比如我在操作一个nginx的vhosts和upstream信息组，这个时候用inventory动态和模块都可以从cmdb资产系统里面取出相关的信息来，只是inventory更能精确的返回，需要在那些target主机执行，这些指令！

引用vars变量：

话说，我这里的例子相当的简单，具体的从接口取数据，大家用urllib2 搞就是了。

#xiaorui.cc
def good(): 
    parser = argparse.ArgumentParser(description='Produce an Ansible Inventory file based on Cobbler')
    parser.add_argument('--list', action='store_true', default=True, help='List instances (default: True)')
    parser.add_argument('--host', action='store', help='Get all the variables about a specific instance')
#    print json.dumps({"web":{"hosts":["10.10.10.66"]},{"vars":{"todo":"this server whill restart"}}})
    print json.dumps({"web":{"hosts":["10.10.10.66"],"vars":{"todo":"this server whill restart"}},"nginx":{"hosts":["10.10.10.69"],"va
rs":{"todo":"this nginx is restart"}}})

大家注意下ansible inventory的返回格式，web相当于/etc/ansible/hosts里面的[web]标题，hosts相当于[web]下面的主机list，vars相当于变量。当然这些变量是供应给hosts主机，通过jinja2引用的。一般来说，返回不能正确的执行，原因在于格式不对，如果格式对了，没道理不行！（this is 废话）

原来的hosts的例子：

[atlanta]
host1
host2

[raleigh]
host2
host3

[southeast:children]
atlanta
raleigh

[southeast:vars]
some_server=foo.southeast.example.com
halon_system_timeout=30
self_destruct_countdown=60
escape_pods=2

[usa:children]
southeast
northeast
southwest
northwest

这是ansible能通过inventory返回的json信息。

来一个比较完整的例子：

#!/usr/bin/env python

import sqlite3
import sys
try:
    import json
except ImportError:
    import simplejson as json

dbname = '/etc/inv.db'

def grouplist(conn):

    inventory ={}


    inventory['local'] = [ '127.0.0.1' ]

    cur = conn.cursor()
    cur.execute("SELECT type, name FROM hosts ORDER BY 1, 2")

    for row in cur.fetchall():
        group = row['type']
        if group is None:
            group = 'ungrouped'
        

        if not group in inventory:
            inventory[group] = {
                'hosts' : []
            }
        inventory[group]['hosts'].append(row['name'])

    cur.close()
    print json.dumps(inventory, indent=4)

def hostinfo(conn, name):

    vars = {}

    cur = conn.cursor()
    cur.execute("SELECT COUNT(*) FROM hosts WHERE name=?", (name, ))

    row = cur.fetchone()
    if row[0] == 0:
        print json.dumps({})
        sys.exit(0)

    # Inject some variables for all hosts
    vars = {
        'admin'         : 'Jane Jolie',
        'datacenter'    : 1
    }

#从ldap重组数据
    if 'ldap' in name.lower():
        vars['baseDN'] = 'dc=mens,dc=de'


    print json.dumps(vars, indent=4)


if __name__ == '__main__':
    con = sqlite3.connect(dbname)
    con.row_factory=sqlite3.Row

    if len(sys.argv) == 2 and (sys.argv[1] == '--list'):
        grouplist(con)
    elif len(sys.argv) == 3 and (sys.argv[1] == '--host'):
        hostinfo(con, sys.argv[2])
    else:
        print "Usage: %s --list or --host <hostname>" % sys.argv[0]
        sys.exit(1)

    con.close()

单纯的看只是格式不一样罢了。好了，就这么着了，ansible的中文的文档有些少，真的希望我的这些个小文，能为大家在工作中提高效率及一些实现的思路。

有关ansible通过cmdb资产接口动态创建hosts列表的更多相关文章

ruby - 如何在 Ruby 中顺序创建 PI - 2
出于纯粹的兴趣，我很好奇如何按顺序创建PI，而不是在过程结果之后生成数字，而是让数字在过程本身生成时显示。如果是这种情况，那么数字可以自行产生，我可以对以前看到的数字实现垃圾收集，从而创建一个无限系列。结果只是在Pi系列之后每秒生成一个数字。这是我通过互联网筛选的结果:这是流行的计算机友好算法，类机器算法:defarccot(x,unity)xpow=unity/xn=1sign=1sum=0loopdoterm=xpow/nbreakifterm==0sum+=sign*(xpow/n)xpow/=x*xn+=2sign=-signendsumenddefcalc_pi(digits
python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声？ - 2
关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题？更新问题，以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点？我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等)，但我确实想创建一个输出文件。
ruby - 通过 rvm 升级 rubygems 的问题 - 2
尝试通过RVM将RubyGems升级到版本1.8.10并出现此错误:$rvmrubygemslatestRemovingoldRubygemsfiles...Installingrubygems-1.8.10forruby-1.9.2-p180...ERROR:Errorrunning'GEM_PATH="/Users/foo/.rvm/gems/ruby-1.9.2-p180:/Users/foo/.rvm/gems/ruby-1.9.2-p180@global:/Users/foo/.rvm/gems/ruby-1.9.2-p180:/Users/foo/.rvm/gems/rub
ruby - 使用 Vim Rails，您可以创建一个新的迁移文件并一次性打开它吗？ - 2
使用带有Rails插件的vim，您可以创建一个迁移文件，然后一次性打开该文件吗？textmate也可以这样吗？最佳答案你可以使用rails.vim然后做类似的事情::Rgeneratemigratonadd_foo_to_bar插件将打开迁移生成的文件，这正是您想要的。我不能代表textmate。关于ruby-使用VimRails，您可以创建一个新的迁移文件并一次性打开它吗？，我们在StackOverflow上找到一个类似的问题： https://sta
ruby-on-rails - 无法使用 Rails 3.2 创建插件？ - 2
我对最新版本的Rails有疑问。我创建了一个新应用程序(railsnewMyProject)，但我没有脚本/生成，只有脚本/rails，当我输入ruby./script/railsgeneratepluginmy_plugin"Couldnotfindgeneratorplugin.".你知道如何生成插件模板吗？没有这个命令可以创建插件吗？PS:我正在使用Rails3.2.1和ruby1.8.7[universal-darwin11.0] 最佳答案随着Rails3.2.0的发布，插件生成器已经被移除。查看变更日志here.现在
ruby - 通过 erb 模板输出 ruby 数组 - 2
我正在使用puppet为ruby程序提供一组常量。我需要提供一组主机名，我的程序将对其进行迭代。在我之前使用的bash脚本中，我只是将它作为一个puppet变量hosts=>"host1,host2"我将其提供给bash脚本作为HOSTS=显然这对ruby不太适用——我需要它的格式hosts=["host1","host2"]自从phosts和putsmy_array.inspect提供输出["host1","host2"]我希望使用其中之一。不幸的是，我终其一生都无法弄清楚如何让它发挥作用。我尝试了以下各项:我发现某处他们指出我需要在函数调用前放置“function_”……这
ruby - 如何使用 RSpec::Core::RakeTask 创建 RSpec Rake 任务？ - 2
如何使用RSpec::Core::RakeTask初始化RSpecRake任务？require'rspec/core/rake_task'RSpec::Core::RakeTask.newdo|t|#whatdoIputinhere?endInitialize函数记录在http://rubydoc.info/github/rspec/rspec-core/RSpec/Core/RakeTask#initialize-instance_method没有很好的记录；它只是说:-(RakeTask)initialize(*args,&task_block)AnewinstanceofRake
ruby - RVM 使用列表[0] - 2
是否有类似“RVMuse1”或“RVMuselist[0]”之类的内容而不是键入整个版本号。在任何时候，我们都会看到一个可能包含5个或更多ruby的列表，我们可以轻松地键入一个数字而不是X.X.X。这也有助于rvmgemset。最佳答案这在RVM2.0中是可能的=>https://docs.google.com/document/d/1xW9GeEpLOWPcddDg_hOPvK4oeLxJmU3Q5FiCNT7nTAc/edit?usp=sharing-知道链接的任何人都可以发表评论
ruby - 通过 ruby 进程共享变量 - 2
我正在编写一个gem，我必须在其中fork两个启动两个webrick服务器的进程。我想通过基类的类方法启动这个服务器，因为应该只有这两个服务器在运行，而不是多个。在运行时，我想调用这两个服务器上的一些方法来更改变量。我的问题是，我无法通过基类的类方法访问fork的实例变量。此外，我不能在我的基类中使用线程，因为在幕后我正在使用另一个不是线程安全的库。所以我必须将每个服务器派生到它自己的进程。我用类变量试过了，比如@@server。但是当我试图通过基类访问这个变量时，它是nil。我读到在Ruby中不可能在分支之间共享类变量，对吗？那么，还有其他解决办法吗？我考虑过使用单例，但我不确定这是
ruby - 通过 RVM (OSX Mountain Lion) 安装 Ruby 2.0.0-p247 时遇到问题 - 2
我的最终目标是安装当前版本的RubyonRails。我在OSXMountainLion上运行。到目前为止，这是我的过程:已安装的RVM$\curl-Lhttps://get.rvm.io|bash-sstable检查已知(我假设已批准)安装$rvmlistknown我看到当前的稳定版本可用[ruby-]2.0.0[-p247]输入命令安装$rvminstall2.0.0-p247注意:我也试过这些安装命令$rvminstallruby-2.0.0-p247$rvminstallruby=2.0.0-p247我很快就无处可去了。结果:$rvminstall2.0.0-p247Search

ansible通过cmdb资产接口动态创建hosts列表

有关ansible通过cmdb资产接口动态创建hosts列表的更多相关文章

随机推荐