Urus kejadian awan menggunakan API Lautan Digital-tutorial php-php.cn

使用 Digital Ocean API 管理云实例

Apakah itu Lautan Digital?

Digital Ocean ialah salah satu hos web yang paling pesat berkembang, sebahagiannya disebabkan oleh pelayan berasaskan SSD yang pantas dan pelan pengehosan $5 sebulan yang murah. Melancarkan contoh di Lautan Digital untuk ujian atau penggunaan jangka panjang adalah pantas, mudah dan berpatutan.

Dalam Membina Imej Aplikasi untuk Dijual Semula di Lautan Digital, saya menunjukkan kepada anda cara memutar instance WordPress (atau aplikasi lain) dan mengklonkannya berulang kali untuk pelanggan. Dalam tutorial ini, saya akan membimbing anda menggunakan API Lautan Digital untuk mengurus kejadian kami (juga dikenali sebagai titisan) dan mengautomasikan tugas biasa. Saya juga akan menyediakan asas kod sampel untuk menjalankan operasi API yang sangat asas yang ditulis dalam Rangka Kerja Yii untuk PHP anda boleh mendapatkan kod di Github.

Digital Ocean API

Digital Ocean API membolehkan anda mengurus titisan dan sumber secara ringkas dan secara pemprograman menggunakan permintaan HTTP. Semua fungsi yang anda kenali dalam panel kawalan Lautan Digital juga tersedia melalui API, membolehkan anda menskrip operasi kompleks mengikut keperluan situasi anda.

Dalam tutorial ini, kami akan menyepadukan perpustakaan API PHP Lautan Digital V2 pembangun Antoine Corcy ke dalam aplikasi konsol berasaskan Yii. Anda tidak perlu mengenali Yii untuk menggunakan aplikasi ini, tetapi anda boleh mengetahui lebih lanjut di sini: Pengenalan kepada Rangka Kerja Yii.

Digital Ocean API mengesahkan akaun anda melalui OAuth dan terdiri daripada hampir sedozen kawasan premium:

Akaun: Berikan maklumat asas tentang akaun Lautan Digital anda.
Operasi: Log sejarah operasi Titisan dalam akaun anda.
Nama Domain dan Rekod Domain: Membolehkan anda mengurus nama domain yang digunakan pada titisan dalam akaun anda dan rekod DNS yang dikaitkan dengannya.
Titisan dan Tindakan Titisan: Membolehkan anda membuat, menutup, memulakan semula, syot kilat, dsb. untuk Titisan.
Imej dan Tindakan Imej: Membolehkan anda menghitung dan mengurus imej syot kilat yang diambil untuk Titisan dalam akaun anda.
SSH Keys: Membolehkan anda mendaftarkan kunci SSH untuk pemasangan semasa membuat titisan, jadi keselamatan kata laluan tidak diperlukan.
Wilayah: Menghitung kawasan geografi di mana titisan lautan digital boleh dibuat.
Saiz: Hitungkan saiz titisan yang boleh digunakan semasa membuat titisan.

Sekarang anda mengetahui beberapa API, mari kita selami aplikasi kita sendiri.

Tetapkan kunci akses

Untuk menggunakan API, anda perlu mengaktifkan token akses peribadi untuk akaun anda. Log masuk ke akaun anda dan lawati halaman aplikasi Tetapan: https://cloud.digitalocean.com/settings/applications. Klik untuk menjana token baharu , seperti yang ditunjukkan di bawah:

使用 Digital Ocean API 管理云实例

Tulis token akses anda di bawah - Lautan Digital hanya akan menunjukkan kepada anda sekali:

使用 Digital Ocean API 管理云实例

Sekarang, mari kita beralih ke aplikasi konsol contoh.

Apl konsol kami

Dalam tutorial ini, kami akan meneroka aplikasi konsol kecil yang saya bina yang melaksanakan beberapa tugas yang berkaitan dengan mengurus Titisan. Anda boleh memasang sendiri aplikasi daripada repositori Tuts+ GitHub dan menyesuaikan atau memanjangkannya untuk melaksanakan fungsi API tambahan yang anda inginkan. Saya telah menyiarkan panduan pemasangan terperinci untuk aplikasi konsol di tapak web saya. Anda juga boleh menyemak imbas panduan pemasangan am saya untuk apl Lautan Digital.

