Obter histórico de desempenho do cluster
Aplica-se a: Azure Local, versões 23H2 e 22H2; Windows Server 2022, Windows Server 2019
O Serviço de Integridade reduz o trabalho necessário para obter informações de desempenho e capacidade em tempo real do cluster do Storage Spaces Direct. Um cmdlet fornece uma lista selecionada de métricas essenciais, que são coletadas de forma eficiente e agregadas dinamicamente entre nós, com lógica interna para detetar a associação ao cluster. Todos os valores são apenas em tempo real e de ponto no tempo.
Uso no PowerShell
Use o cmdlet a seguir para obter métricas para todo o cluster do Storage Spaces Direct:
Get-ClusterPerformanceHistory
Gorjeta
Use o alias Get-ClusterPerf para salvar alguns pressionamentos de teclas.
Você também pode obter métricas para um volume ou servidor específico:
Get-Volume -FileSystemLabel <Label> | Get-ClusterPerformanceHistory
Get-StorageNode -Name <Name> | Get-ClusterPerformanceHistory
Uso em .NET e C#
Esta seção mostra como se conectar ao Serviço de Integridade, usar objetos de descoberta e implementar um Observador para iniciar métricas de streaming.
Ligar
Para consultar o Serviço de Saúde, você estabelece uma CimSession com o cluster. Para fazer isso, você precisa de algumas coisas que só estão disponíveis no Microsoft .NET completo, o que significa que você não pode fazer isso prontamente diretamente de um aplicativo Web ou móvel. Os exemplos de código nesta seção usam C#, a opção mais simples para essa camada de acesso a dados.
using System.Security;
using Microsoft.Management.Infrastructure;
public CimSession Connect(string Domain = "...", string Computer = "...", string Username = "...", string Password = "...")
{
SecureString PasswordSecureString = new SecureString();
foreach (char c in Password)
{
PasswordSecureString.AppendChar(c);
}
CimCredential Credentials = new CimCredential(
PasswordAuthenticationMechanism.Default, Domain, Username, PasswordSecureString);
WSManSessionOptions SessionOptions = new WSManSessionOptions();
SessionOptions.AddDestinationCredentials(Credentials);
Session = CimSession.Create(Computer, SessionOptions);
return Session;
}
O nome de usuário fornecido deve ser um administrador local do computador de destino.
Recomendamos construir o Password SecureString diretamente da entrada do usuário em tempo real, para que a senha nunca seja armazenada na memória em texto não criptografado. Isso ajuda a mitigar uma variedade de preocupações de segurança. Mas, na prática, construí-lo como acima é comum para fins de prototipagem.
Descobrir objetos
Com o CimSession estabelecido, você pode consultar a Instrumentação de Gerenciamento do Windows (WMI) no cluster.
Antes de obter falhas ou métricas, você precisa obter instâncias de vários objetos relevantes. Primeiro, obtenha o MSFT_StorageSubSystem que representa os Espaços de Armazenamento Diretos no cluster. Usando isso, você pode obter todos os MSFT_StorageNode no cluster e cada MSFT_Volume dos volumes de dados. Por fim, é preciso obter o MSCluster_ClusterHealthService, o próprio Serviço de Saúde.
CimInstance Cluster;
List<CimInstance> Nodes;
List<CimInstance> Volumes;
CimInstance HealthService;
public void DiscoverObjects(CimSession Session)
{
// Get MSFT_StorageSubSystem for Storage Spaces Direct
Cluster = Session.QueryInstances(@"root\microsoft\windows\storage", "WQL", "SELECT * FROM MSFT_StorageSubSystem")
.First(Instance => (Instance.CimInstanceProperties["FriendlyName"].Value.ToString()).Contains("Cluster"));
// Get MSFT_StorageNode for each cluster node
Nodes = Session.EnumerateAssociatedInstances(Cluster.CimSystemProperties.Namespace,
Cluster, "MSFT_StorageSubSystemToStorageNode", null, "StorageSubSystem", "StorageNode").ToList();
// Get MSFT_Volumes for each data volume
Volumes = Session.EnumerateAssociatedInstances(Cluster.CimSystemProperties.Namespace,
Cluster, "MSFT_StorageSubSystemToVolume", null, "StorageSubSystem", "Volume").ToList();
// Get MSCluster_ClusterHealthService itself
HealthService = session.QueryInstances(@"root\MSCluster", "WQL", "SELECT * FROM MSCluster_ClusterHealthService").First();
}
Esses são os mesmos objetos que você obtém no PowerShell usando cmdlets como Get-StorageSubSystem, Get-StorageNode e Get-Volume.
Você pode acessar todas as mesmas propriedades, documentadas em Storage Management API Classes.
using System.Diagnostics;
foreach (CimInstance Node in Nodes)
{
// For illustration, write each node's Name to the console. You could also write State (up/down), or anything else!
Debug.WriteLine("Discovered Node " + Node.CimInstanceProperties["Name"].Value.ToString());
}
Invoque GetMetric para começar a transmitir amostras de uma lista selecionada por especialistas de métricas essenciais com base nos nomes de métricas fornecidos do parâmetro MetricName, que são coletadas de forma eficiente e agregadas dinamicamente entre nós, com lógica interna para detetar a associação ao cluster. As amostras chegam com base no período de tempo fornecido a partir do parâmetro StreamName .
Para obter a lista completa de métricas disponíveis, consulte Histórico de desempenho para Espaços de Armazenamento Diretos.
IObserver.OnNext()
Este código de exemplo usa o Observer Design Pattern para implementar um Observer cujo método OnNext() é invocado quando cada nova amostra de métricas chega. Seu método OnCompleted() é chamado se/quando o streaming termina. Por exemplo, você pode usá-lo para reiniciar o streaming, para que ele continue indefinidamente.
class MetricsObserver<T> : IObserver<T>
{
public void OnNext(T Result)
{
// Cast
CimMethodStreamedResult StreamedResult = Result as CimMethodStreamedResult;
if (StreamedResult != null)
{
CimInstance Metric = (CimInstance)StreamedResult.ItemValue;
Console.WriteLine("MetricName: " + Metric.CimInstanceProperties["MetricId"].Value);
IEnumerable<CimInstance> Records = (IEnumerable<CimInstance>)Metric.CimInstanceProperties["Records"].Value;
foreach (CimInstance Record in Records)
{
// Each Record has "TimeStamp" and "Value. For Illustration, just print the metric"
Console.WriteLine(record.CimInstanceProperties["TimeStamp"] + ": " + record.CimInstanceProperties["Value"]);
}
// TODO: Whatever you want!
}
}
public void OnError(Exception e)
{
// Handle Exceptions
}
public void OnCompleted()
{
// Reinvoke BeginStreamingMetrics(), defined in the next section
}
}
Comece a transmitir
Com o Observador definido, pode começar a transmitir.
Especifique a CimInstance de destino para a qual você deseja que as métricas tenham escopo. Pode ser o cluster, qualquer nó ou qualquer volume.
O parâmetro count é o número de amostras antes do streaming terminar.
CimInstance Target = Cluster; // From among the objects discovered in DiscoverObjects()
public void BeginStreamingMetrics(CimSession Session, CimInstance HealthService, CimInstance Target)
{
// Set Parameters
CimMethodParametersCollection MetricsParams = new CimMethodParametersCollection();
string[] metricNames = new string[] { "ClusterNode.Cpu.Usage,ClusterNode=RRN44-13-01", "ClusterNode.Cpu.Usage.Host,ClusterNode=RRN44-13-01" };
MetricsParams.Add(CimMethodParameter.Create("MetricName", metricNames, CimType.StringArray, CimFlags.In));
MetricsParams.Add(CimMethodParameter.Create("StreamName", "LastHour", CimType.String, CimFlags.In));
// Enable WMI Streaming
CimOperationOptions Options = new CimOperationOptions();
Options.EnableMethodResultStreaming = true;
// Invoke API
CimAsyncMultipleResults<CimMethodResultBase> InvokeHandler;
InvokeHandler = Session.InvokeMethodAsync(
HealthService.CimSystemProperties.Namespace, HealthService, "GetMetric", MetricsParams, Options
);
// Subscribe the Observer
MetricsObserver<CimMethodResultBase> Observer = new MetricsObserver<CimMethodResultBase>(this);
IDisposable Disposeable = InvokeHandler.Subscribe(Observer);
}
Essas métricas podem ser visualizadas, armazenadas em um banco de dados ou usadas da maneira que você achar melhor.