基于文心一言AI大模型，编写一段python3程序以获取华为分布式块存储REST接口的实时数据_python调用服务器获取数据

#!/usr/bin/python3
#coding=utf-8
 
##__author__='daijianbing'
 
import requests
import json
  
def authenticate(username, password,url_auth):
    # 构建认证数据
    auth_data = {
        'user_name': username,
        'password': password
    }
  
    # 将认证数据转换为JSON格式
    auth_json = json.dumps(auth_data)
  
    #禁止未经验证的HTTPS
    requests.packages.urllib3.disable_warnings()
    # 发送POST请求到REST API进行身份验证
    response = requests.post(url_auth,verify = False, data=auth_json, headers={'Content-Type': 'application/json'})
  
    # 检查响应状态码，如果成功则返回认证令牌，否则抛出异常
    if response.status_code == 200:
        #print(response.json())
        return response.json()['data']['x_auth_token']
    else:
        connect = 0
        raise Exception('Authentication failed')
  
def queryStoragePool(token,url):
    # 构建认证数据
    headers = {
        'Connection': 'keep-alive',
        'X-Auth-Token': token
    }
 
    #print(headers)
 
    # 发送请求到REST API
    response = requests.get(url, verify = False, headers=headers)
 
    # 检查响应状态码，如果成功则返回认证令牌，否则抛出异常
    if response.status_code == 200:
        #print(response.json())
        return response.json()['storagePools']
    else:
        raise Exception('Authentication failed')
 
def queryPoolstatus(token,url,poolId):
    # 构建认证数据
    headers = {
        'Connection': 'keep-alive',
        'X-Auth-Token': token
    }
    params = {
        'poolId':str(poolId),
        'vbs': 'true'
    }
 
    params_json = json.dumps(params)
    #print("url:",url,"headers:",headers,"params_json:",params_json)
 
    # 发送T请求到REST API
    response = requests.get(url, verify = False, params=params, headers=headers)
 
    # 检查响应状态码，如果成功则返回认证令牌，否则抛出异常
    if response.status_code == 200:
        #print(response.json())
        return response.json()['status']
    else:
        raise Exception('Authentication failed')
 
def queryAlarms(token,url):
    # 构建认证数据
    headers = {
        'Connection': 'keep-alive',
        'X-Auth-Token': token
    }
    params = {
        'filter':"alarmStatus::1",
    }
    params_json = json.dumps(params)
    # 发送请求到REST API
    response = requests.get(url, verify = False, params=params, headers=headers)
 
    # 检查响应状态码，如果成功则返回认证令牌，否则抛出异常
    if response.status_code == 200:
        #print(response.json())
        return response.json()['data']
    else:
        raise Exception('Authentication failed')
 
# 使用示例  
username = 'zabbix'  
password = 'passwd'
hostip = '192.168.0.1'
port = '8088'
hostport = "https://"+hostip+":"+port
url_auth = hostport+'/api/v2/aa/sessions'
checkstatus = 1
requests.packages.urllib3.disable_warnings()
try:
    token = authenticate(username, password, url_auth)
    print('x_auth_token:', token)
 
    url_pool = hostport+'/dsware/service/resource/queryStoragePool'
    pools = queryStoragePool(token,url_pool)
 
    url_poolstatus=hostport+'/dsware/service/cluster/storagepool/queryStatus'
    for pool in pools:
       poolstatus=queryPoolstatus(token,url_poolstatus,pool['poolId'])
 
    url_alarms = hostport+'/api/v2/common/alarm_count'
    Alarms=queryAlarms(token,url_alarms)
    print('poolid:',pool['poolId'],'poolname:',pool['poolName'],'poolstatus:',poolstatus,'alarmcount:',Alarms['count'])
except:
    checkstatus = 0
finally:
    print("checkstatus:",checkstatus)
    print("chech over")
'
运行
运行

四、验证运行

实际运行:

# python3 --version
Python 3.9.9
# python3 healthck.py   
x_auth_token: MzMwMDE0OTkyNkEzMDAxNGUwOTcwMzE2
poolid: 0 poolname: Pool01 poolstatus: 0 alarmcount: 0
checkstatus: 1
chech over

本段代码实现了存储REST接口认证登录，查询全部的pool并列出poolid,poolname,pool状态，输出当前未恢复告警数并返回本次的检查状态（1为检查成功）。