Add support for pg_stat_statements to MetricBeat Postgresql module

metricbeat/docs/fields.asciidoc

@@ -10817,6 +10817,221 @@ type: date
 Time at which these statistics were last reset.
 
 
+--
+
+[float]
+== statement fields
+
+One document per query per user per database, showing information related invocation of that query, such as cpu usage and total time. Collected by querying pg_stat_statements.
+
+
+
+*`postgresql.statement.user.id`*::
++
+--
+type: long
+
+OID of the user logged into the backend that ran the query.
+
+
+--
+
+*`postgresql.statement.database.oid`*::
++
+--
+type: long
+
+OID of the database the query was run on.
+
+
+--
+
+*`postgresql.statement.query.id`*::
++
+--
+type: long
+
+ID of the statement.
+
+
+--
+
+*`postgresql.statement.query.text`*::
++
+--
+Query text
+
+
+--
+
+*`postgresql.statement.query.calls`*::
++
+--
+type: long
+
+Number of times the query has been run.
+
+
+--
+
+*`postgresql.statement.query.rows`*::
++
+--
+type: long
+
+Total number of rows returned by query.
+
+
+--
+
+*`postgresql.statement.time.total`*::
++
+--
+type: long
+
+Total number of milliseconds spent running query.
+
+
+--
+
+*`postgresql.statement.time.min`*::
++
+--
+type: long
+
+Minimum number of milliseconds spent running query.
+
+
+--
+
+*`postgresql.statement.time.max`*::
++
+--
+type: long
+
+Maximum number of milliseconds spent running query.
+
+
+--
+
+*`postgresql.statement.time.mean`*::
++
+--
+type: long
+
+Mean number of milliseconds spent running query.
+
+
+--
+
+*`postgresql.statement.time.stddev`*::
++
+--
+type: long
+
+Population standard deviation of time spent running query, in milliseconds.
+
+
+--
+
+*`postgresql.statement.memory.shared.hit`*::
++
+--
+type: long
+
+Total number of shared block cache hits by the query.
+
+
+--
+
+*`postgresql.statement.memory.shared.read`*::
++
+--
+type: long
+
+Total number of shared block cache read by the query.
+
+
+--
+
+*`postgresql.statement.memory.shared.dirtied`*::
++
+--
+type: long
+
+Total number of shared block cache dirtied by the query.
+
+
+--
+
+*`postgresql.statement.memory.shared.written`*::
++
+--
+type: long
+
+Total number of shared block cache written by the query.
+
+
+--
+
+*`postgresql.statement.memory.local.hit`*::
++
+--
+type: long
+
+Total number of local block cache hits by the query.
+
+
+--
+
+*`postgresql.statement.memory.local.read`*::
++
+--
+type: long
+
+Total number of local block cache read by the query.
+
+
+--
+
+*`postgresql.statement.memory.local.dirtied`*::
++
+--
+type: long
+
+Total number of local block cache dirtied by the query.
+
+
+--
+
+*`postgresql.statement.memory.local.written`*::
++
+--
+type: long
+
+Total number of local block cache written by the query.
+
+
+--
+
+*`postgresql.statement.memory.temp.read`*::
++
+--
+type: long
+
+Total number of temp block cache read by the query.
+
+
+--
+
+*`postgresql.statement.memory.temp.written`*::
++
+--
+type: long
+
+Total number of temp block cache written by the query.
+
+
 --
 
 [[exported-fields-prometheus]]

metricbeat/docs/modules/postgresql.asciidoc

@@ -103,9 +103,13 @@ The following metricsets are available:
 
 * <<metricbeat-metricset-postgresql-database,database>>
 
+* <<metricbeat-metricset-postgresql-statement,statement>>
+
 include::postgresql/activity.asciidoc[]
 
 include::postgresql/bgwriter.asciidoc[]
 
 include::postgresql/database.asciidoc[]
 
+include::postgresql/statement.asciidoc[]
+

metricbeat/docs/modules/postgresql/statement.asciidoc

