raven/server/AyaNova/generator/CoreJobMetricsSnapshot.cs

using System;
using System.Linq;
using System.Diagnostics;
using Microsoft.Extensions.Logging;
using AyaNova.Util;
using AyaNova.Models;
using Microsoft.EntityFrameworkCore;
//using StackExchange.Profiling;


namespace AyaNova.Biz
{
    /// <summary>
    /// called by Generator to gather server metrics and insert in db
    /// </summary>
    internal static class CoreJobMetricsSnapshot
    {
        private static ILogger log = AyaNova.Util.ApplicationLogging.CreateLogger("CoreJobMetricsSnapshot");
        private static TimeSpan tsDataRetention = new TimeSpan(365, 0, 0, 0, 0);//one year 
        private static Process _process = Process.GetCurrentProcess();

        private static TimeSpan _oldCPUTime = TimeSpan.Zero;
        private static DateTime _lastMMSnapshot = DateTime.UtcNow;       
        private static DateTime _lastDDSnapshot = DateTime.UtcNow;

        // private static DateTime _lastRpsTime = DateTime.UtcNow;
        private static double _cpu = 0;

#if(DEBUG)
       private static TimeSpan tsOneMinute = new TimeSpan(0, 1, 0);       
        private static TimeSpan ts24Hours = new TimeSpan(24, 0, 0);
#else
        private static TimeSpan tsOneMinute = new TimeSpan(0, 1, 0);      
        private static TimeSpan ts24Hours = new TimeSpan(24, 0, 0);
#endif
        ////////////////////////////////////////////////////////////////////////////////////////////////
        // DoAsync
        //
        public static void DoJob()
        {


            if (DateUtil.IsAfterDuration(_lastMMSnapshot, tsOneMinute))
            {
                /////////////////////////////////////////////
                //ONE MINUTE SNAPS
                //
                log.LogTrace("MM metrics snapshot");
                var now = DateTime.UtcNow;
                _process.Refresh();

                //CPU
                var cpuElapsedTime = now.Subtract(_lastMMSnapshot).TotalMilliseconds;
                var newCPUTime = _process.TotalProcessorTime;
                var elapsedCPU = (newCPUTime - _oldCPUTime).TotalMilliseconds;
                _cpu = elapsedCPU * 100 / Environment.ProcessorCount / cpuElapsedTime;
                _oldCPUTime = newCPUTime;

                //MEMORY
                // The memory occupied by objects.
                var Allocated = GC.GetTotalMemory(false);//bigint

                // The working set includes both shared and private data. The shared data includes the pages that contain all the 
                // instructions that the process executes, including instructions in the process modules and the system libraries.
                var WorkingSet = _process.WorkingSet64;//bigint

                // The value returned by this property represents the current size of memory used by the process, in bytes, that 
                // cannot be shared with other processes.
                var PrivateBytes = _process.PrivateMemorySize64;//bigint

              
                //NOTE: CPU percentage is *our* process cpu percentage over timeframe of last captured avg
                //So it does *not* show the entire server cpu load, only for RAVEN.
                //Overall, server stats need to be captured / viewed independently (digital ocean control panel for example or windows task manager)
                var CPU = _cpu;// double precision
                //In some cases the first snapshot taken after a reboot 
                //is a huge number way beyond 100 which fucks up the charts
                //likely due to the algorithm above and new values but not worth looking into atm
                if(CPU > 100){
                   CPU=0;
                }
                using (AyContext ct = ServiceProviderProvider.DBContext)
                {
                    //write to db
                    MetricMM mm = new MetricMM(Allocated, WorkingSet, PrivateBytes, CPU);
                    ct.MetricMM.Add(mm);
                    ct.SaveChanges();
                    //System.Diagnostics.Debug.WriteLine("MM SAVED");
                }
                _lastMMSnapshot = now;
            }

         

            /////////////////////////////////////////////
            //ONCE A DAY SNAPS AND CLEANUP
            //
            if (DateUtil.IsAfterDuration(_lastDDSnapshot, ts24Hours))
            {
                log.LogTrace("DD metrics snapshot");
                var now = DateTime.UtcNow;
                //FILES ON DISK
                var UtilFilesInfo = FileUtil.GetUtilityFolderSizeInfo();
                var AttachmentFilesInfo = FileUtil.GetAttachmentFolderSizeInfo();

                //Available space
                var UtilityFilesAvailableSpace = FileUtil.UtilityFilesDriveAvailableSpace();
                var AttachmentFilesAvailableSpace = FileUtil.AttachmentFilesDriveAvailableSpace();

                using (AyContext ct = ServiceProviderProvider.DBContext)
                {
                    //DB total size          
                    long DBTotalSize = 0;
                    using (var command = ct.Database.GetDbConnection().CreateCommand())
                    {
                        command.CommandText = "select pg_database_size(current_database());";
                        ct.Database.OpenConnection();
                        using (var dr = command.ExecuteReader())
                        {
                            if (dr.HasRows)
                            {
                                DBTotalSize = dr.Read() ? dr.GetInt64(0) : 0;
                            }
                            ct.Database.CloseConnection();
                        }
                    }
                    //write to db
                    MetricDD dd = new MetricDD()
                    {
                        AttachmentFileSize = AttachmentFilesInfo.SizeWithChildren,
                        AttachmentFileCount = AttachmentFilesInfo.FileCountWithChildren,
                        AttachmentFilesAvailableSpace = AttachmentFilesAvailableSpace,
                        UtilityFileSize = UtilFilesInfo.SizeWithChildren,
                        UtilityFileCount = UtilFilesInfo.FileCountWithChildren,
                        UtilityFilesAvailableSpace = UtilityFilesAvailableSpace,
                        DBTotalSize = DBTotalSize
                    };
                    ct.MetricDD.Add(dd);
                    ct.SaveChanges();
                }


                /////////////////////////////////
                //CLEAR OLD ENTRIES
                //

                DateTime ClearDate = DateTime.UtcNow - tsDataRetention;
                using (AyContext ct = ServiceProviderProvider.DBContext)
                {
                     ct.Database.ExecuteSqlInterpolated($"delete from ametricmm where t < {ClearDate.ToUniversalTime()}");
                     ct.Database.ExecuteSqlInterpolated($"delete from ametricdd where t < {ClearDate.ToUniversalTime()}");
                }
                _lastDDSnapshot = now;
            }




            //----
        }





        /////////////////////////////////////////////////////////////////////

    }//eoc
}//eons