Cloudways API Python Example

Cloudways API Python Example.py

import urllib
import urlparse
import requests
import json
import random
import time

#Fetch Key from platform.cloudways.com/api
API_SECRET_KEY ="YOUR SECRET API KEY"
EMAIL ="YOUR EMAIL Address"
BASE_URL ="https://api.cloudways.com/api/v1/"


class callCloudwaysAPI():
    url = ""
    payload = {}
    req = ""
    access_token = {}
    headers = {}

    #Get access_token while authorizing your EMAIL and API-KEY
    def setUp(self):
        self.url = urlparse.urljoin(BASE_URL, 'oauth/access_token',)  
        self.payload = {'email': EMAIL, 'api_key': API_SECRET_KEY}
        self.req = requests.post(self.url, data=self.payload)
        self.access_token = json.loads(self.req.text).get('access_token')
        self.headers = {'Authorization': 'Bearer %s' % self.access_token}

    #Show Sample Response 
    def setUpResponse(self):
        print "\n\n *** Complete Response oauth Call ***\n"
        print self.req.text

    #Shows Server List
    def getServerRegions(self):
        self.url = urlparse.urljoin(BASE_URL, 'regions')
        self.req = requests.get(self.url, headers=self.headers)
        res = json.loads(self.req.text)
        print "\n\n*** Server Regions List ***\n"
        print res['regions']

    #Shows All Apps 
    def getAllApps(self):
        self.url = urlparse.urljoin(BASE_URL, 'apps')
        self.req = requests.get(self.url, headers=self.headers)
        res = json.loads(self.req.text)
        print "\n\n*** Application Lists ***\n"
        print res['apps']

    #Shows Launched Servers
    def getServersList(self):
        self.url = urlparse.urljoin(BASE_URL, 'server')
        self.req = requests.get(self.url, headers=self.headers)
        res = json.loads(self.req.text)
        print "\n\n*** Launched Servers List ***\n"
        print res['servers'][0]

    #Call to check Operation Details
    def isOpCompleted(self,op_id=None):
        self.url = urlparse.urljoin(BASE_URL, 'operation')
        self.req = requests.get(self.url, headers=self.headers)
        if(op_id):
            self.url = urlparse.urljoin(BASE_URL, 'operation/'+str(op_id))
            self.req = requests.get(self.url, headers=self.headers)
            res = json.loads(self.req.text)
            return res['operation']['is_completed'] 
        else:
            pass

    #Launch Server
    def launchServer(self):
        print "\n\n*** Launching Server ***\n"
        operation_id = 0
        self.payload = {
            'cloud' : 'do',
            'region': 'nyc3',
            'instance_type': '512MB',
            'application': 'wordpress',
            'app_version': '4.6.1',
            'server_label': 'API Test',
            'app_label': 'API Test',
            
            }

        self.url = urlparse.urljoin(BASE_URL, 'server')
        self.req = requests.post(self.url, headers=self.headers, data=self.payload)
        self.res = json.loads(self.req.text)
        if (self.res):
            self.operation_id = self.res['server']['operations'][0]['id']
            flag = True
            #Check if Operation is Compelted
            while(flag):
                check = self.isOpCompleted(op_id=self.operation_id)
                if (int(check)!=0):
                    flag = False
                    time.sleep(5)       
        else:
            pass
        

def main():
    CA = callCloudwaysAPI() 
    CA.setUp()
    CA.setUpResponse()  
    CA.getServerRegions()
    CA.getAllApps()
    CA.getServersList()
    CA.launchServer()


if __name__ == "__main__":
    main()