Konfigurasikan akses API

Kami sekali lagi menggunakan perpustakaan API PHP Lautan Digital V2 Antoine Corcy untuk mengakses API.

Kami membina komponen bernama Ocean.php yang bertindak sebagai model untuk menggunakan perpustakaannya. Ia terletak di /app/protected/components/Ocean.php. /app/protected/components/Ocean.php。

Yii 从 Ocean.ini 文件加载您的访问令牌（如《数字海洋控制台应用程序安装指南》中所述），并实例化 digitalOcean API 对象。

<?php

use DigitalOceanV2\Adapter\BuzzAdapter;
use DigitalOceanV2\DigitalOceanV2;

class Ocean extends CComponent
{
  private $adapter;
  private $digitalOcean;
  
   function __construct() {     
     // create an adapter with your access token which can be
     // generated at https://cloud.digitalocean.com/settings/applications
     $this->adapter = new BuzzAdapter(Yii::app()->params['ocean']['access_key']);
     // create a digital ocean object with the previous adapter
     $this->digitalOcean = new DigitalOceanV2($this->adapter);
  }

Salin selepas log masuk

获取 Droplet

使用 Digital Ocean API 管理云实例

现在，让我们获取活跃 Droplet 的列表。在 /app/protected/models/Droplet.php 中，我们的 sync 方法调用 Ocean 组件并获取 Droplet：

    public function sync() {
    $ocean = new Ocean();
    $droplets = $ocean->getDroplets();
    foreach ($droplets as $d) {
      $droplet_id = $this->add($d);
    }	      
  }

Salin selepas log masuk

Ocean getDroplets 方法如下所示：

  public function getDroplets() {
    // return the action api
    $action  = $this->digitalOcean->droplet();
    // return a collection of Action entity
    $actions = $action->getAll();    
    return $actions;
  }

Salin selepas log masuk

注意：基本控制台应用程序仅对我们的 Droplet 列表进行单向下载同步。您可以自己实现更多功能，包括删除已在云端删除的水滴。

这是我们的 Droplet 模型的 add

Yii memuatkan token akses anda daripada fail Ocean.ini (seperti yang diterangkan dalam Panduan Pemasangan Aplikasi Konsol Lautan Digital) dan menjadikan objek API digitalOcean. 🎜

public function add($droplet) {
     $d = Droplet::model()->findByAttributes(array('droplet_id'=>$droplet->id));
    if (empty($d)) {
      $d = new Droplet;
    }
    $d->user_id = Yii::app()->user->id;
      $d->droplet_id = $droplet->id;
      $d->name = $droplet->name;
      $d->vcpus = $droplet->vcpus;
      $d->memory = $droplet->memory;
      $d->disk = $droplet->disk;
      $d->status = $droplet->status;
      $d->active =1;
     $d->created_at = $d->created_at;
     $d->modified_at =new CDbExpression('NOW()');          
     $d->save();
    return $d->id;
   }

Salin selepas log masuk

🎜Dapatkan Titisan🎜 🎜 Urus kejadian awan menggunakan API Lautan Digital

🎜🎜Sekarang, mari dapatkan Senarai daripada Titisan aktif. Dalam /app/protected/models/Droplet.php, kaedah sync kami memanggil komponen Ocean dan mendapatkan Droplet: 🎜

   public function sync() {
     $ocean = new Ocean();
     $snapshots = $ocean->getSnapshots();
     foreach ($snapshots as $i) {
       $image_id = $this->add($i);
       if ($image_id!==false) {
         echo $image_id;lb();
         pp($i);        
       }
     }          
   }

Salin selepas log masuk

🎜Kaedah getDroplets Ocean adalah seperti berikut: 🎜

