@cryptotaxi247 / netdata-1 / commits / 41d0bd590

Add connections per database.

Facetoe committed Oct 23, 2016 at 18:10 UTC 41d0bd5909389b20700f77d076c29aab7fe9fe68
1 file changed +8
python.d/postgres.chart.py
+8
@@ -60,6 +60,7 @@ WHERE relkind = 'i';"""
60 DATABASE = """
61 SELECT
62 datname AS database_name,
63 + sum(numbackends) AS connections,
64 sum(xact_commit) AS xact_commit,
65 sum(xact_rollback) AS xact_rollback,
66 sum(blks_read) AS blks_read,
@@ -142,6 +143,11 @@ CHARTS = {
143 ['db_stat_xact_commit', 'Committed', 'absolute'],
144 ['db_stat_xact_rollback', 'Rolled Back', 'absolute']
145 ]},
146 + 'db_stat_connections': {
147 + 'options': [None, ' Connections', 'Count', ' database statistics', '.db_stat_connections', 'line'],
148 + 'lines': [
149 + ['db_stat_connections', 'Connections', 'absolute']
150 + ]},
151 'db_stat_tuple_read': {
152 'options': [None, ' Tuple read', 'Count', ' database statistics', '.db_stat_tuple_read', 'line'],
153 'lines': [
@@ -361,6 +367,8 @@ class Service(SimpleService):
367 self.add_derive_value('db_stat_tup_updated', prefix=database_name, value=int(row.get('tup_updated', 0)))
368 self.add_derive_value('db_stat_tup_deleted', prefix=database_name, value=int(row.get('tup_deleted', 0)))
369 self.add_derive_value('db_stat_conflicts', prefix=database_name, value=int(row.get('conflicts', 0)))
370 + conn_key = "{}_{}".format(database_name, 'db_stat_connections')
371 + self.data[conn_key] = int(row.get('connections', 0))
372
373 def add_backend_stats(self, cursor):
374 cursor.execute(BACKENDS)