import paramiko

# 创建SSH对象

ssh = paramiko.SSHClient()

# 允许连接不在know_hosts文件中的主机

ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())

# 连接服务器

ssh.connect(hostname='c1.salt.com', port=, username='wupeiqi', password='')

# 执行命令

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 =

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 / (**), # unit GB

         'slot' => slot,

         'model' => model,

         'sn' => sn,

         'manufactory' => manufactory,

       })

      end

    end

    JSON.dump(ram_slot)

  end

end