Configuração
Implemente
cd /usr/share/ruby/vendor_ruby/mcollective/application
wget https://raw.githubusercontent.com/arnobroekhof/mcollective-plugin-power/master/application/power.rb
e
cd /usr/libexec/mcollective/mcollective/agent
wget https://raw.githubusercontent.com/arnobroekhof/mcollective-plugin-power/master/agent/power.ddl
wget https://raw.githubusercontent.com/arnobroekhof/mcollective-plugin-power/master/agent/power.rb
em ambos os hosts, por exemplo, test-server1
e test-server2
.
Serviços
Reinicie o coletivo em ambos os serviços:
[vagrant@test-server1 ~]# sudo service mcollective restart
e
[vagrant@test-server2 ~]# sudo service mcollective restart
Comandos
Execute os seguintes comandos no nó do servidor coletivo:
O host test-server2
está escutando:
[vagrant@test-server1 ~]$ mco ping
test-server2 time=25.32 ms
test-server1 time=62.51 ms
---- ping statistics ----
2 replies max: 62.51 min: 25.32 avg: 43.91
Reinicialize o test-server2
:
[vagrant@test-server1 ~]$ mco power reboot -I test-server2
* [ ============================================================> ] 1 / 1
test-server2 Reboot initiated
Finished processing 1 / 1 hosts in 123.94 ms
O test-server2
está reinicializando:
[vagrant@test-server1 ~]$ mco ping
test-server1 time=13.87 ms
---- ping statistics ----
1 replies max: 13.87 min: 13.87 avg: 13.87
e foi reinicializado:
[vagrant@test-server1 ~]$ mco ping
test-server1 time=22.88 ms
test-server2 time=54.27 ms
---- ping statistics ----
2 replies max: 54.27 min: 22.88 avg: 38.57
Note que também é possível desligar um host:
[vagrant@test-server1 ~]$ mco power shutdown -I test-server2
* [ ============================================================> ] 1 / 1
test-server2 Shutdown initiated
Finished processing 1 / 1 hosts in 213.18 ms
/usr/libexec/mcollective/mcollective/agent/power.rb
module MCollective module Agent class Power<RPC::Agent action "shutdown" do out = "" run("/sbin/shutdown -h now", :stdout => out, :chomp => true ) reply[:output] = "Shutdown initiated" end action "reboot" do out = "" run("/sbin/shutdown -r now", :stdout => out, :chomp => true ) reply[:output] = "Reboot initiated" end end end end # vi:tabstop=2:expandtab:ai:filetype=ruby
/usr/libexec/mcollective/mcollective/agent/power.ddl
metadata :name => "power", :description => "An agent that can shutdown or reboot them system", :author => "A.Broekhof", :license => "Apache 2", :version => "2.1", :url => "http://github.com/arnobroekhof/mcollective-plugins/wiki", :timeout => 5 action "reboot", :description => "Reboots the system" do display :always output :output, :description => "Reboot the system", :display_as => "Power" end action "shutdown", :description => "Shutdown the system" do display :always output :output, :description => "Shutdown the system", :display_as => "Power" end
/usr/share/ruby/vendor_ruby/mcollective/application/power.rb
class MCollective::Application::Power<MCollective::Application description "Linux Power broker" usage "power [reboot|shutdown]" def post_option_parser(configuration) if ARGV.size == 1 configuration[:command] = ARGV.shift end end def validate_configuration(configuration) raise "Command should be one of reboot or shutdown" unless configuration[:command] =~ /^shutdown|reboot$/ end def main mc = rpcclient("power") mc.discover :verbose => true mc.send(configuration[:command]).each do |node| case configuration[:command] when "reboot" printf("%-40s %s\n", node[:sender], node[:data][:output]) when "shutdown" printf("%-40s %s\n", node[:sender], node[:data][:output]) end end printrpcstats mc.disconnect end end # vi:tabstop=2:expandtab:ai
Código modificado
/usr/libexec/mcollective/mcollective/agent/power.ddl
metadata :name => "power",
:description => "An agent that can shutdown or reboot them system",
:author => "A.Broekhof",
:license => "Apache 2",
:version => "2.1",
:url => "http://github.com/arnobroekhof/mcollective-plugins/wiki",
:timeout => 5
action "update-and-reboot", :description => "Reboots the system" do
display :always
output :output,
:description => "Reboot the system",
:display_as => "Power"
end
/usr/libexec/mcollective/mcollective/agent/power.rb
module MCollective
module Agent
class Power<RPC::Agent
action "update-and-reboot" do
out = ""
run("yum update -y && /sbin/shutdown -r now", :stdout => out, :chomp => true )
reply[:output] = "Reboot initiated"
end
end
end
end
# vi:tabstop=2:expandtab:ai:filetype=ruby
Comando
[vagrant@test-server1 ~]$ mco power update-and-reboot -I test-server2
* [ ============================================================> ] 1 / 1
Finished processing 1 / 1 hosts in 1001.22 ms