云架构系列之一-Azure云核心内核系统架构详解

[Dynamic, Provider("CIMWin32"), SupportsCreate, CreateBy("Create"), SupportsDelete, DeleteBy("DeleteInstance"), UUID("{8502C4DC-5FBB-11D2-AAC1-006008C78BC7}"), DisplayName("Processes"), AMENDMENT]class Win32_Process : CIM_Process{  string   CreationClassName;  string   Caption;  string   CommandLine;  datetime CreationDate;  string   CSCreationClassName;  string   CSName;  string   Description;  string   ExecutablePath;  uint16   ExecutionState;  string   Handle;  uint32   HandleCount;  datetime InstallDate;  uint64   KernelModeTime;  uint32   MaximumWorkingSetSize;  uint32   MinimumWorkingSetSize;  string   Name;  string   OSCreationClassName;  string   OSName;  uint64   OtherOperationCount;  uint64   OtherTransferCount;  uint32   PageFaults;  uint32   PageFileUsage;  uint32   ParentProcessId;  uint32   PeakPageFileUsage;  uint64   PeakVirtualSize;  uint32   PeakWorkingSetSize;  uint32   Priority = NULL;  uint64   PrivatePageCount;  uint32   ProcessId;  uint32   QuotaNonPagedPoolUsage;  uint32   QuotaPagedPoolUsage;  uint32   QuotaPeakNonPagedPoolUsage;  uint32   QuotaPeakPagedPoolUsage;  uint64   ReadOperationCount;  uint64   ReadTransferCount;  uint32   SessionId;  string   Status;  datetime TerminationDate;  uint32   ThreadCount;  uint64   UserModeTime;  uint64   VirtualSize;  string   WindowsVersion;  uint64   WorkingSetSize;  uint64   WriteOperationCount;  uint64   WriteTransferCount;};