  public function getSnapshots() {
    // return the action api
    $action  = $this->digitalOcean->image();
    // return a collection of Action entity
    $actions = $action->getAll();    
    return $actions;
  }

Salin selepas log masuk

🎜🎜NOTA: 🎜Apl konsol asas hanya melakukan penyegerakan muat turun sehala senarai titisan kami. Anda boleh melaksanakan lebih banyak fungsi sendiri, termasuk memadam titisan yang telah dipadamkan dalam awan. 🎜 🎜Ini ialah fungsi add untuk model Droplet kami. Jika titisan itu sudah wujud, kami hanya mengemas kini rekod: 🎜

public function add($droplet) {
     $d = Droplet::model()->findByAttributes(array('droplet_id'=>$droplet->id));
    if (empty($d)) {
      $d = new Droplet;
    }
    $d->user_id = Yii::app()->user->id;
      $d->droplet_id = $droplet->id;
      $d->name = $droplet->name;
      $d->vcpus = $droplet->vcpus;
      $d->memory = $droplet->memory;
      $d->disk = $droplet->disk;
      $d->status = $droplet->status;
      $d->active =1;
     $d->created_at = $d->created_at;
     $d->modified_at =new CDbExpression('NOW()');          
     $d->save();
    return $d->id;
   }

Salin selepas log masuk

如果您希望扩展模型的功能，Digital Ocean 提供了各种 Droplet API 操作，Corcy 在此列出了清晰的示例。

获取图像

接下来，我们将使用 API 来获取当前图像的列表。映像是快照，本质上是备份，是在给定时间点从服务器实例获取的。

使用 Digital Ocean API 管理云实例

我们的 Snapshot.php 模型有一个 sync 操作，它会请求图像列表并添加将它们分别写入数据库：

   public function sync() {
     $ocean = new Ocean();
     $snapshots = $ocean->getSnapshots();
     foreach ($snapshots as $i) {
       $image_id = $this->add($i);
       if ($image_id!==false) {
         echo $image_id;lb();
         pp($i);        
       }
     }          
   }

Salin selepas log masuk

这是海洋组件 getSnapshots 代码：

  public function getSnapshots() {
    // return the action api
    $action  = $this->digitalOcean->image();
    // return a collection of Action entity
    $actions = $action->getAll();    
    return $actions;
  }

Salin selepas log masuk

这是快照模型 add 代码 - 我们忽略 Digital Ocean 的库存应用程序映像，这些映像被区分为公共：

   public function add($snapshot) {
      $i = Snapshot::model()->findByAttributes(array('image_id'=>$snapshot->id));
     if (empty($i)) {
       $i = new Snapshot;
       $i->created_at =new CDbExpression('NOW()');          
     }
     if (isset($snapshot->public) and $snapshot->public ==1) {
       return false; // no need to save public images right now
     } else 
       $i->user_id = Yii::app()->user->id;       
       $i->image_id = $snapshot->id;
       $i->name = $snapshot->name;
       $i->region = $snapshot->regions[0];
       $i->active =1;
       $i->modified_at =new CDbExpression('NOW()');          
      $i->save();
    return $i->id;
    }

Salin selepas log masuk

自动化快照

正如我们在构建要在 Digital Ocean 进行转售的应用映像中所讨论的那样，自动创建可传输给客户和顾客的快照非常有用。遗憾的是，目前无法通过引用克隆或传输图像；每次您将快照转移到另一个帐户时，它就会消失。

由于 Digital Ocean 要求您将图像实例化为 Droplet，并在拍摄新快照之前将其关闭，因此重复创建快照是一个耗时的手动过程。 Digital Ocean 在拍摄快照后再次启动水滴并没有什么帮助，这只会减慢进程。

由于 API 在其他操作挂起时不接受请求，因此我们必须构建一个表来跟踪后台操作并使用 cron 作业来重复断电、快照操作。其工作原理如下：

访问图像页面，然后单击您想要克隆的快照的查看。然后，单击右侧的复制菜单选项。

使用 Digital Ocean API 管理云实例

这将创建一个 Droplet 并使用此 image_id 和droplet_id。 end_stage 是一个常量，您可以设置它来指示要创建的重复项的数量。

使用 Digital Ocean API 管理云实例

这是 Snapshot 模型的 replicate() 方法：

