Rodrigo Arias Mallo
4048b3327a
Allows us to track ambient temperature changes and estimate the temperature delta between the server room and exterior temperature. We should be able to predict when we would need to stop the machines due to excesive temperature as summer approaches. Reviewed-by: Aleix Boné <abonerib@bsc.es>
55 lines
1.9 KiB
Python
55 lines
1.9 KiB
Python
#!/usr/bin/env python3
|
|
|
|
import time
|
|
from prometheus_client import start_http_server, Gauge
|
|
from bs4 import BeautifulSoup
|
|
from urllib import request
|
|
|
|
# Configuration -------------------------------------------
|
|
meteo_station = "X8" # Barcelona - Zona Universitària
|
|
listening_port = 9929
|
|
update_period = 60 * 5 # Each 5 min
|
|
# ---------------------------------------------------------
|
|
|
|
metric_tmin = Gauge('meteocat_temp_min', 'Min temperature')
|
|
metric_tmax = Gauge('meteocat_temp_max', 'Max temperature')
|
|
metric_tavg = Gauge('meteocat_temp_avg', 'Average temperature')
|
|
metric_srad = Gauge('meteocat_solar_radiation', 'Solar radiation')
|
|
|
|
def update(st):
|
|
url = 'https://www.meteo.cat/observacions/xema/dades?codi=' + st
|
|
response = request.urlopen(url)
|
|
data = response.read()
|
|
soup = BeautifulSoup(data, 'lxml')
|
|
table = soup.find("table", {"class" : "tblperiode"})
|
|
rows = table.find_all('tr')
|
|
row = rows[-1] # Take the last row
|
|
row_data = []
|
|
header = row.find('th')
|
|
header_text = header.text.strip()
|
|
row_data.append(header_text)
|
|
for col in row.find_all('td'):
|
|
row_data.append(col.text)
|
|
try:
|
|
# Sometimes it will return '(s/d)' and fail to parse
|
|
metric_tavg.set(float(row_data[1]))
|
|
metric_tmax.set(float(row_data[2]))
|
|
metric_tmin.set(float(row_data[3]))
|
|
metric_srad.set(float(row_data[10]))
|
|
#print("ok: temp_avg={}".format(float(row_data[1])))
|
|
except:
|
|
print("cannot parse row: {}".format(row))
|
|
metric_tavg.set(float("nan"))
|
|
metric_tmax.set(float("nan"))
|
|
metric_tmin.set(float("nan"))
|
|
metric_srad.set(float("nan"))
|
|
|
|
if __name__ == '__main__':
|
|
start_http_server(port=listening_port, addr="localhost")
|
|
while True:
|
|
try:
|
|
update(meteo_station)
|
|
except:
|
|
print("update failed")
|
|
time.sleep(update_period)
|