Utilisez Nutanix avec l'API REST, partie 2

En ce qui concerne les environnements à grande échelle, il y a au moins des exigences en matière d'automatisation et de script, et jusqu'à présent, nous avons utilisé des scripts tels que perl et PowerShell, SNMP, etc., mais je pense que la demande d'API REST a augmenté récemment.
Vérifions l'API REST à partir d'un état dans lequel vous n'êtes pas sûr.
La dernière fois, j'ai regardé ce que vous pouvez faire avec l'API REST depuis l'écran Prism.
Cette fois, j'essaierai de fonctionner avec Python.

table des matières

Il est résumé dans le flux suivant
Regardez l'API REST avec Prism (précédent)
Essayez d'utiliser l'API REST avec Python (cette fois)

Présentation du script

Objectif

Accéder à un cluster spécifique et afficher les résultats de l'API REST spécifiée
Étant donné que les informations de cluster sont souvent modifiées, spécifiez-les comme fichier de paramètres dans un fichier séparé.

Flux de programme

Lire le fichier de configuration
conf.json
rest-api_list.txt
Émettre l'API REST pour le cluster
Sortie uniquement des clés spécifiques séparées par des virgules
Sortie jusqu'à ce qu'il n'y ait plus d'éléments

Faire petit à petit

Script de confirmation de processus principal

Copiez ce que vous avez ramassé

import requests
import urllib3
from urllib3.exceptions import InsecureRequestWarning
urllib3.disable_warnings(InsecureRequestWarning)
import json

IP = '10.42.8.37'
USER = 'admin'
PASSWORD = 'hogehoge'

# (1) Make Session
session = requests.Session()
session.auth = (USER, PASSWORD)
session.verify = False                              
session.headers.update({'Content-Type': 'application/json; charset=utf-8'})

# (2) Make URL
url = 'https://{}:9440/PrismGateway/services/rest/v1/cluster'.format(IP)

# (3) Send request and get Response
response = session.get(url)

# (4) Check response code
print('Response Code: {}'.format(response.status_code))
print('Response OK?: {}'.format(response.ok))

# (5) Check response body
print('Response Body:')
print(response.text)

Description du script

processus d'importation. Défini lorsque vous faites quelque chose à l'aide de la communication http

Bibliothèque de communication HTTP ** Requêtes **.
Urllib3, une collection de modules qui gèrent les URL
Ignorer mon certificat
Module Json que je n'ai pas encore utilisé mais que j'utiliserai quand même

import requests
import urllib3
from urllib3.exceptions import InsecureRequestWarning
urllib3.disable_warnings(InsecureRequestWarning)
import json

Création et initialisation des objets de session

