cose
This commit is contained in:
@@ -341,7 +341,7 @@ if __name__ == '__main__':
|
||||
for idx,rec in enumerate(tempSamples[ax][reg]):
|
||||
tempSamples[ax][reg][idx]=(tempSamples[ax][reg][idx][templates.SAM_TS],
|
||||
tempSamples[ax][reg][idx][templates.SAM_VAL])
|
||||
if not settings["sendMqtt"]:
|
||||
if settings["sendMqtt"]:
|
||||
if tempSamples[ax][reg][idx][templates.SAM_TS] > settings["recordTime"]:
|
||||
samples[ax][reg] = samples[ax][reg][-(len(samples)-len(tempSamples)):]
|
||||
if bufferFull < 1:
|
||||
@@ -356,7 +356,7 @@ if __name__ == '__main__':
|
||||
samples[ax][reg]+=tempSamples[ax][reg]
|
||||
else:
|
||||
sendSamples(tempSamples)
|
||||
else:
|
||||
elif settings['sendInflux']:
|
||||
influxMeas = list()
|
||||
for idx,record in enumerate(tempSamples[ax][reg]):
|
||||
ts = tempSamples[ax][reg][idx][templates.SAM_TS]+firstTS*1000000
|
||||
@@ -376,6 +376,8 @@ if __name__ == '__main__':
|
||||
LOGGER.error(f'Impossibile scrivere nel database: {e}')
|
||||
LOGGER.error(f'TS da controllo: {datetime.fromtimestamp(ts).strftime("%d/%m/%y_%H:%M:%S,%f")}')
|
||||
stat='STOP'
|
||||
else:
|
||||
pass
|
||||
pass
|
||||
pass
|
||||
pass
|
||||
|
||||
Reference in New Issue
Block a user