Skip to content

Commit

Permalink
Update getInventory.pl
Browse files Browse the repository at this point in the history
  • Loading branch information
@vmdude
vmdude authored Jun 16, 2016
1 parent 77f1d51 commit 63c9a49
Showing 1 changed file with 127 additions and 127 deletions.
254 changes: 127 additions & 127 deletions root/getInventory.pl
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,132 +19,133 @@
$ENV{'PERL_LWP_SSL_VERIFY_HOSTNAME'} = 0;

sub sexiprocess {
my $logger = Log::Log4perl->get_logger('sexigraf.getInventory');
my $u_item;
my @user_list;
my $password;
my $url;
my $vm_views;
my $logger = Log::Log4perl->get_logger('sexigraf.getInventory');
my $u_item;
my @user_list;
my $password;
my $url;
my $vm_views;

# set graphite target
my $graphite = Net::Graphite->new(
# except for host, these hopefully have reasonable defaults, so are optional
host => '127.0.0.1',
port => 2003,
trace => 0, # if true, copy what's sent to STDERR
proto => 'tcp', # can be 'udp'
timeout => 1, # timeout of socket connect in seconds
fire_and_forget => 1, # if true, ignore sending errors
return_connect_error => 0, # if true, forward connect error to caller
);
# set graphite target
my $graphite = Net::Graphite->new(
# except for host, these hopefully have reasonable defaults, so are optional
host => '127.0.0.1',
port => 2003,
trace => 0, # if true, copy what's sent to STDERR
proto => 'tcp', # can be 'udp'
timeout => 1, # timeout of socket connect in seconds
fire_and_forget => 1, # if true, ignore sending errors
return_connect_error => 0, # if true, forward connect error to caller
);

my ( $listVM_ref, $s_item ) = @_;
my $exec_start = time;
my $normalizedServerName = $s_item;
@user_list = VMware::VICredStore::get_usernames (server => $s_item);
if (scalar @user_list == 0) {
$logger->logdie ("[ERROR] No credential store user detected for $s_item");
} elsif (scalar @user_list > 1) {
$logger->logdie ("[ERROR] Multiple credential store user detected for $s_item");
} else {
foreach $u_item (@user_list) {
$password = VMware::VICredStore::get_password (server => $s_item, username => $u_item);
$url = "https://" . $s_item . "/sdk";
$normalizedServerName =~ s/[ .]/_/g;
$normalizedServerName = lc ($normalizedServerName);
my $sessionfile = "/tmp/vpx_${normalizedServerName}.dat";
if (defined($sessionfile) and -e $sessionfile) {
eval { Vim::load_session(service_url => $url, session_file => $sessionfile); };
if ($@) {
Vim::login(service_url => $url, user_name => $u_item, password => $password) or $logger->logdie ("[ERROR] Unable to connect to $url with username $u_item");
}
} else {
Vim::login(service_url => $url, user_name => $u_item, password => $password) or $logger->logdie ("[ERROR] Unable to connect to $url with username $u_item");
}
my ( $listVM_ref, $s_item ) = @_;
my $exec_start = time;
my $normalizedServerName = $s_item;
@user_list = VMware::VICredStore::get_usernames (server => $s_item);
if (scalar @user_list == 0) {
$logger->logdie ("[ERROR] No credential store user detected for $s_item");
} elsif (scalar @user_list > 1) {
$logger->logdie ("[ERROR] Multiple credential store user detected for $s_item");
} else {
foreach $u_item (@user_list) {
$password = VMware::VICredStore::get_password (server => $s_item, username => $u_item);
$url = "https://" . $s_item . "/sdk";
$normalizedServerName =~ s/[ .]/_/g;
$normalizedServerName = lc ($normalizedServerName);
my $sessionfile = "/tmp/vpx_${normalizedServerName}.dat";
if (defined($sessionfile) and -e $sessionfile) {
eval { Vim::load_session(service_url => $url, session_file => $sessionfile); };
if ($@) {
Vim::login(service_url => $url, user_name => $u_item, password => $password) or $logger->logdie ("[ERROR] Unable to connect to $url with username $u_item");
}
} else {
Vim::login(service_url => $url, user_name => $u_item, password => $password) or $logger->logdie ("[ERROR] Unable to connect to $url with username $u_item");
}

if (defined($sessionfile)) {
Vim::save_session(session_file => $sessionfile);
}
my %h_cluster = ("domain-c000" => "N/A");
my %h_host = ();
my %h_hostcluster = ();
my $clusters_views = Vim::find_entity_views(view_type => 'ClusterComputeResource', properties => ['name', 'host']);
foreach my $cluster_view (@$clusters_views) {
my $cluster_name = lc ($cluster_view->name);
$h_cluster{%$cluster_view{'mo_ref'}->value} = $cluster_name;
my $cluster_hosts_views = Vim::find_entity_views(view_type => 'HostSystem', begin_entity => $cluster_view , properties => [ 'name' ]);
foreach my $cluster_host_view (@$cluster_hosts_views) {
my $host_name = lc ($cluster_host_view->{'name'});
$h_host{%$cluster_host_view{'mo_ref'}->value} = $host_name;
$h_hostcluster{%$cluster_host_view{'mo_ref'}->value} = %$cluster_view{'mo_ref'}->value;
}
}
my $StandaloneComputeResources = Vim::find_entity_views(view_type => 'ComputeResource', filter => {'summary.numHosts' => "1"}, properties => [ 'host' ]);
foreach my $StandaloneComputeResource (@$StandaloneComputeResources) {
if ($StandaloneComputeResource->{'mo_ref'}->type eq "ComputeResource" ) {
my @StandaloneResourceVMHost = Vim::get_views(mo_ref_array => $StandaloneComputeResource->host, properties => ['name']);
my $StandaloneResourceVMHostName = $StandaloneResourceVMHost[0][0]->{'name'};
$h_host{$StandaloneResourceVMHost[0][0]->{'mo_ref'}->value} = $StandaloneResourceVMHostName;
}
}
$vm_views = Vim::find_entity_views(view_type => 'VirtualMachine', properties => ['name','guest','summary.config.vmPathName','runtime.host','network','summary.config.numCpu','summary.config.memorySizeMB','summary.storage']);
foreach my $vm_view (@$vm_views) {
my $vnics = $vm_view->guest->net;
my @vm_pg_string = ();
my @vm_ip_string = ();
my @vm_mac = ();
foreach (@$vnics) {
($_->macAddress) ? push(@vm_mac, $_->macAddress) : push(@vm_mac, "N/A");
($_->network) ? push(@vm_pg_string, $_->network) : push(@vm_pg_string, "N/A");
if ($_->ipConfig) {
my $ips = $_->ipConfig->ipAddress;
foreach (@$ips) {
if ($_->ipAddress and $_->prefixLength <= 32) {
push(@vm_ip_string, $_->ipAddress);
}
}
} else {
push(@vm_ip_string, "N/A");
}
}
my $vcentersdk = new URI::URL $vm_view->{'vim'}->{'service_url'};
my %h_vm : shared = (
VM => $vm_view->name,
VCENTER => $vcentersdk->host,
CLUSTER => $h_cluster{($h_hostcluster{$vm_view->{'runtime.host'}->value} ? $h_hostcluster{$vm_view->{'runtime.host'}->value} : "domain-c000")},
HOST => $h_host{$vm_view->{'runtime.host'}->value},
VMXPATH => $vm_view->{'summary.config.vmPathName'},
PORTGROUP => join(',', @vm_pg_string),
IP => join(',', @vm_ip_string),
NUMCPU => ($vm_view->{'summary.config.numCpu'} ? $vm_view->{'summary.config.numCpu'} : "N/A"),
MEMORY => ($vm_view->{'summary.config.memorySizeMB'} ? $vm_view->{'summary.config.memorySizeMB'} : "N/A"),
COMMITED => int($vm_view->{'summary.storage'}->committed / 1073741824),
PROVISIONNED => int(($vm_view->{'summary.storage'}->committed + $vm_view->{'summary.storage'}->uncommitted) / 1073741824),
DATASTORE => (split /\[/, (split /\]/, $vm_view->{'summary.config.vmPathName'})[0])[1],
MAC => join(',', @vm_mac)
);
push( @{$listVM_ref}, \%h_vm );
}
}
}
my $exec_duration = time - $exec_start;
my $vm_exec_duration_h = { time() => { "$normalizedServerName.vm" . ".exec.duration", $exec_duration } };
$graphite->send(path => "vi.", data => $vm_exec_duration_h) or $logger->logdie ("[ERROR] Unable to send to graphite instance.");
$logger->info("[INFO] Successfully retrieve " . scalar @$vm_views . " VM for vCenter server $s_item in ${exec_duration}s");
if (defined($sessionfile)) {
Vim::save_session(session_file => $sessionfile);
}
my %h_cluster = ("domain-c000" => "N/A");
my %h_host = ();
my %h_hostcluster = ();
my $clusters_views = Vim::find_entity_views(view_type => 'ClusterComputeResource', properties => ['name', 'host']);
foreach my $cluster_view (@$clusters_views) {
my $cluster_name = lc ($cluster_view->name);
$h_cluster{%$cluster_view{'mo_ref'}->value} = $cluster_name;
my $cluster_hosts_views = Vim::find_entity_views(view_type => 'HostSystem', begin_entity => $cluster_view , properties => [ 'name' ]);
foreach my $cluster_host_view (@$cluster_hosts_views) {
my $host_name = lc ($cluster_host_view->{'name'});
$h_host{%$cluster_host_view{'mo_ref'}->value} = $host_name;
$h_hostcluster{%$cluster_host_view{'mo_ref'}->value} = %$cluster_view{'mo_ref'}->value;
}
}
my $StandaloneComputeResources = Vim::find_entity_views(view_type => 'ComputeResource', filter => {'summary.numHosts' => "1"}, properties => [ 'host' ]);
foreach my $StandaloneComputeResource (@$StandaloneComputeResources) {
if ($StandaloneComputeResource->{'mo_ref'}->type eq "ComputeResource" ) {
my @StandaloneResourceVMHost = Vim::get_views(mo_ref_array => $StandaloneComputeResource->host, properties => ['name']);
my $StandaloneResourceVMHostName = $StandaloneResourceVMHost[0][0]->{'name'};
$h_host{$StandaloneResourceVMHost[0][0]->{'mo_ref'}->value} = $StandaloneResourceVMHostName;
}
}
$vm_views = Vim::find_entity_views(view_type => 'VirtualMachine', properties => ['name','guest','summary.config.vmPathName','runtime.host','network','summary.config.numCpu','summary.config.memorySizeMB','summary.storage']);
foreach my $vm_view (@$vm_views) {
my $vnics = $vm_view->guest->net;
my @vm_pg_string = ();
my @vm_ip_string = ();
my @vm_mac = ();
foreach (@$vnics) {
($_->macAddress) ? push(@vm_mac, $_->macAddress) : push(@vm_mac, "N/A");
($_->network) ? push(@vm_pg_string, $_->network) : push(@vm_pg_string, "N/A");
if ($_->ipConfig) {
my $ips = $_->ipConfig->ipAddress;
foreach (@$ips) {
if ($_->ipAddress and $_->prefixLength <= 32) {
push(@vm_ip_string, $_->ipAddress);
}
}
} else {
push(@vm_ip_string, "N/A");
}
}
my $vcentersdk = new URI::URL $vm_view->{'vim'}->{'service_url'};
my $cluster = $h_cluster{($h_hostcluster{$vm_view->{'runtime.host'}->value} ? $h_hostcluster{$vm_view->{'runtime.host'}->value} : "domain-c000")};
my %h_vm : shared = (
VM => '<a href="/dashboard/file/VMware_Multi_Cluster_Top_N_VM_Stats.json?var-vm=' . lc($vm_view->name) . '&var-N=1" target="_blank">' . $vm_view->name . '</a>',
VCENTER => $vcentersdk->host,
CLUSTER => '<a href="/dashboard/file/VMware_Cluster_FullStats.json?var-cluster=' . $cluster . '" target="_blank">' . $cluster . '</a>',
HOST => $h_host{$vm_view->{'runtime.host'}->value},
VMXPATH => $vm_view->{'summary.config.vmPathName'},
PORTGROUP => join(',', @vm_pg_string),
IP => join(',', @vm_ip_string),
NUMCPU => ($vm_view->{'summary.config.numCpu'} ? $vm_view->{'summary.config.numCpu'} : "N/A"),
MEMORY => ($vm_view->{'summary.config.memorySizeMB'} ? $vm_view->{'summary.config.memorySizeMB'} : "N/A"),
COMMITED => int($vm_view->{'summary.storage'}->committed / 1073741824),
PROVISIONNED => int(($vm_view->{'summary.storage'}->committed + $vm_view->{'summary.storage'}->uncommitted) / 1073741824),
DATASTORE => (split /\[/, (split /\]/, $vm_view->{'summary.config.vmPathName'})[0])[1],
MAC => join(',', @vm_mac)
);
push( @{$listVM_ref}, \%h_vm );
}
}
}
my $exec_duration = time - $exec_start;
my $vm_exec_duration_h = { time() => { "$normalizedServerName.vm" . ".exec.duration", $exec_duration } };
$graphite->send(path => "vi.", data => $vm_exec_duration_h) or $logger->logdie ("[ERROR] Unable to send to graphite instance.");
$logger->info("[INFO] Successfully retrieve " . scalar @$vm_views . " VM for vCenter server $s_item in ${exec_duration}s");
}

