CMDB开发(需求分析)

import paramiko
   
# 创建SSH对象
ssh = paramiko.SSHClient()
# 允许连接不在know_hosts文件中的主机
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# 连接服务器
ssh.connect(hostname=‘c1.salt.com‘, port=22, username=‘wupeiqi‘, password=‘123‘)
   
# 执行命令
stdin, stdout, stderr = ssh.exec_command(‘df‘)
# 获取命令结果
result = stdout.read()
   
# 关闭连接
ssh.close()

import salt.client
local = salt.client.LocalClient()
local.cmd(‘*‘, ‘cmd.run‘, [‘whoami‘])

puppet中默认自带了5个report，放置在【/usr/lib/ruby/site_ruby/1.8/puppet/reports/】路径下。如果需要执行某个report，那么就在puppet的master的配置文件中做如下配置：
 
######################## on master ###################
/etc/puppet/puppet.conf
[main]
reports = store #默认
#report = true #默认
#pluginsync ＝ true #默认
 
 
####################### on client #####################
 
/etc/puppet/puppet.conf
[main]
#report = true #默认
   
[agent]
runinterval = 10
server = master.puppet.com
certname = c1.puppet.com
 
如上述设置之后，每次执行client和master同步，就会在master服务器的 【/var/lib/puppet/reports】路径下创建一个文件，主动执行：puppet agent  --test

在 /etc/puppet/modules 目录下创建如下文件结构： 

modules
└── cmdb
    ├── lib
    │   └── puppet
    │       └── reports
    │           └── cmdb.rb
    └── manifests
        └── init.pp

################ cmdb.rb ################
# cmdb.rb
require ‘puppet‘
require ‘fileutils‘
require ‘puppet/util‘
  
SEPARATOR = [Regexp.escape(File::SEPARATOR.to_s), Regexp.escape(File::ALT_SEPARATOR.to_s)].join
  
Puppet::Reports.register_report(:cmdb) do
  desc "Store server info
    These files collect quickly -- one every half hour -- so it is a good idea
    to perform some maintenance on them if you use this report (it‘s the only
    default report)."
  
  def process
    certname = self.name
    now = Time.now.gmtime
    File.open("/tmp/cmdb.json",‘a‘) do |f|
      f.write(certname)
      f.write(‘ | ‘)
      f.write(now)
      f.write("\r\n")
    end
  
  end
end


################ 配置 ################
/etc/puppet/puppet.conf
[main]
reports = cmdb
#report = true #默认
#pluginsync ＝ true #默认 

$LOAD_PATH.unshift(File.dirname(__FILE__)) unless $LOAD_PATH.include?(File.dirname(__FILE__))
require "rubygems"
require ‘pp‘
require ‘json‘
require ‘utils‘

def dmi_get_ram(cmd)

    ram_slot = []

    key_map = {
        ‘Size‘ => ‘capacity‘,
        ‘Serial Number‘ => ‘sn‘,
        ‘Type‘ => ‘model‘,
        ‘Manufacturer‘ => ‘manufactory‘,
        ‘Locator‘ => ‘slot‘,
    }

    output = Utils.facter_exec(cmd)
    devices = output.split(‘Memory Device‘)

    devices.each do |d|
      next if d.strip.empty?
      segment = {}
      d.strip.split("\n\t").each do |line|
        key, value = line.strip.split(":")
        if key_map.has_key?(key.strip)
          if key.strip == ‘Size‘
            segment[key_map[‘Size‘]] = value.chomp("MB").strip.to_i / 1024.0 # unit GB
          else
            segment[key_map[key.strip]] =  value ? value.strip : ‘‘
          end
        end
      end

      ram_slot.push(segment) unless segment.empty?
    end

    return ram_slot

end

Facter.add("ram") do
  confine :kernel => "Linux"
  setcode do

    ram_slot = []
    cmd = "dmidecode -q -t 17 2>/dev/null"
    ram_slot = dmi_get_ram(cmd)

    JSON.dump(ram_slot)

  end
end


Facter.add("ram") do
  confine :kernel => ‘windows‘
  setcode do

    ram_slot = []

    if Facter.value(:manufacturer)  =~ /.*HP.*/i
      cli = ‘C:\cmdb_report\dmidecode.exe‘
      cmd = "#{cli} -q -t 17"
      ram_slot = dmi_get_ram(cmd) if File.exist?(cli)

    else

      require ‘facter/util/wmi‘
      Facter::Util::WMI.execquery("select * from Win32_PhysicalMemory").each do | item |

        if item.DeviceLocator
          slot = item.DeviceLocator.strip
        else
          slot = ‘‘
        end

        if item.PartNumber
          model = item.PartNumber.strip
        else
          model = ‘‘
        end

        if item.SerialNumber
          sn = item.SerialNumber.strip
        else
          sn = ‘‘
        end

        if item.Manufacturer
          manufactory = item.Manufacturer.strip
        else
          manufactory = ‘‘
        end

        ram_slot.push({
         ‘capacity‘ => item.Capacity.to_i / (1024**3), # unit GB
         ‘slot‘ => slot,
         ‘model‘ => model,
         ‘sn‘ => sn,
         ‘manufactory‘ => manufactory,
       })

      end
    end

    JSON.dump(ram_slot)

  end
end