Added wsgi archive plot file
This commit is contained in:
Bernardo
186
wsgi_isttok_archive.py
Normal file
186
wsgi_isttok_archive.py
Normal file
@@ -0,0 +1,186 @@
|
||||
#!/usr/bin/env python2
|
||||
# -*- coding: utf-8 -*-
|
||||
"""
|
||||
Created on Thu Feb 8 16:34:35 2018
|
||||
|
||||
@author: joao_loureiro
|
||||
"""
|
||||
|
||||
import epics
|
||||
import time
|
||||
import os
|
||||
|
||||
import matplotlib
|
||||
matplotlib.use('Agg')
|
||||
import matplotlib.pyplot as plt
|
||||
import matplotlib.ticker as mtick
|
||||
|
||||
import mpld3
|
||||
from mpld3 import plugins, utils
|
||||
|
||||
import numpy as np
|
||||
import MySQLdb
|
||||
|
||||
os.environ['EPICS_CA_ADDR_LIST']= '192.168.1.110 192.168.1.152'
|
||||
os.environ['EPICS_CA_AUTO_ADDR_LIST']= 'NO'
|
||||
|
||||
class HelloWorld(mpld3.plugins.PluginBase): # inherit from PluginBase
|
||||
"""Hello World plugin"""
|
||||
|
||||
JAVASCRIPT = """
|
||||
mpld3.register_plugin("helloworld", HelloWorld);
|
||||
HelloWorld.prototype = Object.create(mpld3.Plugin.prototype);
|
||||
HelloWorld.prototype.constructor = HelloWorld;
|
||||
function HelloWorld(fig, props){
|
||||
mpld3.Plugin.call(this, fig, props);
|
||||
};
|
||||
|
||||
HelloWorld.prototype.draw = function(){
|
||||
// FIXME: this is a very brittle way to select the y-axis element
|
||||
var ax = this.fig.axes[0].elements[1];
|
||||
|
||||
// see https://github.com/mbostock/d3/wiki/Formatting#d3_format
|
||||
// for d3js formating documentation
|
||||
ax.axis.tickFormat(d3.format(",.3e"));
|
||||
|
||||
// TODO: use a function for tick values that
|
||||
// updates when values pan and zoom
|
||||
//ax.axis.tickValues([1,100,1000]);
|
||||
|
||||
// HACK: use reset to redraw figure
|
||||
this.fig.reset();
|
||||
}
|
||||
"""
|
||||
def __init__(self):
|
||||
self.dict_ = {"type": "helloworld"}
|
||||
|
||||
style_tooltip = """
|
||||
<style>
|
||||
.tooltip {
|
||||
position: relative;
|
||||
display: inline-block;
|
||||
border-bottom: 1px dotted black;
|
||||
}
|
||||
|
||||
.tooltip .tooltiptext {
|
||||
visibility: hidden;
|
||||
width: 800px;
|
||||
background-color: #555;
|
||||
color: #fff;
|
||||
text-align: center;
|
||||
border-radius: 6px;
|
||||
padding: 5px 0;
|
||||
position: absolute;
|
||||
z-index: 1;
|
||||
bottom: 125%;
|
||||
left: 50%;
|
||||
margin-left: -60px;
|
||||
opacity: 0;
|
||||
transition: opacity 1s;
|
||||
}
|
||||
|
||||
.tooltip .tooltiptext::after {
|
||||
content: "";
|
||||
position: absolute;
|
||||
top: 100%;
|
||||
left: 50%;
|
||||
margin-left: -5px;
|
||||
border-width: 5px;
|
||||
border-style: solid;
|
||||
border-color: #555 transparent transparent transparent;
|
||||
}
|
||||
|
||||
.tooltip:hover .tooltiptext {
|
||||
visibility: visible;
|
||||
opacity: 1;
|
||||
}
|
||||
</style>
|
||||
"""
|
||||
|
||||
def text_with_tooltip(text, tooltip):
|
||||
html = '<div class="tooltip">'+text+'\n'\
|
||||
' <span class="tooltiptext">'+tooltip+'</span></div>'
|
||||
return html
|
||||
|
||||
|
||||
def application(environ,start_response):
|
||||
status = '200 OK'
|
||||
valuePrimary1 = epics.caget('ISTTOK:central:RPump1-Pressure')
|
||||
valuePrimary2 = epics.caget('ISTTOK:central:RPump2-Pressure')
|
||||
valueChamber1 = epics.caget('ISTTOK:central:VVessel-Pressure')
|
||||
valueTMPadmission = epics.caget('ISTTOK:central:TMPump1-PressureAdmission')
|
||||
now = time.ctime()
|
||||
# Open database connection
|
||||
db = MySQLdb.connect(host = "192.168.1.152",user = "report", passwd="$report", db = "archive")
|
||||
# prepare a cursor object using cursor() method
|
||||
cursor = db.cursor()
|
||||
|
||||
# 19 | ISTTOK:central:VVessel-Pressure
|
||||
sql_chamber ="SELECT `smpl_time`, `float_val` FROM `sample` WHERE `channel_id` = 19 ORDER BY `smpl_time` DESC LIMIT 250;"
|
||||
# 21 | ISTTOK:central:RPump1-Pressure
|
||||
sql_primary ="SELECT `smpl_time`, `float_val` FROM `sample` WHERE `channel_id` = 21 ORDER BY `smpl_time` DESC LIMIT 250;"
|
||||
# Execute the SQL command
|
||||
cursor.execute(sql_chamber)
|
||||
# Fetch all the rows in a list of lists.
|
||||
results = cursor.fetchall()
|
||||
|
||||
data_chamber = []
|
||||
for row in results:
|
||||
data_chamber.append([row[0],row[1]])
|
||||
|
||||
# Execute the SQL command
|
||||
cursor.execute(sql_primary)
|
||||
# Fetch all the rows in a list of lists.
|
||||
results = cursor.fetchall()
|
||||
|
||||
data_primary = []
|
||||
for row in results:
|
||||
data_primary.append([row[0],row[1]])
|
||||
|
||||
# disconnect from server
|
||||
db.close()
|
||||
#
|
||||
data_chamber = np.array(data_chamber)
|
||||
data_primary = np.array(data_primary)
|
||||
fig,axr = plt.subplots(1, sharex=True)
|
||||
|
||||
axr.plot(data_chamber[:,0],data_chamber[:,1])
|
||||
axr.plot(data_primary[:,0],data_primary[:,1])
|
||||
axr.legend(['Tokamak Chamber', 'Primary pump'], loc =2)
|
||||
axr.set_xlabel('Time', fontsize = 15)
|
||||
axr.set_ylabel('Pressure [mbar]', fontsize = 15)
|
||||
axr.yaxis.set_major_formatter(mtick.FormatStrFormatter('%.3e'))
|
||||
fig.set_size_inches(12,5, forward=True)
|
||||
fig.tight_layout()
|
||||
ax_fmt = HelloWorld()
|
||||
mpld3.plugins.connect(fig, ax_fmt)
|
||||
html2 = mpld3.fig_to_html(fig)
|
||||
html = '<html>\n' \
|
||||
'<head>' \
|
||||
'<title>ISTTOK EPICS WSGI Page</title>' \
|
||||
'</head>\n' \
|
||||
'<body>\n' \
|
||||
'<div>'+style_tooltip+'</div>\n'\
|
||||
'<div style="width: 100%; font-size: 40px; font-weight: bold; text-align: center;">\n' \
|
||||
'mod_wsgi EPICS ISTTOK info Page\n' \
|
||||
'</div>\n' \
|
||||
'<div style="width: 100%; font-size: 30px; font-weight: bold; text-align: center;">\n' \
|
||||
' '+text_with_tooltip('Primary pump 1 pressure: '+ '{0:.3e}'.format(valuePrimary1)+ ' mBar','ISTTOK:vacuum:Pressure_Primary1')+'\n' \
|
||||
'</div>\n' \
|
||||
'<div style="width: 100%; font-size: 30px; font-weight: bold; text-align: center;">\n' \
|
||||
' '+text_with_tooltip('Turbopump 1 admission pressure: '+ '{0:.3e}'.format(valueTMPadmission)+ ' mBar','ISTTOK:vacuum:Pressure_TMP_admission')+'\n' \
|
||||
'</div>\n' \
|
||||
'<div style="width: 100%; font-size: 30px; font-weight: bold; text-align: center;">\n' \
|
||||
' '+text_with_tooltip('Tokamak Vessel pressure: '+ '{0:.3e}'.format(valueChamber1)+ ' mBar','ISTTOK:vacuum:Pressure_Chamber1')+'\n' \
|
||||
'</div>\n' \
|
||||
'<div style="width: 100%; font-size: 30px; font-weight: bold; text-align: center;">\n' \
|
||||
'Current Time: ' +now+ '\n' \
|
||||
'</div><center>\n'+html2 +'</center>\n' \
|
||||
'</body>\n' \
|
||||
'</html>\n'
|
||||
response_header = [('Content-type','text/html')]
|
||||
start_response(status,response_header)
|
||||
html = bytes(html, encoding= 'utf-8')
|
||||
return [html]
|
||||
|
||||
#'</div><center>\n'+html2.encode('utf8')+'</center>\n' \
|
||||
Reference in New Issue
Block a user