Add new sql server output data model (#3618)
This commit is contained in:
Mark Wilkinson - m82labs
Daniel Nelson
parent
86e08e6ce7
commit
426360d61f
File diff suppressed because it is too large
Load Diff
|
|
@ -14,7 +14,10 @@ import (
|
|||
|
||||
// SQLServer struct
|
||||
type SQLServer struct {
|
||||
Servers []string
|
||||
Servers []string `toml:"servers"`
|
||||
QueryVersion int `toml:"query_version"`
|
||||
AzureDB bool `toml:"azuredb"`
|
||||
ExcludeQuery []string `toml:"exclude_query"`
|
||||
}
|
||||
|
||||
// Query struct
|
||||
|
|
@ -29,18 +32,41 @@ type MapQuery map[string]Query
|
|||
|
||||
var queries MapQuery
|
||||
|
||||
// Initialized flag
|
||||
var isInitialized = false
|
||||
|
||||
var defaultServer = "Server=.;app name=telegraf;log=1;"
|
||||
|
||||
var sampleConfig = `
|
||||
## Specify instances to monitor with a list of connection strings.
|
||||
## All connection parameters are optional.
|
||||
## By default, the host is localhost, listening on default port, TCP 1433.
|
||||
## for Windows, the user is the currently running AD user (SSO).
|
||||
## See https://github.com/denisenkom/go-mssqldb for detailed connection
|
||||
## parameters.
|
||||
# servers = [
|
||||
# "Server=192.168.1.10;Port=1433;User Id=<user>;Password=<pw>;app name=telegraf;log=1;",
|
||||
# ]
|
||||
## Specify instances to monitor with a list of connection strings.
|
||||
## All connection parameters are optional.
|
||||
## By default, the host is localhost, listening on default port, TCP 1433.
|
||||
## for Windows, the user is the currently running AD user (SSO).
|
||||
## See https://github.com/denisenkom/go-mssqldb for detailed connection
|
||||
## parameters.
|
||||
# servers = [
|
||||
# "Server=192.168.1.10;Port=1433;User Id=<user>;Password=<pw>;app name=telegraf;log=1;",
|
||||
# ]
|
||||
#
|
||||
## Optional parameter, setting this to 2 will use a new version
|
||||
## of the collection queries that break compatibility with the original
|
||||
## dashboards.
|
||||
# query_version = 2
|
||||
## If you are using AzureDB, setting this to True will gather resource utilization metrics
|
||||
# azuredb = False
|
||||
## If you would like to exclude some of the metrics queries, list them here
|
||||
## Possible choices:
|
||||
## - PerformanceCounters
|
||||
## - WaitStatsCategorized
|
||||
## - DatabaseIO
|
||||
## - DatabaseProperties
|
||||
## - CPUHistory
|
||||
## - DatabaseSize
|
||||
## - DatabaseStats
|
||||
## - MemoryClerk
|
||||
## - VolumeSpace
|
||||
## - PerformanceMetrics
|
||||
# exclude_query = [ 'PerformanceCounters','WaitStatsCatagorized' ]
|
||||
`
|
||||
|
||||
// SampleConfig return the sample configuration
|
||||
|
|
@ -57,23 +83,47 @@ type scanner interface {
|
|||
Scan(dest ...interface{}) error
|
||||
}
|
||||
|
||||
func initQueries() {
|
||||
func initQueries(s *SQLServer) {
|
||||
queries = make(MapQuery)
|
||||
queries["PerformanceCounters"] = Query{Script: sqlPerformanceCounters, ResultByRow: true}
|
||||
queries["WaitStatsCategorized"] = Query{Script: sqlWaitStatsCategorized, ResultByRow: false}
|
||||
queries["CPUHistory"] = Query{Script: sqlCPUHistory, ResultByRow: false}
|
||||
queries["DatabaseIO"] = Query{Script: sqlDatabaseIO, ResultByRow: false}
|
||||
queries["DatabaseSize"] = Query{Script: sqlDatabaseSize, ResultByRow: false}
|
||||
queries["DatabaseStats"] = Query{Script: sqlDatabaseStats, ResultByRow: false}
|
||||
queries["DatabaseProperties"] = Query{Script: sqlDatabaseProperties, ResultByRow: false}
|
||||
queries["MemoryClerk"] = Query{Script: sqlMemoryClerk, ResultByRow: false}
|
||||
queries["VolumeSpace"] = Query{Script: sqlVolumeSpace, ResultByRow: false}
|
||||
queries["PerformanceMetrics"] = Query{Script: sqlPerformanceMetrics, ResultByRow: false}
|
||||
|
||||
// If this is an AzureDB instance, grab some extra metrics
|
||||
if s.AzureDB {
|
||||
queries["AzureDB"] = Query{Script: sqlAzureDB, ResultByRow: true}
|
||||
}
|
||||
|
||||
// Decide if we want to run version 1 or version 2 queries
|
||||
if s.QueryVersion == 2 {
|
||||
queries["PerformanceCounters"] = Query{Script: sqlPerformanceCountersV2, ResultByRow: true}
|
||||
queries["WaitStatsCategorized"] = Query{Script: sqlWaitStatsCategorizedV2, ResultByRow: false}
|
||||
queries["DatabaseIO"] = Query{Script: sqlDatabaseIOV2, ResultByRow: false}
|
||||
queries["ServerProperties"] = Query{Script: sqlServerPropertiesV2, ResultByRow: false}
|
||||
queries["MemoryClerk"] = Query{Script: sqlMemoryClerkV2, ResultByRow: false}
|
||||
} else {
|
||||
queries["PerformanceCounters"] = Query{Script: sqlPerformanceCounters, ResultByRow: true}
|
||||
queries["WaitStatsCategorized"] = Query{Script: sqlWaitStatsCategorized, ResultByRow: false}
|
||||
queries["CPUHistory"] = Query{Script: sqlCPUHistory, ResultByRow: false}
|
||||
queries["DatabaseIO"] = Query{Script: sqlDatabaseIO, ResultByRow: false}
|
||||
queries["DatabaseSize"] = Query{Script: sqlDatabaseSize, ResultByRow: false}
|
||||
queries["DatabaseStats"] = Query{Script: sqlDatabaseStats, ResultByRow: false}
|
||||
queries["DatabaseProperties"] = Query{Script: sqlDatabaseProperties, ResultByRow: false}
|
||||
queries["MemoryClerk"] = Query{Script: sqlMemoryClerk, ResultByRow: false}
|
||||
queries["VolumeSpace"] = Query{Script: sqlVolumeSpace, ResultByRow: false}
|
||||
queries["PerformanceMetrics"] = Query{Script: sqlPerformanceMetrics, ResultByRow: false}
|
||||
}
|
||||
|
||||
for _, query := range s.ExcludeQuery {
|
||||
delete(queries, query)
|
||||
}
|
||||
|
||||
// Set a flag so we know that queries have already been initialized
|
||||
isInitialized = true
|
||||
}
|
||||
|
||||
// Gather collect data from SQL Server
|
||||
func (s *SQLServer) Gather(acc telegraf.Accumulator) error {
|
||||
initQueries()
|
||||
if !isInitialized {
|
||||
initQueries(s)
|
||||
}
|
||||
|
||||
if len(s.Servers) == 0 {
|
||||
s.Servers = append(s.Servers, defaultServer)
|
||||
|
|
@ -188,7 +238,875 @@ func init() {
|
|||
})
|
||||
}
|
||||
|
||||
// queries
|
||||
// Queries - V2
|
||||
// Thanks Bob Ward (http://aka.ms/bobwardms)
|
||||
// and the folks at Stack Overflow (https://github.com/opserver/Opserver/blob/9c89c7e9936b58ad237b30e6f4cc6cd59c406889/Opserver.Core/Data/SQL/SQLInstance.Memory.cs)
|
||||
// for putting most of the memory clerk definitions online!
|
||||
const sqlMemoryClerkV2 = `SELECT
|
||||
'sqlserver_memory_clerks' As [measurement],
|
||||
REPLACE(@@SERVERNAME,'\',':') AS [sql_instance],
|
||||
SERVERPROPERTY('ServerName') AS [host],
|
||||
ISNULL(clerk_names.name,mc.type) AS clerk_type,
|
||||
SUM(mc.pages_kb) AS size_kb
|
||||
FROM
|
||||
sys.dm_os_memory_clerks AS mc WITH (NOLOCK)
|
||||
LEFT OUTER JOIN ( VALUES
|
||||
('CACHESTORE_BROKERDSH','Service Broker Dialog Security Header Cache'),
|
||||
('CACHESTORE_BROKERKEK','Service Broker Key Exchange Key Cache'),
|
||||
('CACHESTORE_BROKERREADONLY','Service Broker (Read-Only)'),
|
||||
('CACHESTORE_BROKERRSB','Service Broker Null Remote Service Binding Cache'),
|
||||
('CACHESTORE_BROKERTBLACS','Broker dormant rowsets'),
|
||||
('CACHESTORE_BROKERTO','Service Broker Transmission Object Cache'),
|
||||
('CACHESTORE_BROKERUSERCERTLOOKUP','Service Broker user certificates lookup result cache'),
|
||||
('CACHESTORE_CLRPROC','CLR Procedure Cache'),
|
||||
('CACHESTORE_CLRUDTINFO','CLR UDT Info'),
|
||||
('CACHESTORE_COLUMNSTOREOBJECTPOOL','Column Store Object Pool'),
|
||||
('CACHESTORE_CONVPRI','Conversation Priority Cache'),
|
||||
('CACHESTORE_EVENTS','Event Notification Cache'),
|
||||
('CACHESTORE_FULLTEXTSTOPLIST','Full Text Stoplist Cache'),
|
||||
('CACHESTORE_NOTIF','Notification Store'),
|
||||
('CACHESTORE_OBJCP','Object Plans'),
|
||||
('CACHESTORE_PHDR','Bound Trees'),
|
||||
('CACHESTORE_SEARCHPROPERTYLIST','Search Property List Cache'),
|
||||
('CACHESTORE_SEHOBTCOLUMNATTRIBUTE','SE Shared Column Metadata Cache'),
|
||||
('CACHESTORE_SQLCP','SQL Plans'),
|
||||
('CACHESTORE_STACKFRAMES','SOS_StackFramesStore'),
|
||||
('CACHESTORE_SYSTEMROWSET','System Rowset Store'),
|
||||
('CACHESTORE_TEMPTABLES','Temporary Tables & Table Variables'),
|
||||
('CACHESTORE_VIEWDEFINITIONS','View Definition Cache'),
|
||||
('CACHESTORE_XML_SELECTIVE_DG','XML DB Cache (Selective)'),
|
||||
('CACHESTORE_XMLDBATTRIBUTE','XML DB Cache (Attribute)'),
|
||||
('CACHESTORE_XMLDBELEMENT','XML DB Cache (Element)'),
|
||||
('CACHESTORE_XMLDBTYPE','XML DB Cache (Type)'),
|
||||
('CACHESTORE_XPROC','Extended Stored Procedures'),
|
||||
('MEMORYCLERK_FILETABLE','Memory Clerk (File Table)'),
|
||||
('MEMORYCLERK_FSCHUNKER','Memory Clerk (FS Chunker)'),
|
||||
('MEMORYCLERK_FULLTEXT','Full Text'),
|
||||
('MEMORYCLERK_FULLTEXT_SHMEM','Full-text IG'),
|
||||
('MEMORYCLERK_HADR','HADR'),
|
||||
('MEMORYCLERK_HOST','Host'),
|
||||
('MEMORYCLERK_LANGSVC','Language Service'),
|
||||
('MEMORYCLERK_LWC','Light Weight Cache'),
|
||||
('MEMORYCLERK_QSRANGEPREFETCH','QS Range Prefetch'),
|
||||
('MEMORYCLERK_SERIALIZATION','Serialization'),
|
||||
('MEMORYCLERK_SNI','SNI'),
|
||||
('MEMORYCLERK_SOSMEMMANAGER','SOS Memory Manager'),
|
||||
('MEMORYCLERK_SOSNODE','SOS Node'),
|
||||
('MEMORYCLERK_SOSOS','SOS Memory Clerk'),
|
||||
('MEMORYCLERK_SQLBUFFERPOOL','Buffer Pool'),
|
||||
('MEMORYCLERK_SQLCLR','CLR'),
|
||||
('MEMORYCLERK_SQLCLRASSEMBLY','CLR Assembly'),
|
||||
('MEMORYCLERK_SQLCONNECTIONPOOL','Connection Pool'),
|
||||
('MEMORYCLERK_SQLGENERAL','General'),
|
||||
('MEMORYCLERK_SQLHTTP','HTTP'),
|
||||
('MEMORYCLERK_SQLLOGPOOL','Log Pool'),
|
||||
('MEMORYCLERK_SQLOPTIMIZER','SQL Optimizer'),
|
||||
('MEMORYCLERK_SQLQERESERVATIONS','SQL Reservations'),
|
||||
('MEMORYCLERK_SQLQUERYCOMPILE','SQL Query Compile'),
|
||||
('MEMORYCLERK_SQLQUERYEXEC','SQL Query Exec'),
|
||||
('MEMORYCLERK_SQLQUERYPLAN','SQL Query Plan'),
|
||||
('MEMORYCLERK_SQLSERVICEBROKER','SQL Service Broker'),
|
||||
('MEMORYCLERK_SQLSERVICEBROKERTRANSPORT','Unified Communication Stack'),
|
||||
('MEMORYCLERK_SQLSOAP','SQL SOAP'),
|
||||
('MEMORYCLERK_SQLSOAPSESSIONSTORE','SQL SOAP (Session Store)'),
|
||||
('MEMORYCLERK_SQLSTORENG','SQL Storage Engine'),
|
||||
('MEMORYCLERK_SQLUTILITIES','SQL Utilities'),
|
||||
('MEMORYCLERK_SQLXML','SQL XML'),
|
||||
('MEMORYCLERK_SQLXP','SQL XP'),
|
||||
('MEMORYCLERK_TRACE_EVTNOTIF','Trace Event Notification'),
|
||||
('MEMORYCLERK_XE','XE Engine'),
|
||||
('MEMORYCLERK_XE_BUFFER','XE Buffer'),
|
||||
('MEMORYCLERK_XTP','In-Memory OLTP'),
|
||||
('OBJECTSTORE_LBSS','Lbss Cache (Object Store)'),
|
||||
('OBJECTSTORE_LOCK_MANAGER','Lock Manager (Object Store)'),
|
||||
('OBJECTSTORE_SECAUDIT_EVENT_BUFFER','Audit Event Buffer (Object Store)'),
|
||||
('OBJECTSTORE_SERVICE_BROKER','Service Broker (Object Store)'),
|
||||
('OBJECTSTORE_SNI_PACKET','SNI Packet (Object Store)'),
|
||||
('OBJECTSTORE_XACT_CACHE','Transactions Cache (Object Store)'),
|
||||
('USERSTORE_DBMETADATA','DB Metadata (User Store)'),
|
||||
('USERSTORE_OBJPERM','Object Permissions (User Store)'),
|
||||
('USERSTORE_SCHEMAMGR','Schema Manager (User Store)'),
|
||||
('USERSTORE_SXC','SXC (User Store)'),
|
||||
('USERSTORE_TOKENPERM','Token Permissions (User Store)'),
|
||||
('USERSTORE_QDSSTMT','QDS Statement Buffer (Pre-persist)'),
|
||||
('CACHESTORE_QDSRUNTIMESTATS','QDS Runtime Stats (Pre-persist)'),
|
||||
('CACHESTORE_QDSCONTEXTSETTINGS','QDS Unique Context Settings'),
|
||||
('MEMORYCLERK_QUERYDISKSTORE','QDS General'),
|
||||
('MEMORYCLERK_QUERYDISKSTORE_HASHMAP','QDS Query/Plan Hash Table')
|
||||
) AS clerk_names(system_name,name)
|
||||
ON mc.type = clerk_names.system_name
|
||||
GROUP BY ISNULL(clerk_names.name,mc.type)
|
||||
HAVING SUM(pages_kb) >= 1024
|
||||
OPTION( RECOMPILE );
|
||||
`
|
||||
|
||||
const sqlDatabaseIOV2 = `SELECT
|
||||
'sqlserver_database_io' As [measurement],
|
||||
REPLACE(@@SERVERNAME,'\',':') AS [sql_instance],
|
||||
SERVERPROPERTY('ServerName') AS [host],
|
||||
DB_NAME([vfs].[database_id]) [database_name],
|
||||
vfs.io_stall_read_ms AS read_latency_ms,
|
||||
vfs.num_of_reads AS reads,
|
||||
vfs.num_of_bytes_read AS read_bytes,
|
||||
vfs.io_stall_write_ms AS write_latency_ms,
|
||||
vfs.num_of_writes AS writes,
|
||||
vfs.num_of_bytes_written AS write_bytes,
|
||||
CASE WHEN vfs.file_id = 2 THEN 'LOG' ELSE 'ROWS' END AS file_type
|
||||
FROM
|
||||
[sys].[dm_io_virtual_file_stats](NULL,NULL) AS vfs
|
||||
OPTION( RECOMPILE );
|
||||
`
|
||||
|
||||
const sqlServerPropertiesV2 = `DECLARE @sys_info TABLE (
|
||||
cpu_count INT,
|
||||
server_memory INT,
|
||||
uptime INT
|
||||
)
|
||||
|
||||
IF OBJECT_ID('master.sys.dm_os_sys_info') IS NOT NULL
|
||||
BEGIN
|
||||
INSERT INTO @sys_info ( cpu_count, server_memory, uptime )
|
||||
EXEC('SELECT cpu_count, physical_memory_kb, DATEDIFF(MINUTE,sqlserver_start_time,GETDATE()) FROM sys.dm_os_sys_info')
|
||||
END
|
||||
|
||||
SELECT
|
||||
'sqlserver_server_properties' As [measurement],
|
||||
REPLACE(@@SERVERNAME,'\',':') AS [sql_instance],
|
||||
SERVERPROPERTY('ServerName') AS [host],
|
||||
SUM( CASE WHEN state = 0 THEN 1 ELSE 0 END ) AS db_online,
|
||||
SUM( CASE WHEN state = 1 THEN 1 ELSE 0 END ) AS db_restoring,
|
||||
SUM( CASE WHEN state = 2 THEN 1 ELSE 0 END ) AS db_recovering,
|
||||
SUM( CASE WHEN state = 3 THEN 1 ELSE 0 END ) AS db_recoveryPending,
|
||||
SUM( CASE WHEN state = 4 THEN 1 ELSE 0 END ) AS db_suspect,
|
||||
SUM( CASE WHEN state = 10 THEN 1 ELSE 0 END ) AS db_offline,
|
||||
MAX( sinfo.cpu_count ) AS cpu_count,
|
||||
MAX( sinfo.server_memory ) AS server_memory,
|
||||
MAX( sinfo.uptime ) AS uptime,
|
||||
SERVERPROPERTY('ProductVersion') AS sql_version
|
||||
FROM sys.databases
|
||||
CROSS APPLY (
|
||||
SELECT *
|
||||
FROM @sys_info
|
||||
) AS sinfo
|
||||
WHERE database_id > 4
|
||||
OPTION( RECOMPILE );
|
||||
`
|
||||
|
||||
const sqlPerformanceCountersV2 string = `DECLARE @PCounters TABLE
|
||||
(
|
||||
object_name nvarchar(128),
|
||||
counter_name nvarchar(128),
|
||||
instance_name nvarchar(128),
|
||||
cntr_value bigint,
|
||||
cntr_type INT,
|
||||
Primary Key(object_name, counter_name, instance_name)
|
||||
);
|
||||
|
||||
INSERT INTO @PCounters
|
||||
SELECT DISTINCT
|
||||
RTrim(spi.object_name) object_name,
|
||||
RTrim(spi.counter_name) counter_name,
|
||||
RTrim(spi.instance_name) instance_name,
|
||||
spi.cntr_value,
|
||||
spi.cntr_type
|
||||
FROM sys.dm_os_performance_counters AS spi
|
||||
WHERE (
|
||||
counter_name IN (
|
||||
'SQL Compilations/sec',
|
||||
'SQL Re-Compilations/sec',
|
||||
'User Connections',
|
||||
'Batch Requests/sec',
|
||||
'Logouts/sec',
|
||||
'Logins/sec',
|
||||
'Processes blocked',
|
||||
'Latch Waits/sec',
|
||||
'Full Scans/sec',
|
||||
'Index Searches/sec',
|
||||
'Page Splits/sec',
|
||||
'Page Lookups/sec',
|
||||
'Page Reads/sec',
|
||||
'Page Writes/sec',
|
||||
'Readahead Pages/sec',
|
||||
'Lazy Writes/sec',
|
||||
'Checkpoint Pages/sec',
|
||||
'Page life expectancy',
|
||||
'Log File(s) Size (KB)',
|
||||
'Log File(s) Used Size (KB)',
|
||||
'Data File(s) Size (KB)',
|
||||
'Transactions/sec',
|
||||
'Write Transactions/sec',
|
||||
'Active Temp Tables',
|
||||
'Temp Tables Creation Rate',
|
||||
'Temp Tables For Destruction',
|
||||
'Free Space in tempdb (KB)',
|
||||
'Version Store Size (KB)',
|
||||
'Memory Grants Pending',
|
||||
'Free list stalls/sec',
|
||||
'Buffer cache hit ratio',
|
||||
'Buffer cache hit ratio base'
|
||||
)
|
||||
) OR (
|
||||
instance_name IN ('_Total','Column store object pool')
|
||||
AND counter_name IN (
|
||||
'Log Flushes/sec',
|
||||
'Log Flush Wait Time',
|
||||
'Lock Timeouts/sec',
|
||||
'Number of Deadlocks/sec',
|
||||
'Lock Waits/sec',
|
||||
'Latch Waits/sec',
|
||||
'Memory broker clerk size',
|
||||
'Log Bytes Flushed/sec',
|
||||
'Bytes Sent to Replica/sec',
|
||||
'Log Send Queue',
|
||||
'Bytes Sent to Transport/sec',
|
||||
'Sends to Replica/sec',
|
||||
'Bytes Sent to Transport/sec',
|
||||
'Sends to Transport/sec',
|
||||
'Bytes Received from Replica/sec',
|
||||
'Receives from Replica/sec',
|
||||
'Flow Control Time (ms/sec)',
|
||||
'Flow Control/sec',
|
||||
'Resent Messages/sec',
|
||||
'Redone Bytes/sec',
|
||||
'XTP Memory Used (KB)'
|
||||
) OR (
|
||||
object_name = 'SQLServer:Database Replica'
|
||||
AND counter_name IN (
|
||||
'Log Bytes Received/sec',
|
||||
'Log Apply Pending Queue',
|
||||
'Redone Bytes/sec',
|
||||
'Recovery Queue',
|
||||
'Log Apply Ready Queue'
|
||||
)
|
||||
AND instance_name = '_Total'
|
||||
)
|
||||
) OR (
|
||||
object_name = 'SQLServer:Database Replica'
|
||||
AND counter_name IN ('Transaction Delay')
|
||||
) OR (
|
||||
object_name = 'SQLServer:Workload Group Stats'
|
||||
AND counter_name IN (
|
||||
'CPU usage %',
|
||||
'CPU usage % base',
|
||||
'Queued requests',
|
||||
'Requests completed/sec',
|
||||
'Blocked tasks'
|
||||
)
|
||||
)
|
||||
|
||||
SELECT 'sqlserver_performance' AS [measurement],
|
||||
REPLACE(@@SERVERNAME,'\',':') AS [sql_instance],
|
||||
SERVERPROPERTY('ServerName') AS [host],
|
||||
pc.object_name AS [object],
|
||||
pc.counter_name AS [counter],
|
||||
CASE pc.instance_name WHEN '_Total' THEN 'Total' ELSE ISNULL(pc.instance_name,'') END AS [instance],
|
||||
CASE WHEN pc.cntr_type = 537003264 AND pc1.cntr_value > 0 THEN (pc.cntr_value * 1.0) / (pc1.cntr_value * 1.0) * 100 ELSE pc.cntr_value END AS [value],
|
||||
CASE
|
||||
WHEN pc.cntr_type = 272696576 THEN 'rate'
|
||||
WHEN pc.cntr_type IN (65792,537003264) THEN 'raw'
|
||||
ELSE 'unknown'
|
||||
END AS c_type
|
||||
FROM @PCounters AS pc
|
||||
LEFT OUTER JOIN @PCounters AS pc1
|
||||
ON (
|
||||
pc.counter_name = REPLACE(pc1.counter_name,' base','')
|
||||
OR pc.counter_name = REPLACE(pc1.counter_name,' base',' (ms)')
|
||||
)
|
||||
AND pc.object_name = pc1.object_name
|
||||
AND pc.instance_name = pc1.instance_name
|
||||
AND pc1.counter_name LIKE '%base'
|
||||
WHERE pc.counter_name NOT LIKE '% base'
|
||||
OPTION( RECOMPILE );
|
||||
`
|
||||
|
||||
const sqlWaitStatsCategorizedV2 string = `SELECT
|
||||
'sqlserver_waitstats' AS [measurement],
|
||||
REPLACE(@@SERVERNAME,'\',':') AS [sql_instance],
|
||||
SERVERPROPERTY('ServerName') AS [host],
|
||||
ws.wait_type,
|
||||
wait_time_ms,
|
||||
wait_time_ms - signal_wait_time_ms AS [resource_wait_ms],
|
||||
signal_wait_time_ms,
|
||||
max_wait_time_ms,
|
||||
waiting_tasks_count,
|
||||
ISNULL(wc.wait_category,'OTHER') AS [wait_category]
|
||||
FROM
|
||||
sys.dm_os_wait_stats AS ws WITH (NOLOCK)
|
||||
LEFT OUTER JOIN ( VALUES
|
||||
('ASYNC_IO_COMPLETION','Other Disk IO'),
|
||||
('ASYNC_NETWORK_IO','Network IO'),
|
||||
('BACKUPIO','Other Disk IO'),
|
||||
('BROKER_CONNECTION_RECEIVE_TASK','Service Broker'),
|
||||
('BROKER_DISPATCHER','Service Broker'),
|
||||
('BROKER_ENDPOINT_STATE_MUTEX','Service Broker'),
|
||||
('BROKER_EVENTHANDLER','Service Broker'),
|
||||
('BROKER_FORWARDER','Service Broker'),
|
||||
('BROKER_INIT','Service Broker'),
|
||||
('BROKER_MASTERSTART','Service Broker'),
|
||||
('BROKER_RECEIVE_WAITFOR','User Wait'),
|
||||
('BROKER_REGISTERALLENDPOINTS','Service Broker'),
|
||||
('BROKER_SERVICE','Service Broker'),
|
||||
('BROKER_SHUTDOWN','Service Broker'),
|
||||
('BROKER_START','Service Broker'),
|
||||
('BROKER_TASK_SHUTDOWN','Service Broker'),
|
||||
('BROKER_TASK_STOP','Service Broker'),
|
||||
('BROKER_TASK_SUBMIT','Service Broker'),
|
||||
('BROKER_TO_FLUSH','Service Broker'),
|
||||
('BROKER_TRANSMISSION_OBJECT','Service Broker'),
|
||||
('BROKER_TRANSMISSION_TABLE','Service Broker'),
|
||||
('BROKER_TRANSMISSION_WORK','Service Broker'),
|
||||
('BROKER_TRANSMITTER','Service Broker'),
|
||||
('CHECKPOINT_QUEUE','Idle'),
|
||||
('CHKPT','Tran Log IO'),
|
||||
('CLR_AUTO_EVENT','SQL CLR'),
|
||||
('CLR_CRST','SQL CLR'),
|
||||
('CLR_JOIN','SQL CLR'),
|
||||
('CLR_MANUAL_EVENT','SQL CLR'),
|
||||
('CLR_MEMORY_SPY','SQL CLR'),
|
||||
('CLR_MONITOR','SQL CLR'),
|
||||
('CLR_RWLOCK_READER','SQL CLR'),
|
||||
('CLR_RWLOCK_WRITER','SQL CLR'),
|
||||
('CLR_SEMAPHORE','SQL CLR'),
|
||||
('CLR_TASK_START','SQL CLR'),
|
||||
('CLRHOST_STATE_ACCESS','SQL CLR'),
|
||||
('CMEMPARTITIONED','Memory'),
|
||||
('CMEMTHREAD','Memory'),
|
||||
('CXPACKET','Parallelism'),
|
||||
('DBMIRROR_DBM_EVENT','Mirroring'),
|
||||
('DBMIRROR_DBM_MUTEX','Mirroring'),
|
||||
('DBMIRROR_EVENTS_QUEUE','Mirroring'),
|
||||
('DBMIRROR_SEND','Mirroring'),
|
||||
('DBMIRROR_WORKER_QUEUE','Mirroring'),
|
||||
('DBMIRRORING_CMD','Mirroring'),
|
||||
('DTC','Transaction'),
|
||||
('DTC_ABORT_REQUEST','Transaction'),
|
||||
('DTC_RESOLVE','Transaction'),
|
||||
('DTC_STATE','Transaction'),
|
||||
('DTC_TMDOWN_REQUEST','Transaction'),
|
||||
('DTC_WAITFOR_OUTCOME','Transaction'),
|
||||
('DTCNEW_ENLIST','Transaction'),
|
||||
('DTCNEW_PREPARE','Transaction'),
|
||||
('DTCNEW_RECOVERY','Transaction'),
|
||||
('DTCNEW_TM','Transaction'),
|
||||
('DTCNEW_TRANSACTION_ENLISTMENT','Transaction'),
|
||||
('DTCPNTSYNC','Transaction'),
|
||||
('EE_PMOLOCK','Memory'),
|
||||
('EXCHANGE','Parallelism'),
|
||||
('EXTERNAL_SCRIPT_NETWORK_IOF','Network IO'),
|
||||
('FCB_REPLICA_READ','Replication'),
|
||||
('FCB_REPLICA_WRITE','Replication'),
|
||||
('FT_COMPROWSET_RWLOCK','Full Text Search'),
|
||||
('FT_IFTS_RWLOCK','Full Text Search'),
|
||||
('FT_IFTS_SCHEDULER_IDLE_WAIT','Idle'),
|
||||
('FT_IFTSHC_MUTEX','Full Text Search'),
|
||||
('FT_IFTSISM_MUTEX','Full Text Search'),
|
||||
('FT_MASTER_MERGE','Full Text Search'),
|
||||
('FT_MASTER_MERGE_COORDINATOR','Full Text Search'),
|
||||
('FT_METADATA_MUTEX','Full Text Search'),
|
||||
('FT_PROPERTYLIST_CACHE','Full Text Search'),
|
||||
('FT_RESTART_CRAWL','Full Text Search'),
|
||||
('FULLTEXT GATHERER','Full Text Search'),
|
||||
('HADR_AG_MUTEX','Replication'),
|
||||
('HADR_AR_CRITICAL_SECTION_ENTRY','Replication'),
|
||||
('HADR_AR_MANAGER_MUTEX','Replication'),
|
||||
('HADR_AR_UNLOAD_COMPLETED','Replication'),
|
||||
('HADR_ARCONTROLLER_NOTIFICATIONS_SUBSCRIBER_LIST','Replication'),
|
||||
('HADR_BACKUP_BULK_LOCK','Replication'),
|
||||
('HADR_BACKUP_QUEUE','Replication'),
|
||||
('HADR_CLUSAPI_CALL','Replication'),
|
||||
('HADR_COMPRESSED_CACHE_SYNC','Replication'),
|
||||
('HADR_CONNECTIVITY_INFO','Replication'),
|
||||
('HADR_DATABASE_FLOW_CONTROL','Replication'),
|
||||
('HADR_DATABASE_VERSIONING_STATE','Replication'),
|
||||
('HADR_DATABASE_WAIT_FOR_RECOVERY','Replication'),
|
||||
('HADR_DATABASE_WAIT_FOR_RESTART','Replication'),
|
||||
('HADR_DATABASE_WAIT_FOR_TRANSITION_TO_VERSIONING','Replication'),
|
||||
('HADR_DB_COMMAND','Replication'),
|
||||
('HADR_DB_OP_COMPLETION_SYNC','Replication'),
|
||||
('HADR_DB_OP_START_SYNC','Replication'),
|
||||
('HADR_DBR_SUBSCRIBER','Replication'),
|
||||
('HADR_DBR_SUBSCRIBER_FILTER_LIST','Replication'),
|
||||
('HADR_DBSEEDING','Replication'),
|
||||
('HADR_DBSEEDING_LIST','Replication'),
|
||||
('HADR_DBSTATECHANGE_SYNC','Replication'),
|
||||
('HADR_FABRIC_CALLBACK','Replication'),
|
||||
('HADR_FILESTREAM_BLOCK_FLUSH','Replication'),
|
||||
('HADR_FILESTREAM_FILE_CLOSE','Replication'),
|
||||
('HADR_FILESTREAM_FILE_REQUEST','Replication'),
|
||||
('HADR_FILESTREAM_IOMGR','Replication'),
|
||||
('HADR_FILESTREAM_IOMGR_IOCOMPLETION','Replication'),
|
||||
('HADR_FILESTREAM_MANAGER','Replication'),
|
||||
('HADR_FILESTREAM_PREPROC','Replication'),
|
||||
('HADR_GROUP_COMMIT','Replication'),
|
||||
('HADR_LOGCAPTURE_SYNC','Replication'),
|
||||
('HADR_LOGCAPTURE_WAIT','Replication'),
|
||||
('HADR_LOGPROGRESS_SYNC','Replication'),
|
||||
('HADR_NOTIFICATION_DEQUEUE','Replication'),
|
||||
('HADR_NOTIFICATION_WORKER_EXCLUSIVE_ACCESS','Replication'),
|
||||
('HADR_NOTIFICATION_WORKER_STARTUP_SYNC','Replication'),
|
||||
('HADR_NOTIFICATION_WORKER_TERMINATION_SYNC','Replication'),
|
||||
('HADR_PARTNER_SYNC','Replication'),
|
||||
('HADR_READ_ALL_NETWORKS','Replication'),
|
||||
('HADR_RECOVERY_WAIT_FOR_CONNECTION','Replication'),
|
||||
('HADR_RECOVERY_WAIT_FOR_UNDO','Replication'),
|
||||
('HADR_REPLICAINFO_SYNC','Replication'),
|
||||
('HADR_SEEDING_CANCELLATION','Replication'),
|
||||
('HADR_SEEDING_FILE_LIST','Replication'),
|
||||
('HADR_SEEDING_LIMIT_BACKUPS','Replication'),
|
||||
('HADR_SEEDING_SYNC_COMPLETION','Replication'),
|
||||
('HADR_SEEDING_TIMEOUT_TASK','Replication'),
|
||||
('HADR_SEEDING_WAIT_FOR_COMPLETION','Replication'),
|
||||
('HADR_SYNC_COMMIT','Replication'),
|
||||
('HADR_SYNCHRONIZING_THROTTLE','Replication'),
|
||||
('HADR_TDS_LISTENER_SYNC','Replication'),
|
||||
('HADR_TDS_LISTENER_SYNC_PROCESSING','Replication'),
|
||||
('HADR_THROTTLE_LOG_RATE_GOVERNOR','Log Rate Governor'),
|
||||
('HADR_TIMER_TASK','Replication'),
|
||||
('HADR_TRANSPORT_DBRLIST','Replication'),
|
||||
('HADR_TRANSPORT_FLOW_CONTROL','Replication'),
|
||||
('HADR_TRANSPORT_SESSION','Replication'),
|
||||
('HADR_WORK_POOL','Replication'),
|
||||
('HADR_WORK_QUEUE','Replication'),
|
||||
('HADR_XRF_STACK_ACCESS','Replication'),
|
||||
('INSTANCE_LOG_RATE_GOVERNOR','Log Rate Governor'),
|
||||
('IO_COMPLETION','Other Disk IO'),
|
||||
('IO_QUEUE_LIMIT','Other Disk IO'),
|
||||
('IO_RETRY','Other Disk IO'),
|
||||
('LATCH_DT','Latch'),
|
||||
('LATCH_EX','Latch'),
|
||||
('LATCH_KP','Latch'),
|
||||
('LATCH_NL','Latch'),
|
||||
('LATCH_SH','Latch'),
|
||||
('LATCH_UP','Latch'),
|
||||
('LAZYWRITER_SLEEP','Idle'),
|
||||
('LCK_M_BU','Lock'),
|
||||
('LCK_M_BU_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_BU_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_IS','Lock'),
|
||||
('LCK_M_IS_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_IS_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_IU','Lock'),
|
||||
('LCK_M_IU_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_IU_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_IX','Lock'),
|
||||
('LCK_M_IX_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_IX_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_RIn_NL','Lock'),
|
||||
('LCK_M_RIn_NL_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_RIn_NL_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_RIn_S','Lock'),
|
||||
('LCK_M_RIn_S_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_RIn_S_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_RIn_U','Lock'),
|
||||
('LCK_M_RIn_U_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_RIn_U_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_RIn_X','Lock'),
|
||||
('LCK_M_RIn_X_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_RIn_X_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_RS_S','Lock'),
|
||||
('LCK_M_RS_S_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_RS_S_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_RS_U','Lock'),
|
||||
('LCK_M_RS_U_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_RS_U_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_RX_S','Lock'),
|
||||
('LCK_M_RX_S_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_RX_S_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_RX_U','Lock'),
|
||||
('LCK_M_RX_U_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_RX_U_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_RX_X','Lock'),
|
||||
('LCK_M_RX_X_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_RX_X_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_S','Lock'),
|
||||
('LCK_M_S_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_S_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_SCH_M','Lock'),
|
||||
('LCK_M_SCH_M_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_SCH_M_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_SCH_S','Lock'),
|
||||
('LCK_M_SCH_S_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_SCH_S_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_SIU','Lock'),
|
||||
('LCK_M_SIU_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_SIU_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_SIX','Lock'),
|
||||
('LCK_M_SIX_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_SIX_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_U','Lock'),
|
||||
('LCK_M_U_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_U_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_UIX','Lock'),
|
||||
('LCK_M_UIX_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_UIX_LOW_PRIORITY','Lock'),
|
||||
('LCK_M_X','Lock'),
|
||||
('LCK_M_X_ABORT_BLOCKERS','Lock'),
|
||||
('LCK_M_X_LOW_PRIORITY','Lock'),
|
||||
('LOGBUFFER','Tran Log IO'),
|
||||
('LOGMGR','Tran Log IO'),
|
||||
('LOGMGR_FLUSH','Tran Log IO'),
|
||||
('LOGMGR_PMM_LOG','Tran Log IO'),
|
||||
('LOGMGR_QUEUE','Idle'),
|
||||
('LOGMGR_RESERVE_APPEND','Tran Log IO'),
|
||||
('MEMORY_ALLOCATION_EXT','Memory'),
|
||||
('MEMORY_GRANT_UPDATE','Memory'),
|
||||
('MSQL_XACT_MGR_MUTEX','Transaction'),
|
||||
('MSQL_XACT_MUTEX','Transaction'),
|
||||
('MSSEARCH','Full Text Search'),
|
||||
('NET_WAITFOR_PACKET','Network IO'),
|
||||
('ONDEMAND_TASK_QUEUE','Idle'),
|
||||
('PAGEIOLATCH_DT','Buffer IO'),
|
||||
('PAGEIOLATCH_EX','Buffer IO'),
|
||||
('PAGEIOLATCH_KP','Buffer IO'),
|
||||
('PAGEIOLATCH_NL','Buffer IO'),
|
||||
('PAGEIOLATCH_SH','Buffer IO'),
|
||||
('PAGEIOLATCH_UP','Buffer IO'),
|
||||
('PAGELATCH_DT','Buffer Latch'),
|
||||
('PAGELATCH_EX','Buffer Latch'),
|
||||
('PAGELATCH_KP','Buffer Latch'),
|
||||
('PAGELATCH_NL','Buffer Latch'),
|
||||
('PAGELATCH_SH','Buffer Latch'),
|
||||
('PAGELATCH_UP','Buffer Latch'),
|
||||
('POOL_LOG_RATE_GOVERNOR','Log Rate Governor'),
|
||||
('PREEMPTIVE_ABR','Preemptive'),
|
||||
('PREEMPTIVE_CLOSEBACKUPMEDIA','Preemptive'),
|
||||
('PREEMPTIVE_CLOSEBACKUPTAPE','Preemptive'),
|
||||
('PREEMPTIVE_CLOSEBACKUPVDIDEVICE','Preemptive'),
|
||||
('PREEMPTIVE_CLUSAPI_CLUSTERRESOURCECONTROL','Preemptive'),
|
||||
('PREEMPTIVE_COM_COCREATEINSTANCE','Preemptive'),
|
||||
('PREEMPTIVE_COM_COGETCLASSOBJECT','Preemptive'),
|
||||
('PREEMPTIVE_COM_CREATEACCESSOR','Preemptive'),
|
||||
('PREEMPTIVE_COM_DELETEROWS','Preemptive'),
|
||||
('PREEMPTIVE_COM_GETCOMMANDTEXT','Preemptive'),
|
||||
('PREEMPTIVE_COM_GETDATA','Preemptive'),
|
||||
('PREEMPTIVE_COM_GETNEXTROWS','Preemptive'),
|
||||
('PREEMPTIVE_COM_GETRESULT','Preemptive'),
|
||||
('PREEMPTIVE_COM_GETROWSBYBOOKMARK','Preemptive'),
|
||||
('PREEMPTIVE_COM_LBFLUSH','Preemptive'),
|
||||
('PREEMPTIVE_COM_LBLOCKREGION','Preemptive'),
|
||||
('PREEMPTIVE_COM_LBREADAT','Preemptive'),
|
||||
('PREEMPTIVE_COM_LBSETSIZE','Preemptive'),
|
||||
('PREEMPTIVE_COM_LBSTAT','Preemptive'),
|
||||
('PREEMPTIVE_COM_LBUNLOCKREGION','Preemptive'),
|
||||
('PREEMPTIVE_COM_LBWRITEAT','Preemptive'),
|
||||
('PREEMPTIVE_COM_QUERYINTERFACE','Preemptive'),
|
||||
('PREEMPTIVE_COM_RELEASE','Preemptive'),
|
||||
('PREEMPTIVE_COM_RELEASEACCESSOR','Preemptive'),
|
||||
('PREEMPTIVE_COM_RELEASEROWS','Preemptive'),
|
||||
('PREEMPTIVE_COM_RELEASESESSION','Preemptive'),
|
||||
('PREEMPTIVE_COM_RESTARTPOSITION','Preemptive'),
|
||||
('PREEMPTIVE_COM_SEQSTRMREAD','Preemptive'),
|
||||
('PREEMPTIVE_COM_SEQSTRMREADANDWRITE','Preemptive'),
|
||||
('PREEMPTIVE_COM_SETDATAFAILURE','Preemptive'),
|
||||
('PREEMPTIVE_COM_SETPARAMETERINFO','Preemptive'),
|
||||
('PREEMPTIVE_COM_SETPARAMETERPROPERTIES','Preemptive'),
|
||||
('PREEMPTIVE_COM_STRMLOCKREGION','Preemptive'),
|
||||
('PREEMPTIVE_COM_STRMSEEKANDREAD','Preemptive'),
|
||||
('PREEMPTIVE_COM_STRMSEEKANDWRITE','Preemptive'),
|
||||
('PREEMPTIVE_COM_STRMSETSIZE','Preemptive'),
|
||||
('PREEMPTIVE_COM_STRMSTAT','Preemptive'),
|
||||
('PREEMPTIVE_COM_STRMUNLOCKREGION','Preemptive'),
|
||||
('PREEMPTIVE_CONSOLEWRITE','Preemptive'),
|
||||
('PREEMPTIVE_CREATEPARAM','Preemptive'),
|
||||
('PREEMPTIVE_DEBUG','Preemptive'),
|
||||
('PREEMPTIVE_DFSADDLINK','Preemptive'),
|
||||
('PREEMPTIVE_DFSLINKEXISTCHECK','Preemptive'),
|
||||
('PREEMPTIVE_DFSLINKHEALTHCHECK','Preemptive'),
|
||||
('PREEMPTIVE_DFSREMOVELINK','Preemptive'),
|
||||
('PREEMPTIVE_DFSREMOVEROOT','Preemptive'),
|
||||
('PREEMPTIVE_DFSROOTFOLDERCHECK','Preemptive'),
|
||||
('PREEMPTIVE_DFSROOTINIT','Preemptive'),
|
||||
('PREEMPTIVE_DFSROOTSHARECHECK','Preemptive'),
|
||||
('PREEMPTIVE_DTC_ABORT','Preemptive'),
|
||||
('PREEMPTIVE_DTC_ABORTREQUESTDONE','Preemptive'),
|
||||
('PREEMPTIVE_DTC_BEGINTRANSACTION','Preemptive'),
|
||||
('PREEMPTIVE_DTC_COMMITREQUESTDONE','Preemptive'),
|
||||
('PREEMPTIVE_DTC_ENLIST','Preemptive'),
|
||||
('PREEMPTIVE_DTC_PREPAREREQUESTDONE','Preemptive'),
|
||||
('PREEMPTIVE_FILESIZEGET','Preemptive'),
|
||||
('PREEMPTIVE_FSAOLEDB_ABORTTRANSACTION','Preemptive'),
|
||||
('PREEMPTIVE_FSAOLEDB_COMMITTRANSACTION','Preemptive'),
|
||||
('PREEMPTIVE_FSAOLEDB_STARTTRANSACTION','Preemptive'),
|
||||
('PREEMPTIVE_FSRECOVER_UNCONDITIONALUNDO','Preemptive'),
|
||||
('PREEMPTIVE_GETRMINFO','Preemptive'),
|
||||
('PREEMPTIVE_HADR_LEASE_MECHANISM','Preemptive'),
|
||||
('PREEMPTIVE_HTTP_EVENT_WAIT','Preemptive'),
|
||||
('PREEMPTIVE_HTTP_REQUEST','Preemptive'),
|
||||
('PREEMPTIVE_LOCKMONITOR','Preemptive'),
|
||||
('PREEMPTIVE_MSS_RELEASE','Preemptive'),
|
||||
('PREEMPTIVE_ODBCOPS','Preemptive'),
|
||||
('PREEMPTIVE_OLE_UNINIT','Preemptive'),
|
||||
('PREEMPTIVE_OLEDB_ABORTORCOMMITTRAN','Preemptive'),
|
||||
('PREEMPTIVE_OLEDB_ABORTTRAN','Preemptive'),
|
||||
('PREEMPTIVE_OLEDB_GETDATASOURCE','Preemptive'),
|
||||
('PREEMPTIVE_OLEDB_GETLITERALINFO','Preemptive'),
|
||||
('PREEMPTIVE_OLEDB_GETPROPERTIES','Preemptive'),
|
||||
('PREEMPTIVE_OLEDB_GETPROPERTYINFO','Preemptive'),
|
||||
('PREEMPTIVE_OLEDB_GETSCHEMALOCK','Preemptive'),
|
||||
('PREEMPTIVE_OLEDB_JOINTRANSACTION','Preemptive'),
|
||||
('PREEMPTIVE_OLEDB_RELEASE','Preemptive'),
|
||||
('PREEMPTIVE_OLEDB_SETPROPERTIES','Preemptive'),
|
||||
('PREEMPTIVE_OLEDBOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_ACCEPTSECURITYCONTEXT','Preemptive'),
|
||||
('PREEMPTIVE_OS_ACQUIRECREDENTIALSHANDLE','Preemptive'),
|
||||
('PREEMPTIVE_OS_AUTHENTICATIONOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_AUTHORIZATIONOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_AUTHZGETINFORMATIONFROMCONTEXT','Preemptive'),
|
||||
('PREEMPTIVE_OS_AUTHZINITIALIZECONTEXTFROMSID','Preemptive'),
|
||||
('PREEMPTIVE_OS_AUTHZINITIALIZERESOURCEMANAGER','Preemptive'),
|
||||
('PREEMPTIVE_OS_BACKUPREAD','Preemptive'),
|
||||
('PREEMPTIVE_OS_CLOSEHANDLE','Preemptive'),
|
||||
('PREEMPTIVE_OS_CLUSTEROPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_COMOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_COMPLETEAUTHTOKEN','Preemptive'),
|
||||
('PREEMPTIVE_OS_COPYFILE','Preemptive'),
|
||||
('PREEMPTIVE_OS_CREATEDIRECTORY','Preemptive'),
|
||||
('PREEMPTIVE_OS_CREATEFILE','Preemptive'),
|
||||
('PREEMPTIVE_OS_CRYPTACQUIRECONTEXT','Preemptive'),
|
||||
('PREEMPTIVE_OS_CRYPTIMPORTKEY','Preemptive'),
|
||||
('PREEMPTIVE_OS_CRYPTOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_DECRYPTMESSAGE','Preemptive'),
|
||||
('PREEMPTIVE_OS_DELETEFILE','Preemptive'),
|
||||
('PREEMPTIVE_OS_DELETESECURITYCONTEXT','Preemptive'),
|
||||
('PREEMPTIVE_OS_DEVICEIOCONTROL','Preemptive'),
|
||||
('PREEMPTIVE_OS_DEVICEOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_DIRSVC_NETWORKOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_DISCONNECTNAMEDPIPE','Preemptive'),
|
||||
('PREEMPTIVE_OS_DOMAINSERVICESOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_DSGETDCNAME','Preemptive'),
|
||||
('PREEMPTIVE_OS_DTCOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_ENCRYPTMESSAGE','Preemptive'),
|
||||
('PREEMPTIVE_OS_FILEOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_FINDFILE','Preemptive'),
|
||||
('PREEMPTIVE_OS_FLUSHFILEBUFFERS','Preemptive'),
|
||||
('PREEMPTIVE_OS_FORMATMESSAGE','Preemptive'),
|
||||
('PREEMPTIVE_OS_FREECREDENTIALSHANDLE','Preemptive'),
|
||||
('PREEMPTIVE_OS_FREELIBRARY','Preemptive'),
|
||||
('PREEMPTIVE_OS_GENERICOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_GETADDRINFO','Preemptive'),
|
||||
('PREEMPTIVE_OS_GETCOMPRESSEDFILESIZE','Preemptive'),
|
||||
('PREEMPTIVE_OS_GETDISKFREESPACE','Preemptive'),
|
||||
('PREEMPTIVE_OS_GETFILEATTRIBUTES','Preemptive'),
|
||||
('PREEMPTIVE_OS_GETFILESIZE','Preemptive'),
|
||||
('PREEMPTIVE_OS_GETFINALFILEPATHBYHANDLE','Preemptive'),
|
||||
('PREEMPTIVE_OS_GETLONGPATHNAME','Preemptive'),
|
||||
('PREEMPTIVE_OS_GETPROCADDRESS','Preemptive'),
|
||||
('PREEMPTIVE_OS_GETVOLUMENAMEFORVOLUMEMOUNTPOINT','Preemptive'),
|
||||
('PREEMPTIVE_OS_GETVOLUMEPATHNAME','Preemptive'),
|
||||
('PREEMPTIVE_OS_INITIALIZESECURITYCONTEXT','Preemptive'),
|
||||
('PREEMPTIVE_OS_LIBRARYOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_LOADLIBRARY','Preemptive'),
|
||||
('PREEMPTIVE_OS_LOGONUSER','Preemptive'),
|
||||
('PREEMPTIVE_OS_LOOKUPACCOUNTSID','Preemptive'),
|
||||
('PREEMPTIVE_OS_MESSAGEQUEUEOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_MOVEFILE','Preemptive'),
|
||||
('PREEMPTIVE_OS_NETGROUPGETUSERS','Preemptive'),
|
||||
('PREEMPTIVE_OS_NETLOCALGROUPGETMEMBERS','Preemptive'),
|
||||
('PREEMPTIVE_OS_NETUSERGETGROUPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_NETUSERGETLOCALGROUPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_NETUSERMODALSGET','Preemptive'),
|
||||
('PREEMPTIVE_OS_NETVALIDATEPASSWORDPOLICY','Preemptive'),
|
||||
('PREEMPTIVE_OS_NETVALIDATEPASSWORDPOLICYFREE','Preemptive'),
|
||||
('PREEMPTIVE_OS_OPENDIRECTORY','Preemptive'),
|
||||
('PREEMPTIVE_OS_PDH_WMI_INIT','Preemptive'),
|
||||
('PREEMPTIVE_OS_PIPEOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_PROCESSOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_QUERYCONTEXTATTRIBUTES','Preemptive'),
|
||||
('PREEMPTIVE_OS_QUERYREGISTRY','Preemptive'),
|
||||
('PREEMPTIVE_OS_QUERYSECURITYCONTEXTTOKEN','Preemptive'),
|
||||
('PREEMPTIVE_OS_REMOVEDIRECTORY','Preemptive'),
|
||||
('PREEMPTIVE_OS_REPORTEVENT','Preemptive'),
|
||||
('PREEMPTIVE_OS_REVERTTOSELF','Preemptive'),
|
||||
('PREEMPTIVE_OS_RSFXDEVICEOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_SECURITYOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_SERVICEOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_SETENDOFFILE','Preemptive'),
|
||||
('PREEMPTIVE_OS_SETFILEPOINTER','Preemptive'),
|
||||
('PREEMPTIVE_OS_SETFILEVALIDDATA','Preemptive'),
|
||||
('PREEMPTIVE_OS_SETNAMEDSECURITYINFO','Preemptive'),
|
||||
('PREEMPTIVE_OS_SQLCLROPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_SQMLAUNCH','Preemptive'),
|
||||
('PREEMPTIVE_OS_VERIFYSIGNATURE','Preemptive'),
|
||||
('PREEMPTIVE_OS_VERIFYTRUST','Preemptive'),
|
||||
('PREEMPTIVE_OS_VSSOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_WAITFORSINGLEOBJECT','Preemptive'),
|
||||
('PREEMPTIVE_OS_WINSOCKOPS','Preemptive'),
|
||||
('PREEMPTIVE_OS_WRITEFILE','Preemptive'),
|
||||
('PREEMPTIVE_OS_WRITEFILEGATHER','Preemptive'),
|
||||
('PREEMPTIVE_OS_WSASETLASTERROR','Preemptive'),
|
||||
('PREEMPTIVE_REENLIST','Preemptive'),
|
||||
('PREEMPTIVE_RESIZELOG','Preemptive'),
|
||||
('PREEMPTIVE_ROLLFORWARDREDO','Preemptive'),
|
||||
('PREEMPTIVE_ROLLFORWARDUNDO','Preemptive'),
|
||||
('PREEMPTIVE_SB_STOPENDPOINT','Preemptive'),
|
||||
('PREEMPTIVE_SERVER_STARTUP','Preemptive'),
|
||||
('PREEMPTIVE_SETRMINFO','Preemptive'),
|
||||
('PREEMPTIVE_SHAREDMEM_GETDATA','Preemptive'),
|
||||
('PREEMPTIVE_SNIOPEN','Preemptive'),
|
||||
('PREEMPTIVE_SOSHOST','Preemptive'),
|
||||
('PREEMPTIVE_SOSTESTING','Preemptive'),
|
||||
('PREEMPTIVE_SP_SERVER_DIAGNOSTICS','Preemptive'),
|
||||
('PREEMPTIVE_STARTRM','Preemptive'),
|
||||
('PREEMPTIVE_STREAMFCB_CHECKPOINT','Preemptive'),
|
||||
('PREEMPTIVE_STREAMFCB_RECOVER','Preemptive'),
|
||||
('PREEMPTIVE_STRESSDRIVER','Preemptive'),
|
||||
('PREEMPTIVE_TESTING','Preemptive'),
|
||||
('PREEMPTIVE_TRANSIMPORT','Preemptive'),
|
||||
('PREEMPTIVE_UNMARSHALPROPAGATIONTOKEN','Preemptive'),
|
||||
('PREEMPTIVE_VSS_CREATESNAPSHOT','Preemptive'),
|
||||
('PREEMPTIVE_VSS_CREATEVOLUMESNAPSHOT','Preemptive'),
|
||||
('PREEMPTIVE_XE_CALLBACKEXECUTE','Preemptive'),
|
||||
('PREEMPTIVE_XE_CX_FILE_OPEN','Preemptive'),
|
||||
('PREEMPTIVE_XE_CX_HTTP_CALL','Preemptive'),
|
||||
('PREEMPTIVE_XE_DISPATCHER','Preemptive'),
|
||||
('PREEMPTIVE_XE_ENGINEINIT','Preemptive'),
|
||||
('PREEMPTIVE_XE_GETTARGETSTATE','Preemptive'),
|
||||
('PREEMPTIVE_XE_SESSIONCOMMIT','Preemptive'),
|
||||
('PREEMPTIVE_XE_TARGETFINALIZE','Preemptive'),
|
||||
('PREEMPTIVE_XE_TARGETINIT','Preemptive'),
|
||||
('PREEMPTIVE_XE_TIMERRUN','Preemptive'),
|
||||
('PREEMPTIVE_XETESTING','Preemptive'),
|
||||
('PWAIT_HADR_ACTION_COMPLETED','Replication'),
|
||||
('PWAIT_HADR_CHANGE_NOTIFIER_TERMINATION_SYNC','Replication'),
|
||||
('PWAIT_HADR_CLUSTER_INTEGRATION','Replication'),
|
||||
('PWAIT_HADR_FAILOVER_COMPLETED','Replication'),
|
||||
('PWAIT_HADR_JOIN','Replication'),
|
||||
('PWAIT_HADR_OFFLINE_COMPLETED','Replication'),
|
||||
('PWAIT_HADR_ONLINE_COMPLETED','Replication'),
|
||||
('PWAIT_HADR_POST_ONLINE_COMPLETED','Replication'),
|
||||
('PWAIT_HADR_SERVER_READY_CONNECTIONS','Replication'),
|
||||
('PWAIT_HADR_WORKITEM_COMPLETED','Replication'),
|
||||
('PWAIT_HADRSIM','Replication'),
|
||||
('PWAIT_RESOURCE_SEMAPHORE_FT_PARALLEL_QUERY_SYNC','Full Text Search'),
|
||||
('QUERY_TRACEOUT','Tracing'),
|
||||
('REPL_CACHE_ACCESS','Replication'),
|
||||
('REPL_HISTORYCACHE_ACCESS','Replication'),
|
||||
('REPL_SCHEMA_ACCESS','Replication'),
|
||||
('REPL_TRANFSINFO_ACCESS','Replication'),
|
||||
('REPL_TRANHASHTABLE_ACCESS','Replication'),
|
||||
('REPL_TRANTEXTINFO_ACCESS','Replication'),
|
||||
('REPLICA_WRITES','Replication'),
|
||||
('REQUEST_FOR_DEADLOCK_SEARCH','Idle'),
|
||||
('RESERVED_MEMORY_ALLOCATION_EXT','Memory'),
|
||||
('RESOURCE_SEMAPHORE','Memory'),
|
||||
('RESOURCE_SEMAPHORE_QUERY_COMPILE','Compilation'),
|
||||
('SLEEP_BPOOL_FLUSH','Idle'),
|
||||
('SLEEP_BUFFERPOOL_HELPLW','Idle'),
|
||||
('SLEEP_DBSTARTUP','Idle'),
|
||||
('SLEEP_DCOMSTARTUP','Idle'),
|
||||
('SLEEP_MASTERDBREADY','Idle'),
|
||||
('SLEEP_MASTERMDREADY','Idle'),
|
||||
('SLEEP_MASTERUPGRADED','Idle'),
|
||||
('SLEEP_MEMORYPOOL_ALLOCATEPAGES','Idle'),
|
||||
('SLEEP_MSDBSTARTUP','Idle'),
|
||||
('SLEEP_RETRY_VIRTUALALLOC','Idle'),
|
||||
('SLEEP_SYSTEMTASK','Idle'),
|
||||
('SLEEP_TASK','Idle'),
|
||||
('SLEEP_TEMPDBSTARTUP','Idle'),
|
||||
('SLEEP_WORKSPACE_ALLOCATEPAGE','Idle'),
|
||||
('SOS_SCHEDULER_YIELD','CPU'),
|
||||
('SQLCLR_APPDOMAIN','SQL CLR'),
|
||||
('SQLCLR_ASSEMBLY','SQL CLR'),
|
||||
('SQLCLR_DEADLOCK_DETECTION','SQL CLR'),
|
||||
('SQLCLR_QUANTUM_PUNISHMENT','SQL CLR'),
|
||||
('SQLTRACE_BUFFER_FLUSH','Idle'),
|
||||
('SQLTRACE_FILE_BUFFER','Tracing'),
|
||||
('SQLTRACE_FILE_READ_IO_COMPLETION','Tracing'),
|
||||
('SQLTRACE_FILE_WRITE_IO_COMPLETION','Tracing'),
|
||||
('SQLTRACE_INCREMENTAL_FLUSH_SLEEP','Idle'),
|
||||
('SQLTRACE_PENDING_BUFFER_WRITERS','Tracing'),
|
||||
('SQLTRACE_SHUTDOWN','Tracing'),
|
||||
('SQLTRACE_WAIT_ENTRIES','Idle'),
|
||||
('THREADPOOL','Worker Thread'),
|
||||
('TRACE_EVTNOTIF','Tracing'),
|
||||
('TRACEWRITE','Tracing'),
|
||||
('TRAN_MARKLATCH_DT','Transaction'),
|
||||
('TRAN_MARKLATCH_EX','Transaction'),
|
||||
('TRAN_MARKLATCH_KP','Transaction'),
|
||||
('TRAN_MARKLATCH_NL','Transaction'),
|
||||
('TRAN_MARKLATCH_SH','Transaction'),
|
||||
('TRAN_MARKLATCH_UP','Transaction'),
|
||||
('TRANSACTION_MUTEX','Transaction'),
|
||||
('WAIT_FOR_RESULTS','User Wait'),
|
||||
('WAITFOR','User Wait'),
|
||||
('WRITE_COMPLETION','Other Disk IO'),
|
||||
('WRITELOG','Tran Log IO'),
|
||||
('XACT_OWN_TRANSACTION','Transaction'),
|
||||
('XACT_RECLAIM_SESSION','Transaction'),
|
||||
('XACTLOCKINFO','Transaction'),
|
||||
('XACTWORKSPACE_MUTEX','Transaction'),
|
||||
('XE_DISPATCHER_WAIT','Idle'),
|
||||
('XE_TIMER_EVENT','Idle')) AS wc(wait_type, wait_category)
|
||||
ON ws.wait_type = wc.wait_type
|
||||
WHERE
|
||||
ws.wait_type NOT IN (
|
||||
N'BROKER_EVENTHANDLER', N'BROKER_RECEIVE_WAITFOR', N'BROKER_TASK_STOP',
|
||||
N'BROKER_TO_FLUSH', N'BROKER_TRANSMITTER', N'CHECKPOINT_QUEUE',
|
||||
N'CHKPT', N'CLR_AUTO_EVENT', N'CLR_MANUAL_EVENT', N'CLR_SEMAPHORE',
|
||||
N'DBMIRROR_DBM_EVENT', N'DBMIRROR_EVENTS_QUEUE', N'DBMIRROR_WORKER_QUEUE',
|
||||
N'DBMIRRORING_CMD', N'DIRTY_PAGE_POLL', N'DISPATCHER_QUEUE_SEMAPHORE',
|
||||
N'EXECSYNC', N'FSAGENT', N'FT_IFTS_SCHEDULER_IDLE_WAIT', N'FT_IFTSHC_MUTEX',
|
||||
N'HADR_CLUSAPI_CALL', N'HADR_FILESTREAM_IOMGR_IOCOMPLETION', N'HADR_LOGCAPTURE_WAIT',
|
||||
N'HADR_NOTIFICATION_DEQUEUE', N'HADR_TIMER_TASK', N'HADR_WORK_QUEUE',
|
||||
N'KSOURCE_WAKEUP', N'LAZYWRITER_SLEEP', N'LOGMGR_QUEUE',
|
||||
N'MEMORY_ALLOCATION_EXT', N'ONDEMAND_TASK_QUEUE',
|
||||
N'PARALLEL_REDO_WORKER_WAIT_WORK',
|
||||
N'PREEMPTIVE_HADR_LEASE_MECHANISM', N'PREEMPTIVE_SP_SERVER_DIAGNOSTICS',
|
||||
N'PREEMPTIVE_OS_LIBRARYOPS', N'PREEMPTIVE_OS_COMOPS', N'PREEMPTIVE_OS_CRYPTOPS',
|
||||
N'PREEMPTIVE_OS_PIPEOPS', N'PREEMPTIVE_OS_AUTHENTICATIONOPS',
|
||||
N'PREEMPTIVE_OS_GENERICOPS', N'PREEMPTIVE_OS_VERIFYTRUST',
|
||||
N'PREEMPTIVE_OS_FILEOPS', N'PREEMPTIVE_OS_DEVICEOPS', N'PREEMPTIVE_OS_QUERYREGISTRY',
|
||||
N'PREEMPTIVE_OS_WRITEFILE',
|
||||
N'PREEMPTIVE_XE_CALLBACKEXECUTE', N'PREEMPTIVE_XE_DISPATCHER',
|
||||
N'PREEMPTIVE_XE_GETTARGETSTATE', N'PREEMPTIVE_XE_SESSIONCOMMIT',
|
||||
N'PREEMPTIVE_XE_TARGETINIT', N'PREEMPTIVE_XE_TARGETFINALIZE',
|
||||
N'PWAIT_ALL_COMPONENTS_INITIALIZED', N'PWAIT_DIRECTLOGCONSUMER_GETNEXT',
|
||||
N'QDS_PERSIST_TASK_MAIN_LOOP_SLEEP',
|
||||
N'QDS_ASYNC_QUEUE',
|
||||
N'QDS_CLEANUP_STALE_QUERIES_TASK_MAIN_LOOP_SLEEP', N'REQUEST_FOR_DEADLOCK_SEARCH',
|
||||
N'RESOURCE_QUEUE', N'SERVER_IDLE_CHECK', N'SLEEP_BPOOL_FLUSH', N'SLEEP_DBSTARTUP',
|
||||
N'SLEEP_DCOMSTARTUP', N'SLEEP_MASTERDBREADY', N'SLEEP_MASTERMDREADY',
|
||||
N'SLEEP_MASTERUPGRADED', N'SLEEP_MSDBSTARTUP', N'SLEEP_SYSTEMTASK', N'SLEEP_TASK',
|
||||
N'SLEEP_TEMPDBSTARTUP', N'SNI_HTTP_ACCEPT', N'SP_SERVER_DIAGNOSTICS_SLEEP',
|
||||
N'SQLTRACE_BUFFER_FLUSH', N'SQLTRACE_INCREMENTAL_FLUSH_SLEEP', N'SQLTRACE_WAIT_ENTRIES',
|
||||
N'WAIT_FOR_RESULTS', N'WAITFOR', N'WAITFOR_TASKSHUTDOWN', N'WAIT_XTP_HOST_WAIT',
|
||||
N'WAIT_XTP_OFFLINE_CKPT_NEW_LOG', N'WAIT_XTP_CKPT_CLOSE',
|
||||
N'XE_BUFFERMGR_ALLPROCESSED_EVENT', N'XE_DISPATCHER_JOIN',
|
||||
N'XE_DISPATCHER_WAIT', N'XE_LIVE_TARGET_TVF', N'XE_TIMER_EVENT')
|
||||
AND waiting_tasks_count > 0
|
||||
ORDER BY
|
||||
waiting_tasks_count DESC
|
||||
OPTION (RECOMPILE);
|
||||
`
|
||||
|
||||
const sqlAzureDB string = `IF OBJECT_ID('sys.dm_db_resource_stats') IS NOT NULL
|
||||
BEGIN
|
||||
SELECT TOP(1)
|
||||
'sqlserver_azurestats' AS [measurement],
|
||||
REPLACE(@@SERVERNAME,'\',':') AS [sql_instance],
|
||||
SERVERPROPERTY('ServerName') AS [host],
|
||||
avg_cpu_percent,
|
||||
avg_data_io_percent,
|
||||
avg_log_write_percent,
|
||||
avg_memory_usage_percent,
|
||||
xtp_storage_percent,
|
||||
max_worker_percent,
|
||||
max_session_percent,
|
||||
dtu_limit,
|
||||
avg_login_rate_percent,
|
||||
end_time
|
||||
FROM
|
||||
sys.dm_db_resource_stats WITH (NOLOCK)
|
||||
ORDER BY
|
||||
end_time DESC
|
||||
OPTION (RECOMPILE)
|
||||
END
|
||||
ELSE
|
||||
BEGIN
|
||||
RAISERROR('This does not seem to be an AzureDB instance. Set "azureDB = false" in your telegraf configuration.',16,1)
|
||||
END`
|
||||
|
||||
// Queries V1
|
||||
const sqlPerformanceMetrics string = `SET NOCOUNT ON;
|
||||
SET ARITHABORT ON;
|
||||
SET QUOTED_IDENTIFIER ON;
|
||||
|
|
|
|||
Loading…
Reference in New Issue