strComputer = "."Set objWMIService = GetObject("winmgmts:{impersonationLevel=impersonate}!\" & strComputer & "rootcimv2")Set colProcessList = objWMIService.ExecQuery("SELECT * FROM Win32_Process")For Each objProcess in colProcessList Wscript.Echo "Process: " & objProcess.Name Wscript.Echo "Process ID: " & objProcess.ProcessID Wscript.Echo "Thread Count: " & objProcess.ThreadCount Wscript.Echo "Page File Size: " & objProcess.PageFileUsage Wscript.Echo "Page Faults: " & objProcess.PageFaults Wscript.Echo "Working Set Size: " & objProcess.WorkingSetSizeNext

$UserName = "AzureCloudUser"$serverpass = "P@ssw0rd"
$Password = ConvertTo-SecureString $serverpass -AsPlainText –Force$cred = New-Object System.Management.Automation.PSCredential($UserName,$Password)
invoke-command -ComputerName localhost -Credential $cred -ScriptBlock { ipconfig }

<s:Envelope    xmlns:s="http://www.w3.org/2003/05/soap-envelope"   xmlns:wsa="http://schemas.xmlsoap.org/ws/2004/08/addressing"   xmlns:wsman="http://schemas.dmtf.org/wbem/wsman/1/wsman.xsd">   <s:Header>     <wsa:To>       http://localhost:80/wsman     </wsa:To>     <wsman:ResourceURI s:mustUnderstand="true">       http://schemas.microsoft.com/wbem/wsman/1/windows/shell/cmd     </wsman:ResourceURI>     <wsa:ReplyTo>       <wsa:Address s:mustUnderstand="true">         http://schemas.xmlsoap.org/ws/2004/08/addressing/role/anonymous       </wsa:Address>     </wsa:ReplyTo>     <wsa:Action s:mustUnderstand="true">       http://schemas.xmlsoap.org/ws/2004/09/transfer/Create     </wsa:Action>     <wsman:MaxEnvelopeSize s:mustUnderstand="true">153600</wsman:MaxEnvelopeSize>     <wsa:MessageID>uuid:AF6A2E07-BA33-496E-8AFA-E77D241A2F2F</wsa:MessageID>     <wsman:Locale xml:lang="en-US" s:mustUnderstand="false" />     <wsman:OptionSet xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">       <wsman:Option Name="WINRS_NOPROFILE">TRUE</wsman:Option>       <wsman:Option Name="WINRS_CODEPAGE">437</wsman:Option>     </wsman:OptionSet>     <wsman:OperationTimeout>PT60.000S</wsman:OperationTimeout>   </s:Header>   <s:Body>     <rsp:Shell  xmlns:rsp="http://schemas.microsoft.com/wbem/wsman/1/windows/shell">       <rsp:Environment>         <rsp:Variable Name="test">1</rsp:Variable>       </rsp:Environment>       <rsp:WorkingDirectory>d:windows</rsp:WorkingDirectory>       <rsp:Lifetime>PT1000.000S</rsp:Lifetime>       <rsp:InputStreams>stdin</rsp:InputStreams>       <rsp:OutputStreams>stdout stderr</rsp:OutputStreams>     </rsp:Shell>       <CommandLine xmlns='http://schemas.microsoft.com/wbem/wsman/1/windows/shell'>        <Command>powershell</Command>        <Arguments>ifconfig</Arguments>      </CommandLine>   </s:Body> </s:Envelope>

Set-Variable -Name HostAgentPort -Option Constant -Value 14200

Set-Variable -Name HostAgentFirewallRuleName -Option Constant -Value "AzsHostAgent"Set-Variable -Name HostAgentFirewallRulePort -Option Constant -Value 14200Set-Variable -Name HostAgentFirewallDisplayName -Option Constant -Value "Allow inbound TCP traffic for AzsHostAgentNew-NetFirewallRule -Name $HostAgentFirewallRuleName -DisplayName $HostAgentFirewallDisplayName -Enabled True -Direction Inbound -Action Allow -Protocol TCP -LocalPort $HostAgentFirewallRulePort

 New-Service -Name $ServiceName -DisplayName $DisplayName -BinaryPathName $ExePath -Description "This is the Host Agent Service" -StartupType Automatic $SvcWmi = Get-CimInstance -ClassName Win32_Service | Where-Object Name -eq $ServiceName $ret = Invoke-CimMethod -InputObject $SvcWmi -MethodName Change -Arguments @{StartName="$env:USERDOMAINazs-jea-comsa$";StartPassword=""}

using System.Threading.Tasks;using Microsoft.AspNetCore.Mvc;using Microsoft.AzureStack.Fabric.HostAgent.HostAgent.Client.Models;using Microsoft.AzureStack.Fabric.HostAgent.HostAgent.Client.Models.VMs;
[Route("host")][ApiController]public abstract class HostVirtualMachineController : ControllerBase{  [HttpGet("vms/{vmName}/powerState")]  public abstract Task<ActionResult<VmPowerState>> GetVmPowerState(string vmName, bool noCache = true);
  [HttpPut("vms/{vmName}")]  public abstract Task<ActionResult> PutVirtualMachine(string vmName, VirtualMachine virtualMachine);
  [HttpGet("vms/{vmName}")]  public abstract Task<ActionResult<VirtualMachine>> GetVirtualMachine(string vmName);
  [HttpDelete("vms/{vmName}")]  public abstract Task<ActionResult> DeleteVirtualMachine(string vmName);
  [HttpGet("vms/{vmName}/thumbnail/width/{widthPixels}/height/{heightPixels}")]  public abstract Task<ActionResult<VmThumbnail>> GetVirtualMachineThumbnail(string vmName, ushort widthPixels, ushort heightPixels);
  [HttpGet("vms/{vmName}/memorySettings")]  public abstract Task<ActionResult<VirtualMachineMemorySettings>> GetVirtualMachineMemorySettings(string vmName);
  [HttpPatch("vms/{vmName}/memorySettings")]  public abstract Task<ActionResult> SetVirtualMachineMemorySettings(string vmName, VirtualMachineMemorySettings virtualMachineMemorySettings);
  [HttpGet("vms/{vmName}/memoryData")]  public abstract Task<ActionResult<VirtualMachineMemoryData>> GetVirtualMachineMemoryData(string vmName);
  [HttpPut("vms/{vmName}/notes")]  public abstract Task<ActionResult> SetVmNotes(string vmName, VmNotes notes);
  [HttpGet("vms/{vmName}/smBios")]  public abstract Task<ActionResult<VmSmBios>> GetVmSmBios(string vmName);
  [HttpPut("vms/{vmName}/smBios")]  public abstract Task<ActionResult> SetVmSmBios(string vmName, VmSmBios smBios);
  [HttpPatch("vms/{vmName}/processorSettings")]  public abstract Task<ActionResult> SetVirtualMachineProcessorSettings(string vmName, VirtualMachineProcessorSettings virtualMachineProcessorSettings);
  [HttpGet("vms/{vmName}/processorSettings")]  public abstract Task<ActionResult<VirtualMachineProcessorSettings>> GetVirtualMachineProcessorSettings(string vmName);
  [HttpHead("vms/{vmName}")]  public abstract Task<ActionResult> DoesVirtualMachineExist(string vmName);
  [HttpGet("vms/{vmName}/generation")]  public abstract Task<ActionResult<VmGeneration>> GetVmGeneration(string vmName);
  [HttpGet("vms/{vmName}/hardwareProfile")]  public abstract Task<ActionResult<VmHardwareProfile>> GetVmHardwareProfile(string vmName);
  [HttpPost("vms/{vmName}")]  public abstract Task<ActionResult> UpdateVmPowerState(string vmName, string action);
  [HttpPost("vms/{vmName}/powerState")]  public abstract Task<ActionResult<Job>> AsyncUpdateVmPowerState(string vmName, string action);}

using System;using System.Diagnostics.CodeAnalysis;using System.Security.Claims;using System.Security.Cryptography.X509Certificates;using System.Threading.Tasks;using Microsoft.AspNetCore.Authentication.Certificate;using Microsoft.AzureStack.Fabric.HostAgent.HostAgent.Controllers.Contract;
[ExcludeFromCodeCoverage]public class CertificateAuthenticationHandler : ICertificateAuthenticationHandler{  private readonly X509Certificate2 peerCertificate;
  public CertificateAuthenticationHandler(X509Certificate2 peerCertificate)  {    this.peerCertificate = peerCertificate;  }
  public Task OnCertficateValidated(CertificateValidatedContext context)  {    if (IsValidCertificate(context.ClientCertificate))    {      Claim[] claims = new Claim[2]      {        new Claim("http://schemas.xmlsoap.org/ws/2005/05/identity/claims/nameidentifier", context.ClientCertificate.Subject, "http://www.w3.org/2001/XMLSchema#string", context.Options.ClaimsIssuer),        new Claim("http://schemas.xmlsoap.org/ws/2005/05/identity/claims/name", context.ClientCertificate.Subject, "http://www.w3.org/2001/XMLSchema#string", context.Options.ClaimsIssuer)      };      context.Principal = new ClaimsPrincipal(new ClaimsIdentity(claims, context.Scheme.Name));      context.Success();      return Task.CompletedTask;    }    throw new UnauthorizedAccessException($"The request is unauthorized because the client certificate thumbprint {context.ClientCertificate.Thumbprint} is not authorized");  }
  private bool IsValidCertificate(X509Certificate2 clientCertificate)  {    return clientCertificate.Thumbprint == peerCertificate.Thumbprint;  }}

using System;using System.Collections.Generic;using System.Threading.Tasks;using Microsoft.AspNetCore.Mvc;using Microsoft.AzureStack.Fabric.HostAgent.HostAgent.Client.Models;using Microsoft.AzureStack.Fabric.HostAgent.HostAgent.Core.Contract;using Microsoft.AzureStack.Fabric.HostAgent.HostAgent.Core.Models;
public override async Task<ActionResult> PutVirtualMachine(string vmName, Microsoft.AzureStack.Fabric.HostAgent.HostAgent.Client.Models.VirtualMachine virtualMachine){  if (!vmName.Equals(virtualMachine.Name, StringComparison.InvariantCultureIgnoreCase))  {    return BadRequest($"Virtual Machine name does not match the model. Uri: {vmName} Model: {virtualMachine.Name}");  }  Func<Task<ActionResult>> createVm = async delegate  {    try    {      await hostFabricManager.GetVirtualMachine(AzureVmId.Parse(vmName));      return Ok();    }    catch (FabricVmNotFoundException)    {    }    Microsoft.AzureStack.Fabric.HostAgent.HostAgent.Core.Models.VirtualMachine coreModel = converter.Convert(virtualMachine);    await hostFabricManager.CreateVirtualMachine(coreModel);    return Ok();  };  Dictionary<string, int> exceptionMapping = new Dictionary<string, int> { ["FabricVirtualMachineNotFound"] = 455 };  return await errorHandler.HandleFabricExceptions(createVm, exceptionMapping);}

await hostFabricManager.CreateVirtualMachine(coreModel);

using System.Threading.Tasks;using Microsoft.AzureStack.Fabric.HostAgent.HostAgent.Core.Models;
public async Task CreateVirtualMachine(VirtualMachine virtualMachine){  string path = await fileSharePathConverter.ConvertPathOnCluster(virtualMachine.Path);  await hyperVWmiInvoker.CreateVirtualMachine(virtualMachine.AzureVmId, path);}

using System;using System.Threading.Tasks;using Microsoft.AzureStack.Fabric.HostAgent.HostAgent.Core.Contract.Exceptions;using Microsoft.AzureStack.Fabric.HostAgent.HostAgent.Core.Models;using Microsoft.AzureStack.Fabric.HostAgent.HostAgent.Core.Source.Trace;using Microsoft.Management.Infrastructure;using Microsoft.Management.Infrastructure.Generic;using Microsoft.Management.Infrastructure.Serialization;
public async Task CreateVirtualMachine(AzureVmId azureVmId, string path){  using CimInstance vssdCimInstance = new CimInstance("Msvm_VirtualSystemSettingData", "root\virtualization\v2");  vssdCimInstance.CimInstanceProperties.Add(CimProperty.Create("ElementName", azureVmId.ToString(), CimType.String, CimFlags.Required));  vssdCimInstance.CimInstanceProperties.Add(CimProperty.Create("ConfigurationDataRoot", path, CimType.String, CimFlags.None));  vssdCimInstance.CimInstanceProperties.Add(CimProperty.Create("AutomaticShutdownAction", (ushort)4, CimType.UInt16, CimFlags.None));  byte[] serializedVssdCimInstance = cimSerializer.Serialize(vssdCimInstance, InstanceSerializationOptions.None);  using CimInstance vmmsCimInstance = await virtualSystemManagementServiceProvider.GetVmmsCimInstance();  using CimMethodParametersCollection parameters = new CimMethodParametersCollection { CimMethodParameter.Create("SystemSettings", unicodeEncoding.GetString(serializedVssdCimInstance), CimType.String, CimFlags.In) };  try  {    CimInstance resultingSystem = (CimInstance)(await cimMethodAsyncOperationPoller.InvokeMethodOnCimInstanceAndWaitForCompletion("root\virtualization\v2", "DefineSystem", parameters, vmmsCimInstance, string.Format(Literals.CreatingVirtualMachine, azureVmId.ToString(), path))).OutParameters["ResultingSystem"].Value;    using (CimInstance kvpSettings = await GetSingleKvpExchangeComponentSettingsData(azureVmId))    {      if (kvpSettings != null)      {        HostAgentLogger.DeletePreExistingDuplicateVms(azureVmId);        await TryCleanupVm(vmmsCimInstance, azureVmId);        throw new KvpSettingsForFabricVmAlreadyExistException(azureVmId);      }      await CreateKvpExchangeDataItem(resultingSystem, azureVmId);    }    Action<CimKeyedCollection<CimProperty>> updateAction = delegate(CimKeyedCollection<CimProperty> settings)    {      settings["ElementName"].Value = "SCSI Controller";      settings["VirtualSystemIdentifiers"].Value = new string[1] { "{f8b3781b-1e82-4818-a1c3-63d806ec15bb}" };    };    HypervVmId hypervVmId = HypervVmId.Parse(resultingSystem.CimInstanceProperties["Name"].Value.ToString());    await vmResourceHandler.AddResourceToVm(hypervVmId, "Microsoft:Hyper-V:Synthetic SCSI Controller", "Msvm_ResourceAllocationSettingData", updateAction);  }  catch (KvpSettingsForFabricVmAlreadyExistException e2)  {    HostAgentLogger.KvpSettingsForFabricVmAlreadyExist(azureVmId, e2);  }  catch (Exception e)  {    HostAgentLogger.AttemptVmDeletionAfterVmCreationFailure(azureVmId, e);    await TryCleanupVm(vmmsCimInstance, azureVmId);    throw;  }}

uint32 DefineSystem(  [in]  string                           SystemSettings,  [in]  string                           ResourceSettings[],  [in]  CIM_VirtualSystemSettingData REF ReferenceConfiguration,  [out] CIM_ComputerSystem           REF ResultingSystem,  [out] CIM_ConcreteJob              REF Job)

#查询物理机可用的内存SELECT AvailableMemory FROM Win32_PerfRawData_BalancerStats_HyperVDynamicMemoryBalancer#查询物理机有多少对应的虚拟机SELECT * FROM Msvm_ComputerSystem WHERE Description = 'Microsoft Virtual Machine'