Push Performance Counter Data into a Power BI Streaming Dataset

/* 
 * Retreives Performance Counter data and pushes it to a Power BI streaming dataset.
 *    
 * Supply your own value for the Power BI push URL in the Main method.
 * Script run time (In minutes) and the push interval (In seconds) are supplied as command line arguments.
 * 
 * The properties of the PerfCounterPowerBI class must match the Power BI Streaming Dataset value names
 * in both the class and where the object is initialized at the beginning of the while loop in the
 * PushToPowerBI method.
 */

using System;
using System.Net.Http;
using System.Threading.Tasks;
using Newtonsoft.Json;
using System.Diagnostics;
using System.Threading;

namespace PowerBiStreamPerfCounters
{
    class StreamPerfCounters
    {
        static int duration;
        static int pauseInterval;

        static HttpClient client = new HttpClient();

        // Initialize Performance Counters
        static PerformanceCounter cpuCounter = new PerformanceCounter("Processor Information", "% Processor Time", "_Total");
        static PerformanceCounter memCounter = new PerformanceCounter("Memory", "Available MBytes", "");

        static int Main(string[] args)
        {
            // Validate and assign command line arguments. Any problems
            // will result in a return value of 1, which ends the script.
            if (HandleArguments(args) == 1)
            {
                return 1;
            }

            // Get the push URL by clicking on the "API Info" button for your streaming dataset
            const string pushUrl = "<Power BI push (Post) URL>";

            PushToPowerBI(pushUrl, duration, pauseInterval);
            return 0;
        }

        public static int HandleArguments(string[] args)
        {
            if (args.Length != 2)
            {
                Console.WriteLine("Please enter two numeric arguments - script run time in minutes and push interval in seconds.");
                Console.WriteLine("Usage: StreamPerfCounters 120 2");
                Console.WriteLine("Press any key to continue.");
                Console.ReadKey();
                return 1;
            }

            bool arg0Test = int.TryParse(args[0], out duration);
            bool arg1Test = int.TryParse(args[1], out pauseInterval);
            if (arg0Test == false || arg1Test == false)
            {
                Console.WriteLine("Failed to convert command line argument to a number. Both arguments must be numeric.");
                Console.WriteLine("Usage: StreamPerfCounters 120 2");
                Console.WriteLine("Press any key to continue.");
                Console.ReadKey();
                return 1;
            }

            return 0;
        }

        public static void PushToPowerBI(string url, int duration, int pauseInterval)
        {
            DateTime startTime = GetDateTimeUtc();
            DateTime currentTime = GetDateTimeUtc();

            while ((currentTime - startTime).TotalMinutes <= duration)
            {
                PerfCounterPowerBI perfCounterPowerBI = new PerfCounterPowerBI
                {
                    dateTime = GetDateTimeUtc().ToString("yyyy-MM-ddTHH:mm:ss.fffZ"),
                    pctProcessorTime = cpuCounter.NextValue().ToString(),
                    availableGBytes = (memCounter.NextValue() / 1024).ToString(),
                };

                var jsonString = JsonConvert.SerializeObject(perfCounterPowerBI);

                // Add brackets for Power BI
                var postToPowerBi = HttpPostAsync(url, "[" + jsonString + "]");

                Console.WriteLine(jsonString);

                // Pause for n seconds. Not a high degree of precision.
                Thread.Sleep(pauseInterval * 1000);
                currentTime = GetDateTimeUtc();
            }
        }

        public class PerfCounterPowerBI
        {
            // Property names must match Power BI Streaming Dataset value names
            public string dateTime { get; set; }
            public string pctProcessorTime { get; set; }
            public string availableGBytes { get; set; }
        }

        static async Task<HttpResponseMessage> HttpPostAsync(string url, string data)
        {
            // Construct an HttpContent object from StringContent
            HttpContent content = new StringContent(data);
            HttpResponseMessage response = await client.PostAsync(url, content);
            response.EnsureSuccessStatusCode();
            return response;
        }

        static DateTime GetDateTimeUtc()
        {
            return DateTime.UtcNow;
        }
    }
}

public PerformanceCounter (string categoryName, string counterName, string instanceName, string machineName);