BEGIN {
Log::Log4perl::init('/etc/log4perl.conf');
$SIG{__WARN__} = sub {
my $logger = get_logger('sexigraf.getInventory');
local $Log::Log4perl::caller_depth = $Log::Log4perl::caller_depth + 1;
$logger->warn("WARN @_");
};
$SIG{__DIE__} = sub {
my $logger = get_logger('sexigraf.getInventory');
local $Log::Log4perl::caller_depth = $Log::Log4perl::caller_depth + 1;
$logger->fatal("DIE @_");
};
$SIG{__WARN__} = sub {
my $logger = get_logger('sexigraf.getInventory');
local $Log::Log4perl::caller_depth = $Log::Log4perl::caller_depth + 1;
$logger->warn("WARN @_");
};
$SIG{__DIE__} = sub {
my $logger = get_logger('sexigraf.getInventory');
local $Log::Log4perl::caller_depth = $Log::Log4perl::caller_depth + 1;
$logger->fatal("DIE @_");
};
}

my $logger = Log::Log4perl->get_logger('sexigraf.getInventory');
Expand Down Expand Up @@ -173,16 +174,16 @@ BEGIN
#my @threads;
@server_list = VMware::VICredStore::get_hosts ();
foreach $s_item (@server_list) {
#my $threadVC = threads->new(\&sexiprocess, \@listVM, $s_item);
$logger->info("[INFO] Start processing vCenter $s_item");
sexiprocess(\@listVM, $s_item);
#push(@threads, $threadVC);
$logger->info("[INFO] End processing vCenter $s_item");
#my $threadVC = threads->new(\&sexiprocess, \@listVM, $s_item);
$logger->info("[INFO] Start processing vCenter $s_item");
sexiprocess(\@listVM, $s_item);
#push(@threads, $threadVC);
$logger->info("[INFO] End processing vCenter $s_item");
}

#foreach (@threads) {
# $_->join();
# $logger->info("[INFO] Process " . $_->tid() . " terminated");
# $_->join();
# $logger->info("[INFO] Process " . $_->tid() . " terminated");
#}

$template->param( VM => \@listVM );
Expand All @@ -192,4 +193,3 @@ BEGIN
close($fh);
my ($login,$pass,$uid,$gid) = getpwnam("www-data");
chown $uid, $gid, $fileOutput or $logger->logdie ("[ERROR] Unable to chown inventory file $fileOutput");

0 comments on commit 63c9a49

Please sign in to comment.