    public function replicate($id) {
        // look up image_id
      $snapshot = Snapshot::model()->findByAttributes(array('id'=>$id));
  	  // create the droplet 
      $ocean = new Ocean();
      $droplet_id = $ocean->launch_droplet($snapshot->name,$snapshot->region,$snapshot->image_id);
  	  // add command to action table with droplet_id and image_id
      $a = new Action();
      $a->droplet_id = $droplet_id;
      $a->snapshot_id = $snapshot->image_id;
      $a->action = Action::ACTION_SNAPSHOT;
      $a->status = Action::STATUS_ACTIVE;
      $a->stage = 0;
    // user settable constant for number of replications to make
      $a->end_stage = Snapshot::NUMBER_REPLICATIONS;
      $a->last_checked = 0;
      $a->modified_at =new CDbExpression('NOW()');          
      $a->created_at =new CDbExpression('NOW()');          
      $a->save(); 
    }

Salin selepas log masuk

cron 任务将 ping http://ocean.yourdomain.com/daemon/index 以定期处理操作表。任何未完成的逾期项目都将请求另一个快照。

这是 Action 模型的 process() 方法：

    public function process() {
	  set_time_limit(0);
	  // look for overdue actions	  
	  $todo = Action::model()->overdue()->findAllByAttributes(array('status'=>self::STATUS_ACTIVE));
	  foreach ($todo as $item) {
	    if ($item->action == self::ACTION_SNAPSHOT) {
          $result = Snapshot::model()->take($item->id);          
	    }
	  }
	}

Salin selepas log masuk

快照过程将关闭 Droplet，暂停 20 秒等待 Droplet 关闭，并请求快照。

使用 Digital Ocean API 管理云实例

这是 Snapshot 模型的 take() 方法：

 public function take($action_id) {
    $result = false;
      $a = Action::model()->findByPk($action_id);
    $snapshot = Snapshot::model()->findByAttributes(array('image_id'=>$a->snapshot_id));
    $ocean = new Ocean();
    // attempt shutdown
    // take snapshot
    $result = $ocean->snapshot($a->stage,$a->droplet_id,$snapshot->name,$snapshot->region,$snapshot->image_id);
    // if snapshot was successful
    if ($result) {
      // increment stage
      $a->stage+=1;
      // if last snapshot replication complete, end action
      if ($a->stage >= $a->end_stage)  
        $a->status = Action::STATUS_COMPLETE;
    } 
	  // either way, update last_checked
    $a->last_checked = time();
    $a->save();              
	  return $result;
  }

Salin selepas log masuk

以下是 Ocean 组件中用于实际进行 API 调用的代码：

public function snapshot($stage,$droplet_id,$name,$region,$image_id,$begin=1,$count=3,$size='512mb') {
    $no_sleep = false;
    $name = str_replace("_","-",$name);
    $droplet  = $this->digitalOcean->droplet();
      try {
        echo 'Shutting down '.$droplet_id;lb();
        $shutdown = $droplet->shutdown($droplet_id);
      } catch (Exception $e) {
          $err = $e->getMessage();
          echo 'Caught exception: ',  $e->getMessage(), "\n";
          if (stristr ( $err , 'already powered off')===false)
            return false;
          else
            $no_sleep = true;
      }
    if (!$no_sleep) {
      echo 'Sleep 20 seconds for power off...';lb();
      sleep(20);              
    }
    echo 'Take snapshot of '.$droplet_id.' named '.$name.'-copy-'.$stage;lb();
    try {
      $snapshot = $droplet->snapshot($droplet_id, $name.'-copy-'.$stage); 
    } catch (Exception $e) {
        echo 'Caught exception: ',  $e->getMessage(), "\n";
        return false;
    }
    // shutdown and snapshot successful
    return true;
  }

Salin selepas log masuk

如果您访问 Digital Ocean 网站查看 Droplet，您将看到正在进行的操作：

使用 Digital Ocean API 管理云实例