IP / nom d'utilisateur / mot de passe sera finalement entré par un autre fichier ou utilisateur. Défini comme une constante pour le moment
Créez un objet de session à partir du module de requêtes et ajoutez-y des informations (mot de passe de l'ID utilisateur, etc.)
L'URL sera décrite plus tard comme une variable ou un fichier séparé lors du traitement.
Pas encore envoyé ici

IP = '10.42.8.37'
USER = 'admin'
PASSWORD = 'hogehoge'

# (1) Make Session
session = requests.Session()
session.auth = (USER, PASSWORD)
session.verify = False                              
session.headers.update({'Content-Type': 'application/json; charset=utf-8'})

# (2) Make URL
url = 'https://{}:9440/PrismGateway/services/rest/v1/cluster'.format(IP)

Exécuter la session

Communiquez réellement avec session.get (url).
Obtenez le code de réponse du serveur pour le débogage et le branchement conditionnel.
print (response.text) Vérifiez le résultat acquis.

# (3) Send request and get Response
response = session.get(url)

# (4) Check response code
print('Response Code: {}'.format(response.status_code))
print('Response OK?: {}'.format(response.ok))

# (5) Check response body
print('Response Body:')
print(response.text)

Le script terminé

get_vms.py
C'est un peu différent du script ci-dessus, mais ce n'est que la sortie finale.
Bien qu'il ne sort pas proprement avec la sortie standard, il peut être utilisé comme CSV.
Certains commentaires sont laissés pour un futur débogage

import requests
import urllib3
from urllib3.exceptions import InsecureRequestWarning
urllib3.disable_warnings(InsecureRequestWarning)
import json
import base64

#Lire le fichier
fin = open('cvm_info.json', 'r')

#Lire les informations du serveur
# IP = '10.42.8.37'
# USER = 'admin'
# PASSWORD = 'pass'

sv_info = json.load(fin)
IP = sv_info['cluster_address']
USER = sv_info['user_name']
PASSWORD = sv_info['cvm_password']
fin.close()

auth_str = USER + ':' + PASSWORD
auth_str = api_head = {
    'Authorization': 'Basic ' + base64.b64encode(auth_str.encode('utf-8')).decode(),
}

# (1) Make Session
session = requests.Session()
session.auth = (USER, PASSWORD)
session.verify = False                              
session.headers.update({'Content-Type': 'application/json; charset=utf-8'})

# (2) Make URL
url = 'https://{}:9440/PrismGateway/services/rest/v2.0/vms/'.format(IP)

# (3) Send request and get Response
response = session.get(url, headers=api_head)

# (4) Check response code
# print('Response Code: {}'.format(response.status_code))
# print('Response OK?: {}'.format(response.ok))

# (5) Check response body
# print('Response Body:')
# print(response.text)


# (6) text -> dict
dict_data = json.loads(response.text)

# (7)Sortie de la liste de VM CSV
i = 0
while i < dict_data['metadata']['total_entities']:
    vms= (
        dict_data['entities'][i]['name'], 
        dict_data['entities'][i]['description'], 
        dict_data['entities'][i]['num_cores_per_vcpu'],
        dict_data['entities'][i]['num_vcpus'],
        dict_data['entities'][i]['memory_mb'], 
        dict_data['entities'][i]['uuid']
        )
    print(*vms,sep=',')
    i += 1

Supplément

L'authentification de base devait être encodée avec utf-8

auth_str = USER + ':' + PASSWORD
auth_str = api_head = {
    'Authorization': 'Basic ' + base64.b64encode(auth_str.encode('utf-8')).decode(),
}

Étant donné que la quantité d'informations était à l'origine importante, seules les informations requises: Nom de la VM, description, nombre de processeurs, nombre de mémoires et uuid sont affichés.
Puisque le nombre de VM a été obtenu par total_entities, il est tourné en fonction de cela.
Je l'ai passé au type tapple (vms) une fois, mais je pense que je peux l'écrire plus magnifiquement.
Si les spécifications de l'API REST changent, vous devrez la modifier directement, elle manque donc de maintenabilité ...

# (6) text -> dict
dict_data = json.loads(response.text)

# (7)Sortie de la liste de VM CSV
i = 0
while i < dict_data['metadata']['total_entities']:
    vms= (
        dict_data['entities'][i]['name'], 
        dict_data['entities'][i]['description'], 
        dict_data['entities'][i]['num_cores_per_vcpu'],
        dict_data['entities'][i]['num_vcpus'],
        dict_data['entities'][i]['memory_mb'], 
        dict_data['entities'][i]['uuid']
        )
    print(*vms,sep=',')
    i += 1

Résultat d'exécution

L'authentification de base devait être encodée avec utf-8
Étant donné que la quantité d'informations était à l'origine importante, seules les informations requises: Nom de la VM, description, nombre de processeurs, nombre de mémoires et uuid sont affichés.
Il semble qu'il puisse être utilisé pour acquérir après des travaux de construction

PS C:\Users\oresama>  get_aos_rest.py
Move VM,RX-Autodeployed-VM,4,1,8192,ffac0fb7-6a0b-45b1-a3ea-7c8079af2364
RXAutomationPC,NutanixPrismCentral,1,4,16384,f6817073-c941-4504-8034-a1d776b03a4c
Windows 2012 VM,RX-Autodeployed-VM,4,1,8192,23647618-2d45-46ac-8909-ea1444be6d94
Windows 10 VM,RX-Autodeployed-VM,4,1,8192,59a768a1-556d-4c17-bd84-71875a666d99
AutoDC VM,RX-Autodeployed-VM,4,1,8192,68eef805-3671-4717-99d6-5a07723da365
CentOS VM,RX-Autodeployed-VM,4,1,8192,cd9d44b4-db7a-4582-91f0-44d5d27aff2b

Au fait, les données originales

{"metadata":{"grand_total_entities":6,"total_entities":6,"count":6,"start_index":0,"end_index":6},"entities":[{"allow_live_migrate":true,"gpus_assigned":false,"boot":{"disk_address":{"device_bus":"scsi","device_index":0},"boot_device_type":"disk"},"description":"RX-Autodeployed-VM","ha_priority":0,"memory_mb":8192,"name":"Move VM","num_cores_per_vcpu":4,"num_vcpus":1,"power_state":"off","timezone":"UTC","uuid":"ffac0fb7-6a0b-45b1-a3ea-7c8079af2364","vm_features":{"AGENT_VM":false,"VGA_CONSOLE":true},"vm_logical_timestamp":1,"machine_type":"pc"},{"allow_live_migrate":true,"gpus_assigned":false,"description":"NutanixPrismCentral","ha_priority":0,"host_uuid":"fab5dfe4-f92d-4ce8-b296-4790dd19f4c8","memory_mb":16384,"name":"RXAutomationPC","num_cores_per_vcpu":1,"num_vcpus":4,"power_state":"on","timezone":"UTC","uuid":"f6817073-c941-4504-8034-a1d776b03a4c","vm_features":{"AGENT_VM":false,"VGA_CONSOLE":true},"vm_logical_timestamp":2,"machine_type":"pc"},{"allow_live_migrate":true,"gpus_assigned":false,"boot":{"disk_address":{"device_bus":"scsi","device_index":0},"boot_device_type":"disk"},"description":"RX-Autodeployed-VM","ha_priority":0,"memory_mb":8192,"name":"Windows 2012 VM","num_cores_per_vcpu":4,"num_vcpus":1,"power_state":"off","timezone":"UTC","uuid":"23647618-2d45-46ac-8909-ea1444be6d94","vm_features":{"AGENT_VM":false,"VGA_CONSOLE":true},"vm_logical_timestamp":1,"machine_type":"pc"},{"allow_live_migrate":true,"gpus_assigned":false,"boot":{"disk_address":{"device_bus":"scsi","device_index":0},"boot_device_type":"disk"},"description":"RX-Autodeployed-VM","ha_priority":0,"host_uuid":"fee3e23a-2c0f-4a51-963e-289601935fd3","memory_mb":8192,"name":"Windows 10 VM","num_cores_per_vcpu":4,"num_vcpus":1,"power_state":"on","timezone":"UTC","uuid":"59a768a1-556d-4c17-bd84-71875a666d99","vm_features":{"AGENT_VM":false,"VGA_CONSOLE":true},"vm_logical_timestamp":2,"machine_type":"pc"},{"allow_live_migrate":true,"gpus_assigned":false,"boot":{"disk_address":{"device_bus":"scsi","device_index":0},"boot_device_type":"disk"},"description":"RX-Autodeployed-VM","ha_priority":0,"host_uuid":"fee3e23a-2c0f-4a51-963e-289601935fd3","memory_mb":8192,"name":"AutoDC VM","num_cores_per_vcpu":4,"num_vcpus":1,"power_state":"on","timezone":"UTC","uuid":"68eef805-3671-4717-99d6-5a07723da365","vm_features":{"AGENT_VM":false,"VGA_CONSOLE":true},"vm_logical_timestamp":2,"machine_type":"pc"},{"allow_live_migrate":true,"gpus_assigned":false,"boot":{"disk_address":{"device_bus":"scsi","device_index":0},"boot_device_type":"disk"},"description":"RX-Autodeployed-VM","ha_priority":0,"memory_mb":8192,"name":"CentOS VM","num_cores_per_vcpu":4,"num_vcpus":1,"power_state":"off","timezone":"UTC","uuid":"cd9d44b4-db7a-4582-91f0-44d5d27aff2b","vm_features":{"AGENT_VM":false,"VGA_CONSOLE":true},"vm_logical_timestamp":1,"machine_type":"pc"}]}

Résumé

J'ai pu obtenir des informations sur le cluster Nutanix en utilisant l'API REST.
Cette fois, j'ai appris ce qui suit. Cette fois, il s'agissait d'une référence de données, mais il semble que vous puissiez également prendre un instantané de la même manière.
Exécution de l'API REST (opération URL)
Formatage des données JSON
Nutanix gère les données en fonction de l'uuid de chaque VM, donc je pense qu'il peut être réutilisé car le nom et l'uuid de la VM peuvent être obtenus par cette méthode.

[PYTHON] Utilisez Nutanix avec l'API REST, partie 2

Utilisez Nutanix avec l'API REST, partie 2

table des matières

Présentation du script

Objectif

Flux de programme

Faire petit à petit

Script de confirmation de processus principal

Description du script

processus d'importation. Défini lorsque vous faites quelque chose à l'aide de la communication http

Création et initialisation des objets de session

Exécuter la session

Le script terminé

Supplément

Résultat d'exécution

Résumé