python-murfey/src/murfey/server/prometheus.py at 69cdc1800311e404d616fff74a9a20eaba72222d · DiamondLightSource/python-murfey · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
from prometheus_client import Counter, Gauge

seen_files = Gauge(
    "acquired_files", "Number of files produced", ["rsync_source", "visit"]
)
seen_data_files = Gauge(
    "acquired_data_files", "Number of data files produced", ["rsync_source", "visit"]
)
transferred_files = Gauge(
    "transferred_files", "Number of files transferred", ["rsync_source", "visit"]
)
transferred_data_files = Gauge(
    "transferred_data_files",
    "Number of data files transferred",
    ["rsync_source", "visit"],
)

transferred_files_bytes = Gauge(
    "transferred_files_bytes", "Size of files transferred", ["rsync_source", "visit"]
)
transferred_data_files_bytes = Gauge(
    "transferred_data_files_bytes",
    "Size of data files transferred",
    ["rsync_source", "visit"],
)

skipped_files = Gauge(
    "skipped_files",
    "Number of files not transferred due to end time",
    ["rsync_source", "visit"],
)

preprocessed_movies = Counter(
    "preprocessed_movies",
    "Number of movies that have been preprocessed",
    ["processing_job"],
)

exposure_time = Gauge("exposure_time", "Exposure time for a single movie")

monitoring_switch = Gauge(
    "monitoring_on",
    "Whether the corresponding visit should be monitored or not",
    ["visit"],
)

alert_end_time = Gauge("alert_end_time", "End time for alerts", [])