クラスターのパフォーマンス履歴を取得する

[アーティクル]
01/31/2024

適用対象: Azure Stack HCI、バージョン 23H2 および 22H2。Windows Server 2022、Windows Server 2019

ヘルスサービスにより、記憶域スペースダイレクトクラスターから現在のパフォーマンスおよび容量の情報を取得するために必要な作業が削減されます。 1 つのコマンドレットにより、厳選された重要なメトリックの一覧が得られます。これらのメトリックは、クラスターメンバーシップを検出する組み込みロジックを使用して複数のノード間で効率的に収集され、動的に集計されます。値はすべて、リアルタイムかつ特定の時点のみのものです。

PowerShell での使用法

次のコマンドレットを使用し、記憶域スペースダイレクトクラスター全体のメトリックを取得します。

Get-ClusterPerformanceHistory

ヒント

Get-ClusterPerf エイリアスを使用すると、キーストロークが短縮されます。

また、特定のボリュームやサーバーのメトリックを取得することもできます。

Get-Volume -FileSystemLabel <Label> | Get-ClusterPerformanceHistory

Get-StorageNode -Name <Name> | Get-ClusterPerformanceHistory

.NET および C# での使用方法

このセクションでは、ヘルスサービスに接続し、検出オブジェクトを使用し、およびオブザーバーを実装してメトリックのストリーミングを開始する方法について説明します。

接続する

ヘルスサービスのクエリを実行するには、クラスターと CimSession を確立します。これを行うには、完全版の Microsoft .NET でのみ使用できるものが必要になります。つまり、Web アプリやモバイルアプリから直接は簡単には実行できません。このセクションのコードサンプルでは、このデータアクセス層のための最も単純な選択肢である C# を使用します。

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;
}

指定するユーザー名は、ターゲットコンピューターのローカル管理者である必要があります。

パスワードがプレーンテキストでメモリに格納されないようにするため、ユーザー入力からパスワードの SecureString をリアルタイムで直接構築することをお勧めします。これは、さまざまなセキュリティの問題を軽減するために役立ちます。ただし、実際には、ひな形作成の目的で上記のように構築するのが一般的です。

オブジェクトを検出します

CimSession が確立されると、クラスターで Windows Management Instrumentation (WMI) に対してクエリを実行できます。

障害またはメトリックを取得するには、いくつかの関連オブジェクトのインスタンスを取得する必要があります。まず、クラスター上の記憶域スペースダイレクトを表す MSFT_StorageSubSystem を取得します。それを使用すると、クラスター内のすべての MSFT_StorageNode や、データボリュームのすべての MSFT_Volume を取得できます。最後に、MSCluster_ClusterHealthService (ヘルスサービス自体) を取得する必要があります。

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();
}

これらは、PowerShell で Get-StorageSubSystem、Get-StorageNode、および Get-Volume のようなコマンドレットを使用して取得するものと同じオブジェクトです。

Storage Management API クラスに記載されている、同じプロパティのすべてにアクセスできます。

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());
}

GetMetric を呼び出して MetricName パラメーターのメトリック名に基づいて、専門家が厳選した重要なメトリックの一覧のストリーミングサンプルを開始します。これは、クラスターメンバーシップを検出するための組み込みロジックを使用して、ノード間で効率的に収集され、動的に集計されます。サンプルは、StreamName パラメーターから、指定された期間に基づいて到着します。

使用可能なメトリックの全一覧については、「記憶域スペースダイレクトのパフォーマンス履歴」を参照してください。

IObserver.OnNext()

このサンプルコードでは、オブザーバーデザインパターンを使用し、メトリックの新しいサンプルが到着するごとに OnNext() メソッドが呼び出されるオブザーバーを実装します。ストリーミングが終了すると、その OnCompleted() メソッドが呼び出されます。たとえば、それを使用してストリーミングを再開し、無期限に続行することができます。

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
    }
}

ストリーミングを開始する

オブザーバーを定義すると、ストリーミングを開始できます。

メトリックのスコープを設定するターゲットの CimInstance を指定します。クラスター、任意のノード、または任意のボリュームを指定できます。

count パラメーターは、ストリーミングが終了する前のサンプル数です。

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);
}

これらのメトリックは、視覚化や、データベースへの格納、または適切と思われるあらゆる方法での使用が可能です。

その他の参照情報

記憶域スペースダイレクトのパフォーマンス履歴