mirror of
https://github.com/puppetlabs/vmpooler.git
synced 2026-01-26 10:08:40 -05:00
Adding rudimentary logging
This commit is contained in:
parent
fe5f2dc28a
commit
5838315609
2 changed files with 23 additions and 4 deletions
13
lib/logger.rb
Executable file
13
lib/logger.rb
Executable file
|
|
@ -0,0 +1,13 @@
|
||||||
|
require 'rubygems' unless defined?(Gem)
|
||||||
|
|
||||||
|
class Logger
|
||||||
|
def initialize
|
||||||
|
end
|
||||||
|
|
||||||
|
def log level, string
|
||||||
|
time = Time.new
|
||||||
|
stamp = time.strftime('%Y-%m-%d %H:%M:%S')
|
||||||
|
puts "[#{stamp}] #{string}"
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
|
@ -5,9 +5,11 @@ require 'redis'
|
||||||
require 'yaml'
|
require 'yaml'
|
||||||
|
|
||||||
$:.unshift(File.dirname(__FILE__))
|
$:.unshift(File.dirname(__FILE__))
|
||||||
|
require 'lib/logger'
|
||||||
require 'lib/require_relative'
|
require 'lib/require_relative'
|
||||||
require 'lib/vsphere_helper'
|
require 'lib/vsphere_helper'
|
||||||
|
|
||||||
|
logger = Logger.new
|
||||||
vsphere_helper = VsphereHelper.new
|
vsphere_helper = VsphereHelper.new
|
||||||
|
|
||||||
Dir.chdir(File.dirname(__FILE__))
|
Dir.chdir(File.dirname(__FILE__))
|
||||||
|
|
@ -74,7 +76,7 @@ loop do
|
||||||
$redis.sadd('vmware_host_pool__ready__'+pool['name'], vm)
|
$redis.sadd('vmware_host_pool__ready__'+pool['name'], vm)
|
||||||
$redis.srem('vmware_host_pool__pending__'+pool['name'], vm)
|
$redis.srem('vmware_host_pool__pending__'+pool['name'], vm)
|
||||||
|
|
||||||
puts '[>] '+vm+' moved to \'ready\' pool'
|
logger.log('s', "[>] '#{vm}' moved to 'ready' queue")
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
@ -92,7 +94,7 @@ loop do
|
||||||
$redis.srem('vmware_host_pool__ready__'+pool['name'], vm)
|
$redis.srem('vmware_host_pool__ready__'+pool['name'], vm)
|
||||||
$redis.sadd('vmware_host_pool__failed__'+pool['name'], vm)
|
$redis.sadd('vmware_host_pool__failed__'+pool['name'], vm)
|
||||||
|
|
||||||
puts '[<] '+vm+' moved to \'failed\' pool'
|
logger.log('s', "[<] '#{vm}' moved to 'failed' queue")
|
||||||
|
|
||||||
break
|
break
|
||||||
end
|
end
|
||||||
|
|
@ -103,7 +105,7 @@ loop do
|
||||||
$redis.srem('vmware_host_pool__ready__'+pool['name'], vm)
|
$redis.srem('vmware_host_pool__ready__'+pool['name'], vm)
|
||||||
$redis.sadd('vmware_host_pool__failed__'+pool['name'], vm)
|
$redis.sadd('vmware_host_pool__failed__'+pool['name'], vm)
|
||||||
|
|
||||||
puts '[<] '+vm+' moved to \'failed\' pool'
|
logger.log('s', "[<] '#{vm}' moved to 'failed' queue")
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
@ -148,16 +150,20 @@ loop do
|
||||||
)
|
)
|
||||||
|
|
||||||
# Clone the VM
|
# Clone the VM
|
||||||
|
logger.log('d', "[ ] '#{vm['hostname']}' is being cloned from '#{vm['template']}'")
|
||||||
|
|
||||||
|
start = Time.now
|
||||||
vm[vm['template']].CloneVM_Task(
|
vm[vm['template']].CloneVM_Task(
|
||||||
:folder => vsphere_helper.find_folder(pool['folder']),
|
:folder => vsphere_helper.find_folder(pool['folder']),
|
||||||
:name => vm['hostname'],
|
:name => vm['hostname'],
|
||||||
:spec => spec
|
:spec => spec
|
||||||
).wait_for_completion
|
).wait_for_completion
|
||||||
|
finish = '%.2f' % (Time.now-start)
|
||||||
|
|
||||||
# Add VM to Redis inventory ('pending' pool)
|
# Add VM to Redis inventory ('pending' pool)
|
||||||
$redis.sadd('vmware_host_pool__pending__'+pool['name'], vm['hostname'])
|
$redis.sadd('vmware_host_pool__pending__'+pool['name'], vm['hostname'])
|
||||||
|
|
||||||
puts '[+] '+vm['hostname']+' cloned from '+vm['template']
|
logger.log('s', "[+] '#{vm['hostname']}' cloned from '#{vm['template']}' in #{finish} seconds")
|
||||||
}
|
}
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue