Reduce cardinality of http_server_active_requests (#745)

Set the multiprocess mode on http_server_active_requests to "livesum" to reduce the cardinality to one metric per server.

baseplate/clients/cassandra.py

@@ -50,6 +50,7 @@ class CassandraPrometheusLabels(NamedTuple):
     "cassandra_client_active_requests",
     "Current number of active cassandra queries",
     CassandraPrometheusLabels._fields,
+    multiprocess_mode="livesum",
 )
 REQUEST_TOTAL = Counter(
     "cassandra_client_requests_total",

baseplate/clients/memcache/__init__.py

@@ -195,6 +195,7 @@ def make_object_for_context(self, name: str, span: Span) -> "MonitoredMemcacheCo
     f"{PROM_NAMESPACE}_client_active_requests",
     "Number of active requests",
     LABELS_COMMON,
+    multiprocess_mode="livesum",
 )
 
 

baseplate/clients/redis.py

@@ -50,6 +50,7 @@
     f"{PROM_PREFIX}_active_requests",
     "Number of active requests for a given client",
     PROM_SHARED_LABELS,
+    multiprocess_mode="livesum",
 )
 
 PROM_POOL_PREFIX = f"{PROM_PREFIX}_pool"
@@ -59,16 +60,19 @@
     f"{PROM_POOL_PREFIX}_max_size",
     "Maximum number of connections allowed in this redis client connection pool",
     PROM_LABELS,
+    multiprocess_mode="livesum",
 )
 IDLE_CONNECTIONS = Gauge(
     f"{PROM_POOL_PREFIX}_idle_connections",
     "Number of idle connections in this redis client connection pool",
     PROM_LABELS,
+    multiprocess_mode="livesum",
 )
 OPEN_CONNECTIONS = Gauge(
     f"{PROM_POOL_PREFIX}_active_connections",
     "Number of open connections in this redis client connection pool",
     PROM_LABELS,
+    multiprocess_mode="livesum",
 )
 
 

baseplate/clients/requests.py

@@ -134,6 +134,7 @@ def http_adapter_from_config(
     f"{PROM_NAMESPACE}_active_requests",
     "Number of active requests for a given client",
     HTTP_LABELS_COMMON,
+    multiprocess_mode="livesum",
 )
 
 

baseplate/clients/sqlalchemy.py

@@ -168,17 +168,20 @@ class SQLAlchemyEngineContextFactory(ContextFactory):
         f"{PROM_POOL_PREFIX}_max_size",
         "Maximum number of connections allowed in this pool",
         PROM_POOL_LABELS,
+        multiprocess_mode="livesum",
     )
 
     checked_out_connections_gauge = Gauge(
         f"{PROM_POOL_PREFIX}_active_connections",
         "Number of connections in use by this pool (checked out + overflow)",
         PROM_POOL_LABELS,
+        multiprocess_mode="livesum",
     )
     checked_in_connections_gauge = Gauge(
         f"{PROM_POOL_PREFIX}_idle_connections",
         "Number of connections not in use by this pool (unused pool connections)",
         PROM_POOL_LABELS,
+        multiprocess_mode="livesum",
     )
 
     PROM_LABELS = [
@@ -198,6 +201,7 @@ class SQLAlchemyEngineContextFactory(ContextFactory):
         f"{PROM_PREFIX}_active_requests",
         "total requests that are in-flight",
         PROM_LABELS,
+        multiprocess_mode="livesum",
     )
 
     requests_total = Counter(

baseplate/clients/thrift.py

@@ -62,6 +62,7 @@
     f"{PROM_NAMESPACE}_active_requests",
     "number of in-flight requests",
     PROM_COMMON_LABELS,
+    multiprocess_mode="livesum",
 )
 
 

baseplate/frameworks/pyramid/__init__.py

@@ -115,6 +115,7 @@ def close(self) -> None:
         "http_method",
         "http_endpoint",
     ],
+    multiprocess_mode="livesum",
 )
 
 

baseplate/frameworks/queue_consumer/kafka.py

@@ -65,6 +65,7 @@ class KafkaConsumerPrometheusLabels(NamedTuple):
     "kafka_consumer_active_messages",
     "gauge that reflects the number of messages currently being processed",
     KafkaConsumerPrometheusLabels._fields,
+    multiprocess_mode="livesum",
 )
 
 

baseplate/frameworks/queue_consumer/kombu.py

@@ -55,6 +55,7 @@ class AmqpConsumerPrometheusLabels(NamedTuple):
     "amqp_consumer_active_messages",
     "gauge that reflects the number of messages currently being processed",
     AmqpConsumerPrometheusLabels._fields,
+    multiprocess_mode="livesum",
 )
 
 

baseplate/frameworks/thrift/__init__.py

@@ -53,6 +53,7 @@
     f"{PROM_NAMESPACE}_active_requests",
     "The number of in-flight requests being handled by the service",
     ["thrift_method"],
+    multiprocess_mode="livesum",
 )