File tree Expand file tree Collapse file tree
ooniapi/services/ooniprobe/src/ooniprobe Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -91,6 +91,12 @@ class Metrics:
9191 labelnames = ["status" , "instance" ],
9292 )
9393
94+ FASTPATH_INSTANCE_FAILURE = Counter (
95+ "fastpath_instance_failure" ,
96+ "How many times a measurement submission per fastpath instance failed" ,
97+ labelnames = ["instance" ]
98+ )
99+
94100 SEND_S3_CNT = Counter (
95101 "measurement_s3_upload_count" ,
96102 "How many times ooniprobe sent a measurement to s3 disaggregated by status"
Original file line number Diff line number Diff line change @@ -194,12 +194,14 @@ async def receive_measurement(
194194 break
195195
196196 except Exception as e :
197+ Metrics .FASTPATH_INSTANCE_FAILURE .labels (
198+ instance = fastpath_url
199+ ).inc ()
197200 log .exception (
198201 f"[{ i + 1 } / { len (fastpath_urls )} ] Unable to send measurement to fastpath "
199202 f"({ fastpath_url } ): { e } "
200203 )
201204
202-
203205 if success :
204206 # Geoip anomaly detection runs only when the measurement was successfully
205207 # submitted to the fastpath, so retries don't cause duplicate anomaly entries.
You can’t perform that action at this time.
0 commit comments