@@ -0,0 +1,23 @@
+////
+This file is generated! See scripts/docs_collector.py
+////
+
+[[metricbeat-metricset-postgresql-statement]]
+=== PostgreSQL statement metricset
+
+beta[]
+
+include::../../../module/postgresql/statement/_meta/docs.asciidoc[]
+
+
+==== Fields
+
+For a description of each field in the metricset, see the
+<<exported-fields-postgresql,exported fields>> section.
+
+Here is an example document generated by this metricset:
+
+[source,json]
+----
+include::../../../module/postgresql/statement/_meta/data.json[]
+----

metricbeat/docs/modules_list.asciidoc

@@ -93,9 +93,10 @@ This file is generated! See scripts/docs_collector.py
 |<<metricbeat-module-php_fpm,PHP_FPM>>  beta[]   |image:./images/icon-no.png[No prebuilt dashboards]    |  
 .1+| .1+|  |<<metricbeat-metricset-php_fpm-pool,pool>> beta[]  
 |<<metricbeat-module-postgresql,PostgreSQL>>     |image:./images/icon-no.png[No prebuilt dashboards]    |  
-.3+| .3+|  |<<metricbeat-metricset-postgresql-activity,activity>>   
+.4+| .4+|  |<<metricbeat-metricset-postgresql-activity,activity>>   
 |<<metricbeat-metricset-postgresql-bgwriter,bgwriter>>   
 |<<metricbeat-metricset-postgresql-database,database>>   
+|<<metricbeat-metricset-postgresql-statement,statement>> beta[]  
 |<<metricbeat-module-prometheus,Prometheus>>  beta[]   |image:./images/icon-no.png[No prebuilt dashboards]    |  
 .2+| .2+|  |<<metricbeat-metricset-prometheus-collector,collector>> beta[]  
 |<<metricbeat-metricset-prometheus-stats,stats>> beta[]  

metricbeat/include/list.go

@@ -100,6 +100,7 @@ import (
 	_ "github.com/elastic/beats/metricbeat/module/postgresql/activity"
 	_ "github.com/elastic/beats/metricbeat/module/postgresql/bgwriter"
 	_ "github.com/elastic/beats/metricbeat/module/postgresql/database"
+	_ "github.com/elastic/beats/metricbeat/module/postgresql/statement"
 	_ "github.com/elastic/beats/metricbeat/module/prometheus"
 	_ "github.com/elastic/beats/metricbeat/module/prometheus/collector"
 	_ "github.com/elastic/beats/metricbeat/module/prometheus/stats"

metricbeat/module/postgresql/statement/_meta/data.json

@@ -0,0 +1,54 @@
+{
+    "@timestamp": "2017-10-12T08:05:34.853Z",
+    "beat": {
+        "hostname": "host.example.com",
+        "name": "host.example.com"
+    },
+    "metricset": {
+        "host": "postgresql:5432",
+        "module": "postgresql",
+        "name": "statements",
+        "rtt": 115
+    },
+    "postgresql": {
+        "statements": {
+            "user": {
+                "id": 10
+            },
+            "database": {
+                "oid": "12407"
+            },
+            "query": {
+                "id":  "3240664890",
+                "text": "SELECT pg_sleep(?);",
+                "calls": "2",
+                "rows": "2",
+                "time": {
+                    "total": 120066.497,
+                    "min": 60029.533,
+                    "max": 60036.964,
+                    "mean": 60033.2485,
+                    "stddev": 3.71549999999843
+                },
+                "memory": {
+                    "shared": {
+                        "hit": 0,
+                        "read": 0,
+                        "dirtied": 0,
+                        "written": 0,
+                    },
+                    "local": {
+                        "hit": 0,
+                        "read": 0,
+                        "dirtied": 0,
+                        "written": 0,
+                    },
+                    "temp": {
+                        "read": 0,
+                        "written": 0,
+                    }
+                }
+            }
+        }
+    }
+}

metricbeat/module/postgresql/statement/_meta/docs.asciidoc

@@ -0,0 +1,3 @@
+=== postgresql statement MetricSet
+
+This is the statement metricset of the module postgresql.