short exp() function for get_experiment
This commit is contained in:
12
t.py
12
t.py
@ -5,6 +5,7 @@ from sehistory.seinflux import SEHistory, fmtime
|
|||||||
from influx import RegExp
|
from influx import RegExp
|
||||||
|
|
||||||
DAY = 24 * 3600
|
DAY = 24 * 3600
|
||||||
|
ETERNITY = 1e10
|
||||||
|
|
||||||
# token = "zqDbTcMv9UizfdTj15Fx_6vBetkM5mXN56EE9CiDaFsh7O2FFWZ2X4VwAAmdyqZr3HbpIr5ixRju07-oQmxpXw=="
|
# token = "zqDbTcMv9UizfdTj15Fx_6vBetkM5mXN56EE9CiDaFsh7O2FFWZ2X4VwAAmdyqZr3HbpIr5ixRju07-oQmxpXw=="
|
||||||
|
|
||||||
@ -13,6 +14,7 @@ db = SEHistory(access='write')
|
|||||||
print("""
|
print("""
|
||||||
qry([start], [stop], [interval=...,] [last=True,] [columns=[...],] [<tag>=<value>, ] ...)
|
qry([start], [stop], [interval=...,] [last=True,] [columns=[...],] [<tag>=<value>, ] ...)
|
||||||
crv([start], [stop], [mod.par], ['float'], [interval=...,] [add_prev=False,] [add_end=True,] [<tag>=<value>, ] ...)
|
crv([start], [stop], [mod.par], ['float'], [interval=...,] [add_prev=False,] [add_end=True,] [<tag>=<value>, ] ...)
|
||||||
|
exp([start], [end], [stream], ...))
|
||||||
""")
|
""")
|
||||||
|
|
||||||
now = int(time.time())
|
now = int(time.time())
|
||||||
@ -54,6 +56,16 @@ def crv(*args, **kwds):
|
|||||||
prt()
|
prt()
|
||||||
|
|
||||||
|
|
||||||
|
def exp(*args, **kwds):
|
||||||
|
res = db.get_experiments(*args, **kwds)
|
||||||
|
for exp, streams in res.items():
|
||||||
|
print('---',' '.join(exp))
|
||||||
|
for key, periods in streams.items():
|
||||||
|
print(' '.join(','.join(k) for k in key))
|
||||||
|
for period in periods:
|
||||||
|
print(' ', fmtime(period[0]), fmtime(period[1]))
|
||||||
|
|
||||||
|
|
||||||
def sry(prectime=False):
|
def sry(prectime=False):
|
||||||
interval = 3600
|
interval = 3600
|
||||||
res = db.query(-DAY * 365, interval=interval, _field='float',
|
res = db.query(-DAY * 365, interval=interval, _field='float',
|
||||||
|
Reference in New Issue
Block a user