diff --git a/nasomain.py b/nasomain.py index d8503eb..329476b 100644 --- a/nasomain.py +++ b/nasomain.py @@ -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 settings["sendMqtt"]: + if not 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,8 +356,9 @@ if __name__ == '__main__': samples[ax][reg]+=tempSamples[ax][reg] else: sendSamples(tempSamples) - elif settings['sendInflux']: + else: influxMeas = list() + LOGGER.debug("Invio Influx") for idx,record in enumerate(tempSamples[ax][reg]): ts = tempSamples[ax][reg][idx][templates.SAM_TS]+firstTS*1000000 influxMeas.append({ @@ -376,8 +377,6 @@ 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