Merge pull request #174 from coinapi/SDKConsoleApp

Generating output.csv file for further processing

Author: kgrudzien

data-api/csharp-ws/CoinAPI.WebSocket.Stats.Console/Program.cs

@@ -165,7 +165,7 @@ public async Task MakeRequest([FromService] IConfiguration configuration, string
             };
             wsClient.SendHelloMessage(hello);
 
-            _ = PrintingTaskLoopAsync(wsClient, endpoint_name, subscribe_data_type, asset, symbol, exchange,latency_type);
+            _ = PrintingTaskLoopAsync(wsClient, endpoint_name, subscribe_data_type, asset, symbol, exchange, supress_hb, latency_type);
 
             await Task.Run(() => Console.ReadKey());
         }
@@ -202,7 +202,7 @@ private void ProcessMsg(DateTime? time_exchange, DateTime? time_coinapi, Latency
 
     private async Task PrintingTaskLoopAsync(CoinApiWsClient wsClient, 
         string endpoint_name, string subscribe_data_type, string asset, 
-        string symbol, string exchange, string latency_type)
+        string symbol, string exchange, bool supress_hb, string latency_type)
     {
         var iterations = 0;
         Serilog.Log.Information($"Time: {DateTime.UtcNow}");
@@ -225,7 +225,32 @@ private async Task PrintingTaskLoopAsync(CoinApiWsClient wsClient,
 
         Serilog.Log.Information(strbld.ToString());
 
-        var process = Process.GetCurrentProcess();
+        string basePath = "output";
+        string extension = ".csv";
+
+        string csvFilePath = basePath + extension;
+        int counter = 1;
+
+        while (File.Exists(csvFilePath))
+        {
+            csvFilePath = $"{basePath}_{counter}{extension}";
+            counter++;
+        }
+
+        using (StreamWriter sw = File.CreateText(csvFilePath))
+        {
+            sw.WriteLine("Parameters:");
+            sw.WriteLine($"Endpoint Name: {endpoint_name}");
+            sw.WriteLine($"Subscribe Data Type: {subscribe_data_type}");
+            sw.WriteLine($"Asset: {asset}");
+            sw.WriteLine($"Symbol: {symbol}");
+            sw.WriteLine($"Exchange: {exchange}");
+            sw.WriteLine($"Supress heartbeat: {supress_hb}");
+            sw.WriteLine($"Latency type: {latency_type}");
+            sw.WriteLine();
+            sw.WriteLine("Timestamp;Messages;BytesReceived;WaitingCPU%;ParsingCPU%;ProcessingCPU%;LatencyMin(ms);LatencyMax(ms)");
+        }
+
 
         while (true)
         {
@@ -276,7 +301,7 @@ private async Task PrintingTaskLoopAsync(CoinApiWsClient wsClient,
 
             strbld.AppendFormat($"Messages: {msgCountOnInterval,-8}");
             strbld.AppendFormat($"| Recv bytes: {bytesCountOnInterval,-8}");
-            strbld.Append($"| CPU: wait: {cpuWaitingPercent:F2}% | parse: {cpuParsingPercent:F2}% | process: {cpuHandlingPercent:F2}%");
+            strbld.Append($"| CPU: wait: {cpuWaitingPercent:P} | parse: {cpuParsingPercent:P} | process: {cpuHandlingPercent:P}");
 
             if (latencies.Any())
             {
@@ -285,6 +310,12 @@ private async Task PrintingTaskLoopAsync(CoinApiWsClient wsClient,
             }
 
             Serilog.Log.Information(strbld.ToString());
+
+            using (StreamWriter sw = File.AppendText(csvFilePath))
+            {
+                sw.WriteLine($"\"{DateTime.UtcNow:yyyy-MM-dd HH:mm:ss}\";{msgCountOnInterval};{bytesCountOnInterval};{cpuWaitingPercent:F2};{cpuParsingPercent:F2};{cpuHandlingPercent:F2};{(latencies.Any() ? latencies.Min().TotalMilliseconds : 0):F2};{(latencies.Any() ? latencies.Max().TotalMilliseconds : 0):F2}");
+            }
+
         }
     }
 

data-api/csharp-ws/CoinAPI.WebSocket.Stats.Console/README.md

@@ -103,6 +103,7 @@ This command subscribes to quote data for the BTC_USD spot symbol in Coinbase ex
 ## Logging
 
 The application logs detailed information to the console, including subscribed data types, message counts, CPU usage, and latencies.
+Furthermore, same data is written in CSV format to the `output.csv` file in the application's root directory.    
 
 ## Stopping the Application