Compare commits

..

No commits in common. "e2df92e6b411f00183a8e689ce3f56bd93a7a538" and "aaadff6306dc47f382a8b97a2611d2c67c4b5231" have entirely different histories.

6 changed files with 37 additions and 59 deletions

4
.gitignore vendored
View File

@ -213,7 +213,3 @@ flycheck_*.el
/__simulate_fail.json /__simulate_fail.json
/mailing_list.yaml /mailing_list.yaml
.vscode/
*.code-workspace

View File

@ -3,7 +3,7 @@
version: 0.2 version: 0.2
survBot is a small program used to track station quality channels of DSEBRA stations via PowBox output over SOH channels survBot is a small program used to track station quality channels of DSEBRA stations via PowBox output over SOH channels
by analyzing contents of a Seiscomp data archive. by analysing contents of a Seiscomp3 datapath.
## Requirements ## Requirements
@ -60,33 +60,33 @@ The directory `/path/to/conf-dir` should contain the `parameters.yaml` file, and
The e-mail server settings can be configured in the `parameters.yaml` file. The following settings are available: The e-mail server settings can be configured in the `parameters.yaml` file. The following settings are available:
* `mailserver`: the address of the mail server - `mailserver`: the address of the mail server
* `auth_type`: the authentication type for the mail server (`None`, `SSL`, `TLS`) - `auth_type`: the authentication type for the mail server (`None`, `SSL`, `TLS`)
* `port`: the port of the mail server - `port`: the port of the mail server
* `user`: the username for the mail server (if required) - `user`: the username for the mail server (if required)
* `password`: the password for the mail server (if required) - `password`: the password for the mail server (if required)
The `user` and `password` fields are optional, and can be left empty if the mail server does not require authentication. The `auth_type` field can be set to `None` if no authentication is required, `SSL` if the mail server requires SSL authentication, or `TLS` if the mail server requires TLS authentication. If the `user` or `password` fields are set to `Docker` ore `ENV` the program will try to read the values from the docker secrets `mail_user` and `mail_password` or environment variables `MAIL_USER` and `MAIL_PASSWORD` respectively. Docker secrets are only available in Docker Swarm mode, i.e. if the program is run as a service. The `user` and `password` fields are optional, and can be left empty if the mail server does not require authentication. The `auth_type` field can be set to `None` if no authentication is required, `SSL` if the mail server requires SSL authentication, or `TLS` if the mail server requires TLS authentication. If the `user` or `password` fileds are set to `Docker` ore `ENV` the program will try to read the values from the docker secrets `mail_user` and `mail_password` or environment variables `MAIL_USER` and `MAIL_PASSWORD` respectively. Docker secrets are only available in Docker Swarm mode, i.e. if the program is run as a service.
## Version Changes ## Version Changes
### 0.2 ### 0.2
* surveillance of mass, clock and gaps - surveillance of mass, clock and gaps
* individual mailing lists for different stations - individual mailing lists for different stations
* html mail with recent status information - html mail with recent status information
* updated web page design - updated web page design
* restructured parameter file - restructured parameter file
* recognize if PBox is disconnected - recognize if PBox is disconnected
### 0.2-docker ### 0.2-docker
* added Dockerfile for easy deployment - added Dockerfile for easy deployment
* added more settings for connection to a mail server - added more settings for connection to a mail server
## Staff ## Staff
Original author: M.Paffrath (<marcel.paffrath@rub.de>) Original author: M.Paffrath (marcel.paffrath@rub.de)
Contributions: Kasper D. Fischer (<kasper.fischer@rub.de>) Contributions by: Kasper D. Fischer (kasper.fischer@rub.de)
Jan 2025 Jan 2025

View File

