Compare commits
No commits in common. "e2df92e6b411f00183a8e689ce3f56bd93a7a538" and "aaadff6306dc47f382a8b97a2611d2c67c4b5231" have entirely different histories.
e2df92e6b4
...
aaadff6306
4
.gitignore
vendored
4
.gitignore
vendored
@ -213,7 +213,3 @@ flycheck_*.el
|
|||||||
|
|
||||||
/__simulate_fail.json
|
/__simulate_fail.json
|
||||||
/mailing_list.yaml
|
/mailing_list.yaml
|
||||||
|
|
||||||
.vscode/
|
|
||||||
|
|
||||||
*.code-workspace
|
|
||||||
|
34
README.md
34
README.md
@ -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
|
||||||
|
@ -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])
|
||||||
|
@ -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;
|
||||||
}
|
}
|
||||||
|
34
survBot.py
34
survBot.py
@ -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 = []
|
||||||
|
7
utils.py
7
utils.py
@ -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
|
||||||
|
Loading…
x
Reference in New Issue
Block a user