bin/pveceph

   1 #!/usr/bin/perl -T
   2
   3 use strict;
   4 use warnings;
   5 use Getopt::Long;
   6 use Fcntl ':flock';
   7 use File::Path;
   8 use IO::File;
   9 use JSON;
  10 use Data::Dumper;
  11
  12 use PVE::SafeSyslog;
  13 use PVE::Cluster;
  14 use PVE::INotify;
  15 use PVE::RPCEnvironment;
  16 use PVE::Storage;
  17 use PVE::Tools qw(run_command);
  18 use PVE::JSONSchema qw(get_standard_option);
  19 use PVE::API2::Ceph;
  20
  21 use PVE::CLIHandler;
  22
  23 use base qw(PVE::CLIHandler);
  24
  25 $ENV{'PATH'} = '/sbin:/bin:/usr/sbin:/usr/bin';
  26
  27 initlog ('pveceph');
  28
  29 die "please run as root\n" if $> != 0;
  30
  31 PVE::INotify::inotify_init();
  32
  33 my $rpcenv = PVE::RPCEnvironment->init('cli');
  34
  35 $rpcenv->init_request();
  36 $rpcenv->set_language($ENV{LANG});
  37 $rpcenv->set_user('root@pam');
  38
  39 my $upid_exit = sub {
  40     my $upid = shift;
  41     my $status = PVE::Tools::upid_read_status($upid);
  42     exit($status eq 'OK' ? 0 : -1);
  43 };
  44
  45 my $nodename = PVE::INotify::nodename();
  46
  47 __PACKAGE__->register_method ({
  48     name => 'purge',
  49     path => 'purge',
  50     method => 'POST',
  51     description => "Destroy ceph related data and configuration files.",
  52     parameters => {
  53         additionalProperties => 0,
  54         properties => {
  55         },
  56     },
  57     returns => { type => 'null' },
  58     code => sub {
  59         my ($param) = @_;
  60
  61         my $monstat;
  62
  63         eval { $monstat = PVE::API2::Ceph::ceph_mon_status(1); };
  64         my $err = $@;
  65
  66         die "detected running ceph services- unable to purge data\n"
  67             if !$err;
  68
  69         # fixme: this is dangerous - should we really support this function?
  70         PVE::API2::Ceph::purge_all_ceph_files();
  71
  72         return undef;
  73     }});
  74
  75 __PACKAGE__->register_method ({
  76     name => 'install',
  77     path => 'install',
  78     method => 'POST',
  79     description => "Install ceph related packages.",
  80     parameters => {
  81         additionalProperties => 0,
  82         properties => {
  83             version => {
  84                 type => 'string',
  85                 enum => ['dumpling', 'emperor', 'firefly'],
  86                 optional => 1,
  87             }
  88         },
  89     },
  90     returns => { type => 'null' },
  91     code => sub {
  92         my ($param) = @_;
  93
  94         my $cephver = $param->{version} || 'dumpling';
  95
  96         local $ENV{DEBIAN_FRONTEND} = 'noninteractive';
  97
  98         my $keyurl = "https://ceph.com/git/?p=ceph.git;a=blob_plain;f=keys/release.asc";
  99
 100         print "download and import ceph reqpository keys\n";
 101         system("wget -q -O- '$keyurl'| apt-key add - 2>&1 >/dev/null") == 0 ||
 102             die "unable to download ceph release key\n";
 103
 104
 105         my $source = "deb http://ceph.com/debian-$cephver wheezy main\n";
 106
 107         PVE::Tools::file_set_contents("/etc/apt/sources.list.d/ceph.list", $source);
 108
 109         print "update available package list\n";
 110         eval { run_command(['apt-get', '-q', 'update'], outfunc => sub {}, errfunc => sub {}); };
 111
 112         run_command(['apt-get', '-q', '--assume-yes', '--no-install-recommends',
 113                      '-o', 'Dpkg::Options::=--force-confnew',
 114                      'install', '--',
 115                      'ceph', 'ceph-common', 'gdisk']);
 116
 117         return undef;
 118     }});
 119
 120 my $cmddef = {
 121     init => [ 'PVE::API2::Ceph', 'init', [], { node => $nodename } ],
 122     lspools => [ 'PVE::API2::Ceph', 'lspools', [], { node => $nodename }, sub {
 123         my $res = shift;
 124
 125         printf("%-20s %10s %10s %20s\n", "Name", "size", "pg_num", "used");
 126         foreach my $p (sort {$a->{pool_name} cmp $b->{pool_name}} @$res) {
 127             printf("%-20s %10d %10d %20d\n", $p->{pool_name}, $p->{size}, $p->{pg_num}, $p->{bytes_used});
 128         }
 129     }],
 130     createpool => [ 'PVE::API2::Ceph', 'createpool', ['name'], { node => $nodename }],
 131     destroypool => [ 'PVE::API2::Ceph', 'destroypool', ['name'], { node => $nodename } ],
 132     createosd => [ 'PVE::API2::CephOSD', 'createosd', ['dev'], { node => $nodename }, $upid_exit],
 133     destroyosd => [ 'PVE::API2::CephOSD', 'destroyosd', ['osdid'], { node => $nodename }, $upid_exit],
 134     createmon => [ 'PVE::API2::Ceph', 'createmon', [], { node => $nodename }, $upid_exit],
 135     destroymon => [ 'PVE::API2::Ceph', 'destroymon', ['monid'], { node => $nodename }, $upid_exit],
 136     start => [ 'PVE::API2::Ceph', 'start', ['service'], { node => $nodename }, $upid_exit],
 137     stop => [ 'PVE::API2::Ceph', 'stop', ['service'], { node => $nodename }, $upid_exit],
 138     install => [ __PACKAGE__, 'install', [] ],
 139     purge => [  __PACKAGE__, 'purge', [] ],
 140     status => [ 'PVE::API2::Ceph', 'status', [], { node => $nodename }, sub {
 141         my $res = shift;
 142         my $json = JSON->new->allow_nonref;
 143         print $json->pretty->encode($res) . "\n";
 144     }],
 145 };
 146
 147 my $cmd = shift;
 148
 149 PVE::CLIHandler::handle_cmd($cmddef, "pveceph", $cmd, \@ARGV, undef, $0);
 150
 151 exit 0;
 152
 153 __END__
 154
 155 =head1 NAME
 156
 157 pveceph - tool to manage ceph services on pve nodes
 158
 159 =head1 SYNOPSIS
 160
 161 =include synopsis
 162
 163 =head1 DESCRIPTION
 164
 165 Tool to manage ceph services on pve nodes.
 166
 167 =include pve_copyright