tubearchivist/tubearchivist-metrics
1
0
Fork 0
mirror of https://github.com/tubearchivist/tubearchivist-metrics.git synced 2024-12-22 09:50:15 +00:00
Code Issues Projects Releases Wiki Activity

Remove unused import

Browse Source 
re-name metrics to be prefixed with yta_
added print log to show the loop is running as expected
This commit is contained in:
Ainsey11 2022-04-15 01:13:25 +01:00
parent 2b4be61d21
commit 848c390bd7
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
tubearchivist-metrics/main.py
View File

@ -1,5 +1,5 @@
import time
from prometheus_client import start_http_server, Gauge, Enum
from prometheus_client import start_http_server, Gauge
from environment import AppConfig
from getmetrics import GetMetrics
@ -21,11 +21,11 @@ class AppMetrics:
self.poll_interval = poll_interval
# Metrics to expose
self.channel_count = Gauge("channel_count", "Number of channels")
self.playlist_count = Gauge("playlist_count", "Number of playlists")
self.download_count = Gauge("download_count", "Number of downloads")
self.download_queue = Gauge("download_queue", "Number of pending downloads")
self.subtitle_count = Gauge("subtitle_count", "Number of subtitles downloaded for videos")
self.channel_count = Gauge("yta_channel_count", "Number of channels")
self.playlist_count = Gauge("yta_playlist_count", "Number of playlists")
self.download_count = Gauge("yta_download_count", "Number of downloads")
self.download_queue = Gauge("yta_download_queue", "Number of pending downloads")
self.subtitle_count = Gauge("yta_subtitle_count", "Number of subtitles downloaded for videos")
# fmt: on
def run_metrics_loop(self):
@ -40,6 +40,7 @@ class AppMetrics:
"""
Retrieves the metrics from the database and updates the metrics.
"""
print("Obtaining Metrics from Elasticsearch")
self.channel_count.set(GetMetrics.count(index_name="ta_channel"))
self.playlist_count.set(GetMetrics.count(index_name="ta_playlist"))
self.download_queue.set(GetMetrics.count(index_name="ta_download"))