@ -13,7 +13,7 @@ logging_level: WARN # set logging level (info, warning, debug)
track_changes: True # tracks all changes since GUI startup by text highlighting (GUI only) track_changes: True # tracks all changes since GUI startup by text highlighting (GUI only)
warn_count: False # show number of warnings and errors in table warn_count: False # show number of warnings and errors in table
min_sample: 5 # minimum samples for raising Warn/FAIL min_sample: 5 # minimum samples for raising Warn/FAIL
dt_thresh: [300, 1800] # threshold (s) for timing delay colourisation (yellow/red) dt_thresh: [300, 1800] # threshold (s) for timing delay colorization (yellow/red)
html_figures: True # Create html figure directory and links html_figures: True # Create html figure directory and links
reread_parameters: True # reread parameters file (change parameters on runtime, not for itself/GUI refresh/datapath) reread_parameters: True # reread parameters file (change parameters on runtime, not for itself/GUI refresh/datapath)
@ -117,11 +117,6 @@ data_channels: ["HHZ", "HHN", "HHE"]
# ---------------------------------------- OPTIONAL PARAMETERS --------------------------------------------------------- # ---------------------------------------- OPTIONAL PARAMETERS ---------------------------------------------------------
# deactivate powbox surveillance for stations (e.g. for solar powered), key: station, value: status message (abbr.)
no_pbox_stations: {'GR33': 'SOL', 'GR27B': 'DCN', 'RP01': 'noPBox', 'RP02': 'noPBox', 'RP03': 'noPBox', 'RP04': 'noPBox', 'RP05B': 'noPBox', 'RP06': 'noPBox', 'RP07': 'noPBox', 'RP08': 'noPBox'}
# deactivate mass position surveillance for stations without connected mass channels (e.g. STS-2 instruments), key: station, value: status message (abbr.)
no_mass_stations: {'BIA': 'DCN', 'KNEZ': 'DCN', 'KRUS': 'DCN', 'OHR': 'DCN', 'OTOV': 'DCN', 'SKO': 'DCN', 'STIP': 'DCN', 'VAY': 'DCN', 'ZUPA': 'DCN'}
# add links to html table with specified key as column and value as relative link, interpretable string parameters: # add links to html table with specified key as column and value as relative link, interpretable string parameters:
# nw (e.g. 1Y), st (e.g. GR01A), nwst_id (e.g. 1Y.GR01A) # nw (e.g. 1Y), st (e.g. GR01A), nwst_id (e.g. 1Y.GR01A)
@ -135,7 +130,7 @@ add_links:
add_global_links: add_global_links:
# for example: - {"text": "our homepage", "URL": "https://www.rub.de"} # for example: - {"text": "our homepage", "URL": "https://www.rub.de"}
- {"text": "show recent events on map", - {"text": "show recent events on map",
"URL": "https://fdsnws.geophysik.ruhr-uni-bochum.de/map/?lat=39.5&lon=21&zoom=7&baselayer=osm"} "URL": "https://fdsnws.geophysik.ruhr-uni-bochum.de/map/?lat=39.5&lon=21&zoom=7&baselayer=mapnik"}
# html logo at page bottom (path relative to html directory) # html logo at page bottom (path relative to html directory)
html_logo: "logo.png" html_logo: "logo.png"
@ -145,14 +140,14 @@ EMAIL:
# specify mail server and credentials # specify mail server and credentials
# port, auth_type, user and password are only required if mailserver is not set to "localhost" # port, auth_type, user and password are only required if mailserver is not set to "localhost"
# user and password can be set to "ENV" or "DOCKER" to read from environment variables or docker secrets # user and password can be set to "ENV" or "DOCKER" to read from environment variables or docker secrets
mailserver: "smtp.example.org" # mail server mailserver: "smtp.rub.de" # mail server
auth_type: "SSL" # mail authentication type, can be "SSL", "TLS" or "None" auth_type: "SSL" # mail authentication type, can be "SSL", "TLS" or "None"
port: 465 # mail port, default 465 for SSL, 587 for TLS port: 465 # mail port, default 465 for SSL, 587 for TLS
user: "DOCKER" # mail user, read from environment variable if set to "ENV" or from docker secret if set to "DOCKER" user: "DOCKER" # mail user, read from environment variable if set to "ENV" or from docker secret if set to "DOCKER"
password: "DOCKER" # mail password, read from environment variable if set to "ENV" or from docker secret if set to "DOCKER" password: "DOCKER" # mail password, read from environment variable if set to "ENV" or from docker secret if set to "DOCKER"
# specify mail recipients, sender and blacklists # specify mail recipients, sender and blacklists
addresses: ["test@example.org"] # list of mail addresses for info mails addresses: ["marcel.paffrath@rub.de", "kasper.fischer@rub.de"] # list of mail addresses for info mails
sender: "<test@example.org>" # mail sender sender: "RUB SeisObs <seisobs@ruhr-uni-bochum.de>" # mail sender
stations_blacklist: [] # do not send emails for specific stations stations_blacklist: [] # do not send emails for specific stations
networks_blacklist: [] # do not send emails for specific network networks_blacklist: [] # do not send emails for specific network
# specify recipients for single stations in a yaml: key = email-address, val = station list (e.g. [1Y.GR01, 1Y.GR02]) # specify recipients for single stations in a yaml: key = email-address, val = station list (e.g. [1Y.GR01, 1Y.GR02])

