some fixes
This commit is contained in:
parent
b6eaafca8e
commit
dd9871578f
@ -48,7 +48,7 @@ def perform(client, params):
|
|||||||
logger.info("Start")
|
logger.info("Start")
|
||||||
sendCmd(client, "start")
|
sendCmd(client, "start")
|
||||||
|
|
||||||
for i in range(10):
|
for i in range(300):
|
||||||
sendValue(client, 'dev05')
|
sendValue(client, 'dev05')
|
||||||
sendValue(client, 'dev06')
|
sendValue(client, 'dev06')
|
||||||
sendLog(client)
|
sendLog(client)
|
||||||
|
@ -35,5 +35,5 @@ class EGM1mdTsDbSinkHandler(AbstractTsDbSinkHandler):
|
|||||||
except KeyError as e:
|
except KeyError as e:
|
||||||
logger.error(f"missing attribute in payload, items dropped: {e}")
|
logger.error(f"missing attribute in payload, items dropped: {e}")
|
||||||
except TsDbSinkException as e:
|
except TsDbSinkException as e:
|
||||||
logger.error(f"error {e.code} when talking to database, items dropped: {e}")
|
logger.error(f"error {e.code} when talking to database, items dropped: {e.msg}")
|
||||||
|
|
||||||
|
@ -4,6 +4,7 @@
|
|||||||
|
|
||||||
// MQTT command data package of the rig-PC.
|
// MQTT command data package of the rig-PC.
|
||||||
// Topic: rd/set01/rig01/cmd
|
// Topic: rd/set01/rig01/cmd
|
||||||
|
// Name of Experiment shall be short and systematic
|
||||||
{
|
{
|
||||||
// ts: time stamp
|
// ts: time stamp
|
||||||
// en: experimental name
|
// en: experimental name
|
||||||
|
Loading…
x
Reference in New Issue
Block a user