Source code for spicerack.redfish

"""Redfish module."""
import json
import logging
from datetime import datetime, timedelta
from enum import Enum
from typing import Dict, List, Optional, Tuple

import urllib3
from requests import Response
from requests.exceptions import RequestException
from wmflib.requests import http_session

from spicerack.decorators import retry
from spicerack.exceptions import SpicerackError

logger = logging.getLogger(__name__)

[docs]class RedfishError(SpicerackError): """General errors raised by this module."""
[docs]class RedfishTaskNotCompletedError(RedfishError): """Raised when a Redfish task is not found on the server."""
[docs]class ChassisResetPolicy(Enum): """Subset of available Chassis.Reset policies compatible with all supported vendors (at this moment only Dell).""" FORCE_OFF: str = "ForceOff" """Turn off the unit immediately (nongraceful shutdown).""" FORCE_RESTART: str = "ForceRestart" """Shut down immediately and nongracefully and restart the system.""" GRACEFUL_RESTART: str = "GracefulRestart" """Shut down gracefully and power on.""" GRACEFUL_SHUTDOWN: str = "GracefulShutdown" """Shut down gracefully and power off.""" ON: str = "On" """Turn on the unit."""
[docs]class DellSCPRebootPolicy(Enum): """Available Dell SCP (Server Configuration Profiles) reboot policies.""" FORCED: str = "Forced" """Issue an immediate hard reboot without notifying the operating system.""" GRACEFUL: str = "Graceful" """Issue a reboot notifying the operating system.""" NO_REBOOT: str = "NoReboot" """Do not reboot right now, the Redfish task will be pending the next reboot to apply the changes."""
[docs]class DellSCPPowerStatePolicy(Enum): """Available Dell SCP (Server Configuration Profiles) final power state after an operation policies.""" OFF: str = "Off" """Keep the host powered off after the operation.""" ON: str = "On" """Turn the host power back on after the operation."""
[docs]class DellSCPTargetPolicy(Enum): """Available sections of the Dell SCP (Server Configuration Profiles) to target.""" ALL = "ALL" """All settings.""" BIOS = "BIOS" """Only BIOS settings.""" IDRAC = "IDRAC" """Only iDRAC settings.""" NIC = "NIC" """Only network interfaces settings.""" RAID = "RAID" """Only RAID controller settings."""
[docs]class Redfish: """Manage Redfish operations on a specific device.""" def __init__(self, fqdn: str, username: str, password: str, *, dry_run: bool = True): """Initialize the instance. Arguments: fqdn (str): the FQDN of the management console to connect to. username (str): the API username. password (str): the API password. dry_run (bool, optional): whether this is a DRY-RUN. """ self._dry_run = dry_run self._fqdn = fqdn self._username = username self._password = password self._http_session = http_session(".".join((self.__module__, self.__class__.__name__)), timeout=10) # TODO: evaluate if we should create an intermediate CA for managament consoles self._http_session.verify = False # The devices have a self-signed certificate self._http_session.auth = (self._username, self._password) self._http_session.headers.update({"Accept": "application/json"})
[docs] def request( self, method: str, uri: str, *, data: Optional[Dict] = None, headers: Optional[Dict] = None ) -> Response: """Perform a request against the target Redfish instance with the provided HTTP method and data. Arguments: uri (str): the relative URI to request. method (str): the HTTP method to use (e.g. "post"). data (dict, optional): the data to send as JSON in the request. data (dict, optional): the custom headers to set in the request. Returns: requests.models.Response: the response. Raises: RedfishError: if the response status code is between 400 and 600 or if the given uri does not start with a slash (/) or if the request couldn't be performed. """ if uri[0] != "/": raise RedfishError(f"Invalid uri {uri}, it must start with a /") url = f"https://{self._fqdn}{uri}" if self._dry_run and (data is not None or method.lower() not in ("head", "get")): # RW call"Would have called %s on %s", method, url) return self._get_dummy_response() try: response = self._http_session.request(method, url, json=data, headers=headers) except RequestException as e: message = f"Failed to perform {method.upper()} request to {url}" if self._dry_run: logger.error("%s: %s", message, e) return self._get_dummy_response() raise RedfishError(message) from e if not response.ok: raise RedfishError( f"{method.upper()} {url} returned HTTP {response.status_code} with message:\n{response.text}" ) return response
[docs] def submit_task(self, uri: str, data: Optional[Dict] = None) -> str: """Submit a request that generates a task, return the URI of the submitted task. Arguments: uri (str): the relative URI to request. data (dict, optional): the data to send in the POST request, if no data is provided a GET request is made. Returns: str: the URI of the task ID to poll the results. Raises: spicerack.redfish.RedfishError: if the response status code is not 202 or there is no Location header. """ if self._dry_run: return "/" response = self.request("post", uri, data=data) if response.status_code != 202: raise RedfishError( f"Unable to start task for {uri}, expected HTTP 202, " f"got HTTP {response.status_code} instead:\n{response.text}" ) # requests allow to access headers with any capitalization if "Location" not in response.headers or not response.headers["Location"]: raise RedfishError( "Unable to get the task URI to poll results for the {uri} request. Returned headers:\n" f"{response.headers}" ) return response.headers["Location"]
[docs] def check_connection(self) -> None: """Check the connection with the Redfish API. Raises: spicerack.redfish.RedfishError: if unable to connect to Redfish API. """"Testing Redfish API connection to %s", self._fqdn) self.request("get", "/redfish")
[docs] @retry( tries=30, delay=timedelta(seconds=30), backoff_mode="constant", exceptions=(RedfishTaskNotCompletedError,), failure_message="Polling task", ) def poll_task(self, uri: str) -> Dict: """Poll a Redfish task until the results are available. Arguments: uri (str): the URI of the task, usually returned as Location header by the originating API call. Returns: dict: the task results. Raises: RedfishError: if the response from the server is outside the expected values of HTTP 200 or 202. RedfishTaskNotCompletedError: if the task is not yet completed. """ if self._dry_run: return {} response = self.request("get", uri) if response.status_code not in (200, 202): raise RedfishError(f"{uri} returned HTTP {response.status_code}:\n{response.text}") results = response.json() if response.status_code == 200 and "" not in results: # Task completed, got data without metadata return results for message in results["Messages"]: if "Oem" in message: continue # Skip Oem messages, they might have any custom structure # Some older Dell implementation use both keys in the same API response :/ message_id = message.get("MessageId", message.get("MessageID", "N.A."))"[%s] %s", message_id, message["Message"]) if "EndTime" not in results or results["EndTime"] == "TIME_NA": raise RedfishTaskNotCompletedError( f"{results['Id']} not completed yet: status={results['TaskStatus']}, state={results['TaskState']}, " f"completed={results.get('PercentComplete', 'unknown')}%" ) return results # When a task is polled after returning the data, will return again the metadata
[docs] def find_account(self, username: str) -> Tuple[str, str]: """Find the account for the given username and return its URI. Arguments: username (str): the username to search for. Returns: tuple: a 2-element tuple with the the URI for the account and the ETag header value of the GET response. Raises: spicerack.redfish.RedfishError: if unable to find the account. """ accounts = self.request("get", "/redfish/v1/Managers/iDRAC.Embedded.1/Accounts").json() uris = [account[""] for account in accounts["Members"]] for uri in uris: response = self.request("get", uri) if response.json()["UserName"] == username: return uri, response.headers.get("ETag", "") raise RedfishError(f"Unable to find account for username {username}")
[docs] def change_user_password(self, username: str, password: str) -> None: """Change the password for the account with the given username. If the username matches the one used by the instance to connect to the API, automatically updates the instance value so that the instance will keep working. Arguments: username (str): the username to search for. password (str): the new password to set. Raises: spicerack.redfish.RedfishError: if unable to find the user or update its password. """ user_uri, etag = self.find_account(username)"Changing password for the account with username %s: %s", username, user_uri) response = self.request( "patch", user_uri, data={"UserName": username, "Password": password}, headers={"If-Match": etag} ) if response.status_code != 200: raise RedfishError(f"Got unexpected HTTP {response.status_code}, expected 200:\n{response.text}") if self._username == username and not self._dry_run: self._password = password self._http_session.auth = (self._username, self._password)"Updated current instance password to the new password") for message in response.json().get("@Message.ExtendedInfo", []): identifier = " ".join((message.get("MessageId", ""), message.get("Severity", ""))).strip() "[%s] %s | Resolution: %s", identifier, message.get("Message", ""), message.get("Resolution", "") )
[docs] def get_power_state(self) -> str: """Return the current power state of the device. Returns: str: the power state. """ response = self.request("get", "/redfish/v1/Chassis/System.Embedded.1").json() return response["PowerState"]
[docs] def chassis_reset(self, action: ChassisResetPolicy) -> None: """Perform a reset of the chassis power status. Arguments: action (spicerack.redfish.ChassisResetPolicy): the reset policy to use. Raises: spicerack.redfish.RedfishError: if unable to perform the reset. """"Resetting chassis power status for %s to %s", self._fqdn, action.value) response = self.request( "post", "/redfish/v1/Systems/System.Embedded.1/Actions/ComputerSystem.Reset", data={"ResetType": action.value}, ) if response.status_code != 204 and not self._dry_run: raise RedfishError( f"Got unexpected response HTTP {response.status_code}, expected HTTP 204: {response.text}" )
@staticmethod def _get_dummy_response() -> Response: """Return a dummy requests's Response to be used in dry-run mode. Returns: requests.Response: the dummy response. """ response = Response() response.status_code = 200 return response
[docs]class DellSCP: """Reprenset a Dell System Configuration Profile configuration as returned by Redfish API.""" def __init__(self, config: Dict, target: DellSCPTargetPolicy): """Parse the Redfish API response. Arguments: config (dict): the configuration as returned by Redfish API. target (spicerack.redfish.DellSCPTargetPolicy): describe which sections of the configuration are represented in the loaded configuration. """ self._config = config self._target = target @property def config(self) -> Dict: """Getter for the whole configuration in Dell's format.""" return self._config @property def target(self) -> DellSCPTargetPolicy: """Getter for the target that the current configuration represents.""" return self._target @property def service_tag(self) -> str: """Getter for the device Dell's Service Tag.""" return self._config["SystemConfiguration"]["ServiceTag"] @property def model(self) -> str: """Getter for the device Dell's model.""" return self._config["SystemConfiguration"]["Model"] @property def timestamp(self) -> datetime: """Getter for the timestamp when the configuration dump was generated.""" return datetime.strptime(self._config["SystemConfiguration"]["TimeStamp"], "%c") @property def comments(self) -> List[str]: """Getter for the comments associated with the configuration.""" return [ comment["Comment"] for comment in self._config["SystemConfiguration"].get("Comments", []) if "Comment" in comment ] @property def components(self) -> Dict[str, Dict[str, str]]: """Getter for the components present in the configuration in a simplified view. The returned dictionary where all the keys are recursively sorted and has the following format:: { '<component name>': { 'key1': 'value1', 'key2': 'value2', }, } """ components: Dict[str, Dict[str, str]] = {} for component in self._config["SystemConfiguration"].get("Components", []): components[component["FQDD"]] = {} for attribute in component.get("Attributes", []): components[component["FQDD"]][attribute["Name"]] = attribute["Value"] # Sort the components recursively return {component: dict(sorted(components[component].items())) for component in sorted(components)}
[docs] def set(self, component_name: str, attribute_name: str, attribute_value: str) -> bool: """Update the current configuration setting to the new value for the given key in the given component. Notes: This updates only the instance representation of the instance. To push and apply the changes to the server see :py:meth:`spicerack.redfish.RedfishDell.scp_push`. Arguments: component_name (str): the name of the component the settings belongs to. attribute_name (str): the attribute name whose value needs to be updated. attribute_value (str): the new value for the attribute to set. Returns: bool: :py:data:`True` if the value was changed, :py:data:`False` if it had already the correct value. Raises: spicerack.redfish.RedfishError: if unable to find the given component or attribute. """ for component in self._config["SystemConfiguration"]["Components"]: if component["FQDD"] != component_name: continue for i in range(len(component["Attributes"])): attribute = component["Attributes"][i] if attribute["Name"] != attribute_name: continue # Attribute found, update it if attribute["Value"] == attribute_value: "Skipped set of attribute %s -> %s, has already the correct value: %s", component_name, attribute_name, attribute["Value"], ) return False "Updated value for attribute %s -> %s%s: %s => %s", component_name, attribute_name, " (marked Set On Import to True)" if attribute["Set On Import"] == "False" else "", attribute["Value"], attribute_value, ) attribute["Value"] = attribute_value attribute["Set On Import"] = "True" return True # Attribute not found raise RedfishError(f"Unable to find attribute {component_name} -> {attribute_name}") # Component not found raise RedfishError(f"Unable to find component {component_name}")
[docs] def update(self, changes: Dict[str, Dict[str, str]]) -> bool: """Bulk update the current configuration with the set of changes provided. Notes: This updates only the instance representation of the instance. To push and apply the changes to the server see :py:meth:`spicerack.redfish.RedfishDell.scp_push`. Arguments: changes (dict): a dictionary of changes to apply in the same format of the one returned by :py:meth:`spicerack.redfish.DellSCP.components`. Returns: bool: :py:data:`True` if any of the values produced a change, :py:data:`False` if no change was made. Raises: spicerack.redfish.RedfishError: if unable to apply all the changes. """ was_changed = False for component, attributes in changes.items(): for name, value in attributes.items(): was_changed |= self.set(component, name, value) return was_changed
[docs]class RedfishDell(Redfish): """Dell specific Redfish support.""" scp_base_uri = "/redfish/v1/Managers/iDRAC.Embedded.1/Actions/Oem/EID_674_Manager"
[docs] def scp_dump(self, target: DellSCPTargetPolicy = DellSCPTargetPolicy.ALL) -> DellSCP: """Dump and return the SCP (Server Configuration Profiles) configuration. Arguments: target (spicerack.redfish.DellSCPTargetPolicy, optional): choose which sections to dump. Returns: spicerack.redfish.DellSCP: the server's configuration. Raises: spicerack.redfish.RedfishError: if the API call fail. spicerack.redfish.RedfishTaskNotCompletedError: if unable to fetch the dumped results. """ data = {"ExportFormat": "JSON", "ShareParameters": {"Target": target.value}} task_uri = self.submit_task(f"{self.scp_base_uri}.ExportSystemConfiguration", data) return DellSCP(self.poll_task(task_uri), target)
[docs] def scp_push( self, scp: DellSCP, *, reboot: DellSCPRebootPolicy = DellSCPRebootPolicy.NO_REBOOT, power_state: DellSCPPowerStatePolicy = DellSCPPowerStatePolicy.ON, preview: bool = True, ) -> Dict: """Push the SCP (Server Configuration Profiles) configuration. Arguments: scp (spicerack.redfish.DellSCP): the configuration that will pushed to the server. reboot (spicerack.redfish.DellSCPRebootPolicy, optional): which reboot policy to use to apply the changes. power_state (spicerack.redfish.DellSCPPowerStatePolicy, optional): which final power state policy to use to apply to the host after the changes have been applied. preview (bool, optional): if :py:data:`True` perform a test push of the SCP data. This will tell if the file parses correctly and would not result in any writes. The comments will tell if the new configuration would not produce any changes. Forces the reboot parameter to be :py:const:`spicerack.redfish.DellSCPRebootPolicy.NO_REBOOT`. Returns: dict: the results of the push operation. Raises: spicerack.redfish.RedfishError: if the API call fail. spicerack.redfish.RedfishTaskNotCompletedError: if unable to fetch the dumped results. """ if preview: uri = "ImportSystemConfigurationPreview" reboot = DellSCPRebootPolicy.NO_REBOOT else: uri = "ImportSystemConfiguration" data = { "ImportBuffer": json.dumps(scp.config), # The API requires a JSON-encoded string inside a JSON payload. "ShareParameters": {"Target":}, "HostPowerState": power_state.value, "ShutdownType": reboot.value, } task_id = self.submit_task(f"{self.scp_base_uri}.{uri}", data) return self.poll_task(task_id)