View File

@ -19,7 +19,7 @@ th {
background-color: #17365c; background-color: #17365c;
color: #fff; color: #fff;
border-radius: 3px; border-radius: 3px;
padding: 10px 2px; padding: 10px, 2px;
position: sticky; position: sticky;
top: 0; top: 0;
} }

View File

@ -1,8 +1,8 @@
#!/usr/bin/env python #!/usr/bin/env python
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
__version__ = '0.3' __version__ = '0.2-docker'
__author__ = ['Marcel Paffrath <marcel.paffrath@rub.de>', 'Kasper D. Fischer <kasper.fischer@rub.de>'] __author__ = 'Marcel Paffrath <marcel.paffrath@rub.de>'
import os import os
import io import io
@ -234,7 +234,7 @@ class SurveillanceBot(object):
self.gaps = self.dataStream.get_gaps(min_gap=self.parameters['THRESHOLDS'].get('min_gap')) self.gaps = self.dataStream.get_gaps(min_gap=self.parameters['THRESHOLDS'].get('min_gap'))
self.dataStream.merge() self.dataStream.merge()
# organize data in dictionary with key for each station # organise data in dictionary with key for each station
for trace in self.dataStream: for trace in self.dataStream:
nwst_id = get_nwst_id(trace) nwst_id = get_nwst_id(trace)
if not nwst_id in self.data.keys(): if not nwst_id in self.data.keys():
@ -351,7 +351,7 @@ class SurveillanceBot(object):
first_exec = False first_exec = False
def console_print(self, itemlist, str_len=21, sep='|', seplen=3): def console_print(self, itemlist, str_len=21, sep='|', seplen=3):
assert len(sep) <= seplen, f'Make sure separator has less than {seplen} characters' assert len(sep) <= seplen, f'Make sure seperator has less than {seplen} characters'
sl = sep.ljust(seplen) sl = sep.ljust(seplen)
sr = sep.rjust(seplen) sr = sep.rjust(seplen)
string = sl string = sl
@ -595,7 +595,6 @@ class StationQC(object):
self.status_track = status_track self.status_track = status_track
self.powbox_active = self.is_pbox_activated_check() self.powbox_active = self.is_pbox_activated_check()
self.mass_active = self.is_mass_activated_check()
self.start() self.start()
@ -1081,11 +1080,6 @@ class StationQC(object):
""" Analyse datalogger mass channels. """ """ Analyse datalogger mass channels. """
key = 'mass' key = 'mass'
# skip processing if mass is not active
if not self.mass_active:
self.set_mass_inactive_error(key)
return
# build stream with all channels # build stream with all channels
st = Stream() st = Stream()
for channel in channels: for channel in channels:
@ -1305,7 +1299,7 @@ class StationQC(object):
# Warn in case of voltage under OK-level (1V) # Warn in case of voltage under OK-level (1V)
if len(under) > 0: if len(under) > 0:
# try calculate number of occurrences from gaps between indices # try calculate number of occurences from gaps between indices
n_occurrences = len(np.where(np.diff(under) > 1)[0]) + 1 n_occurrences = len(np.where(np.diff(under) > 1)[0]) + 1
voltage_dict[-1] = under voltage_dict[-1] = under
self.status_other(detailed_message=f'Trace {trace.get_id()}: ' self.status_other(detailed_message=f'Trace {trace.get_id()}: '
@ -1347,12 +1341,6 @@ class StationQC(object):
msg = self.parameters.get('no_pbox_stations')[self.station] msg = self.parameters.get('no_pbox_stations')[self.station]
self.error(key, detailed_message=f'PowBox not connected', disc=msg) self.error(key, detailed_message=f'PowBox not connected', disc=msg)
def is_mass_activated_check(self):
return self.station not in self.parameters.get('no_mass_stations', [])
def set_mass_inactive_error(self, key):
msg = self.parameters.get('no_mass_stations')[self.station]
self.error(key, detailed_message=f'Mass channels not connected', disc=msg)
class Status(object): class Status(object):
""" Basic Status class. All status classes are derived from this class.""" """ Basic Status class. All status classes are derived from this class."""
@ -1407,15 +1395,15 @@ class StatusOK(Status):
class StatusWarn(Status): class StatusWarn(Status):
def __init__(self, message='WARN', count=1, last_occurrence=None, detailed_messages=None, show_count=False): def __init__(self, message='WARN', count=1, last_occurence=None, detailed_messages=None, show_count=False):
super(StatusWarn, self).__init__(message=message, count=count, last_occurrence=last_occurrence, super(StatusWarn, self).__init__(message=message, count=count, last_occurrence=last_occurence,
detailed_messages=detailed_messages, show_count=show_count) detailed_messages=detailed_messages, show_count=show_count)
self.set_warn() self.set_warn()
class StatusError(Status): class StatusError(Status):
def __init__(self, message='FAIL', count=1, last_occurrence=None, detailed_messages=None, show_count=False): def __init__(self, message='FAIL', count=1, last_occurence=None, detailed_messages=None, show_count=False):
super(StatusError, self).__init__(message=message, count=count, last_occurrence=last_occurrence, super(StatusError, self).__init__(message=message, count=count, last_occurrence=last_occurence,
detailed_messages=detailed_messages, show_count=show_count) detailed_messages=detailed_messages, show_count=show_count)
self.set_error() self.set_error()
self.default_message = message self.default_message = message
@ -1432,8 +1420,8 @@ class StatusError(Status):
class StatusOther(Status): class StatusOther(Status):
def __init__(self, messages=None, count=1, last_occurrence=None, detailed_messages=None): def __init__(self, messages=None, count=1, last_occurence=None, detailed_messages=None):
super(StatusOther, self).__init__(count=count, last_occurrence=last_occurrence, super(StatusOther, self).__init__(count=count, last_occurrence=last_occurence,
detailed_messages=detailed_messages) detailed_messages=detailed_messages)
if messages is None: if messages is None:
messages = [] messages = []

View File

@ -6,7 +6,6 @@ import logging
import matplotlib import matplotlib
import numpy as np import numpy as np
import smtplib import smtplib
import os
from obspy import Stream from obspy import Stream
@ -175,7 +174,7 @@ def transform_trace(data, transf):
elif operator_str == '/': elif operator_str == '/':
data = data / val data = data / val
else: else:
raise IOError(f'Unknown arithmetic operator string: {operator_str}') raise IOError(f'Unknown arithmethic operator string: {operator_str}')
return data return data
@ -302,7 +301,7 @@ def get_credential(source, param):
# return source if no credential was found # return source if no credential was found
return source return source
def connect_to_mail_server(mail_params): def connect_to_mail_server(self, mail_params):
""" """
Connect to mail server and return server object. Connect to mail server and return server object.
""" """
@ -326,5 +325,5 @@ def connect_to_mail_server(mail_params):
else: else:
logging.error('Unknown authentication type. Mails can not be sent') logging.error('Unknown authentication type. Mails can not be sent')
return return
s.login(user, password) s.login(mail_params.get('user'), mail_params.get('password'))
return s return s