Compare commits
2 Commits
43912135e9
...
23a2d9b7c9
Author | SHA1 | Date | |
---|---|---|---|
23a2d9b7c9 | |||
cf12500ec2 |
@ -8,4 +8,4 @@ RUN apt update && apt install -y bind9-host iputils-ping
|
|||||||
|
|
||||||
COPY . .
|
COPY . .
|
||||||
|
|
||||||
CMD [ "python", "./survBot.py", "-html", "www" ]
|
CMD [ "python", "./survBot.py", "-html", "www", "-parfile", "conf/parameters.yaml" ]
|
||||||
|
@ -137,13 +137,18 @@ html_logo: "logo.png"
|
|||||||
|
|
||||||
# E-mail notifications
|
# E-mail notifications
|
||||||
EMAIL:
|
EMAIL:
|
||||||
mailserver: "smtp.rub.de" # mail server
|
# specify mail server and credentials
|
||||||
port: 465 # mail port
|
# 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
|
||||||
|
mailserver: "smtp.rub.de" # mail server
|
||||||
|
auth_type: "SSL" # mail authentication type, can be "SSL", "TLS" or "None"
|
||||||
|
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
|
||||||
addresses: ["marcel.paffrath@rub.de", "kasper.fischer@rub.de"] # list of mail addresses for info mails
|
addresses: ["marcel.paffrath@rub.de", "kasper.fischer@rub.de"] # list of mail addresses for info mails
|
||||||
sender: "RUB SeisObs <seisobs@ruhr-uni-bochum.de>" # 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])
|
||||||
external_mail_list: "mailing_list.yaml"
|
external_mail_list: "conf/mailing_list.yaml"
|
||||||
|
45
survBot.py
45
survBot.py
@ -23,7 +23,8 @@ from obspy.clients.filesystem.sds import Client
|
|||||||
|
|
||||||
from write_utils import get_html_text, get_html_link, get_html_row, html_footer, get_html_header, get_print_title_str, \
|
from write_utils import get_html_text, get_html_link, get_html_row, html_footer, get_html_header, get_print_title_str, \
|
||||||
init_html_table, finish_html_table, get_mail_html_header, add_html_image
|
init_html_table, finish_html_table, get_mail_html_header, add_html_image
|
||||||
from utils import get_bg_color, get_font_color, modify_stream_for_plot, set_axis_yticks, set_axis_color, plot_axis_thresholds
|
from utils import get_bg_color, get_font_color, modify_stream_for_plot, set_axis_yticks, set_axis_color, plot_axis_thresholds, \
|
||||||
|
connect_to_mail_server
|
||||||
|
|
||||||
try:
|
try:
|
||||||
import smtplib
|
import smtplib
|
||||||
@ -738,7 +739,6 @@ class StationQC(object):
|
|||||||
if add_addresses:
|
if add_addresses:
|
||||||
# create copy of addresses ( [:] ) to prevent changing original, general list with addresses
|
# create copy of addresses ( [:] ) to prevent changing original, general list with addresses
|
||||||
addresses = addresses[:] + list(add_addresses)
|
addresses = addresses[:] + list(add_addresses)
|
||||||
server = mail_params.get('mailserver')
|
|
||||||
if not sender or not addresses:
|
if not sender or not addresses:
|
||||||
logging.info('Mail sender or addresses not (correctly) defined. Return')
|
logging.info('Mail sender or addresses not (correctly) defined. Return')
|
||||||
return
|
return
|
||||||
@ -757,43 +757,10 @@ class StationQC(object):
|
|||||||
html_str = self.add_html_mail_body(text)
|
html_str = self.add_html_mail_body(text)
|
||||||
msg.add_alternative(html_str, subtype='html')
|
msg.add_alternative(html_str, subtype='html')
|
||||||
|
|
||||||
# send message via SMTP server
|
# connect to server, send mail and close connection
|
||||||
# set up starttls connection if server is not "localhost"
|
s = connect_to_mail_server(mail_params)
|
||||||
if server == 'localhost':
|
if not s: # if connection failed
|
||||||
# create connection to localhost
|
return
|
||||||
s = smtplib.SMTP(server)
|
|
||||||
else:
|
|
||||||
user = mail_params.get('user')
|
|
||||||
# read user from docker secret if it is set to 'DOCKER' or
|
|
||||||
# read user from environment variable if it is set to 'ENV'
|
|
||||||
if user == 'DOCKER':
|
|
||||||
try:
|
|
||||||
with open('/run/secrets/mail_user', 'r') as f:
|
|
||||||
user = f.read().strip()
|
|
||||||
except FileNotFoundError as e:
|
|
||||||
logging.error('Could not read mail user from docker secret')
|
|
||||||
logging.error(e)
|
|
||||||
elif user == 'ENV':
|
|
||||||
user = os.environ.get(mail_params.get('user_env'))
|
|
||||||
|
|
||||||
password = mail_params.get('password')
|
|
||||||
# read password from docker secret if it is set to 'DOCKER' or
|
|
||||||
# read password from environment variable if it is set to 'ENV'
|
|
||||||
if password == 'DOCKER':
|
|
||||||
try:
|
|
||||||
with open('/run/secrets/mail_password', 'r') as f:
|
|
||||||
password = f.read().strip()
|
|
||||||
except FileNotFoundError as e:
|
|
||||||
logging.error('Could not read mail password from docker secret')
|
|
||||||
logging.error(e)
|
|
||||||
elif password == 'ENV':
|
|
||||||
password = os.environ.get(mail_params.get('password_env'))
|
|
||||||
|
|
||||||
# create SSL connection to server
|
|
||||||
s = smtplib.SMTP_SSL(server, mail_params.get('port'))
|
|
||||||
s.login(mail_params.get('user'), mail_params.get('password'))
|
|
||||||
|
|
||||||
# send mail and close connection
|
|
||||||
s.send_message(msg)
|
s.send_message(msg)
|
||||||
s.quit()
|
s.quit()
|
||||||
|
|
||||||
|
48
utils.py
48
utils.py
@ -5,6 +5,7 @@ import logging
|
|||||||
|
|
||||||
import matplotlib
|
import matplotlib
|
||||||
import numpy as np
|
import numpy as np
|
||||||
|
import smtplib
|
||||||
|
|
||||||
from obspy import Stream
|
from obspy import Stream
|
||||||
|
|
||||||
@ -279,3 +280,50 @@ def annotate_voltage_states(ax, parameters, pb_key, color='0.75'):
|
|||||||
|
|
||||||
ax.annotate(out_string, (ax.get_xlim()[-1], voltage), color=color, fontsize='xx-small',
|
ax.annotate(out_string, (ax.get_xlim()[-1], voltage), color=color, fontsize='xx-small',
|
||||||
horizontalalignment='right')
|
horizontalalignment='right')
|
||||||
|
|
||||||
|
def get_credential(source, param):
|
||||||
|
"""
|
||||||
|
Retrieve a credential from a Docker secret or environment variable.
|
||||||
|
"""
|
||||||
|
if source == 'DOCKER':
|
||||||
|
try:
|
||||||
|
with open('/run/secrets/'+param.lower(), 'r') as f:
|
||||||
|
return f.read().strip()
|
||||||
|
except FileNotFoundError as e:
|
||||||
|
logging.error(f'Could not read from Docker secret at /run/secrets/{param.lower()}')
|
||||||
|
logging.error(e)
|
||||||
|
elif source == 'ENV':
|
||||||
|
try:
|
||||||
|
return os.environ.get(param.upper())
|
||||||
|
except Exception as e:
|
||||||
|
logging.error(f'Could not read from environment variable {param.upper()}')
|
||||||
|
logging.error(e)
|
||||||
|
# return source if no credential was found
|
||||||
|
return source
|
||||||
|
|
||||||
|
def connect_to_mail_server(self, mail_params):
|
||||||
|
"""
|
||||||
|
Connect to mail server and return server object.
|
||||||
|
"""
|
||||||
|
# get server from parameters
|
||||||
|
server = mail_params.get('mailserver')
|
||||||
|
# get auth_type from parameters
|
||||||
|
auth_type = mail_params.get('auth_type')
|
||||||
|
# set up connection to mail server
|
||||||
|
if auth_type == 'None':
|
||||||
|
s = smtplib.SMTP(server)
|
||||||
|
else:
|
||||||
|
# user and password from parameters, docker secret or environment variable
|
||||||
|
user = get_credential(mail_params.get('user'), 'mail_user')
|
||||||
|
password = get_credential(mail_params.get('password'), 'mail_password')
|
||||||
|
# create secure connection to server
|
||||||
|
if auth_type == 'SSL':
|
||||||
|
s = smtplib.SMTP_SSL(server, mail_params.get('port'))
|
||||||
|
elif auth_type == 'TLS':
|
||||||
|
s = smtplib.SMTP(server, mail_params.get('port'))
|
||||||
|
s.starttls()
|
||||||
|
else:
|
||||||
|
logging.error('Unknown authentication type. Mails can not be sent')
|
||||||
|
return
|
||||||
|
s.login(mail_params.get('user'), mail_params.get('password'))
|
||||||
|
return s
|
||||||
|
Loading…
x
Reference in New Issue
Block a user