Skip to content
GitLab
Commit 52b3c44c authored by Olivier Kaufmann's avatar Olivier Kaufmann
Browse files

Stores state before working in class branch

parent 0a062438
master 144-create-testing-framework-for-tests-automation EGU23 MB.2024.ter_restored MUX_board_v2024 Refactor_mb_2023 battery_charger board_v4 code_refactor dev/dummy mqtt update_V2023 v2024_rc v2025_alpha v2024.0.34 v2024.0.33 v2024.0.32 v2024.0.31 v2024.0.30 v2024.0.29 v2024.0.28 v2024.0.27 v2024.0.26 v2024.0.25 v2024.0.24 v2024.0.23 v2024.0.22 v2024.0.21 v2024.0.20 v2024.0.19 v2024.0.18 v2024.0.17 v2024.0.16 v2024.0.15 v2024.0.14 v2024.0.13 v2024.0.12 v2024.0.11 v2024.0.10 v2024.0.9 v2024.0.8 v2024.0.7 v2024.0.0 v2023.0.1 v2023.0.0 archives/mqtt
No related merge requests found
Expand all Hide whitespace changes
Inline Side-by-side
Showing
with 811 additions and 302 deletions
+811 -302
Ohmpi_4elec_mqtt.py
+ 24
− 28
View file @ 52b3c44c
......@@ -19,7 +19,7 @@ try:
except:
pass
from pandas import DataFrame
# from pandas import DataFrame
from datetime import datetime
import time
import numpy as np
......@@ -230,28 +230,23 @@ def run_measurement(nb_stack, injection_deltat, r_shunt, coefp2, coefp3):
#print(['time stop=',((2*(end_delay-start_delay)-(end_calc-start_delay)))])
# return averaged values
# cpu= CPUTemperature()
output = DataFrame({
"time": [datetime.now()],
"A": [(1)],
"B": [(2)],
"M": [(3)],
"N": [(4)],
output = {
"time": datetime.now(),
"A": (1),
"B": (2),
"M": (3),
"N": (4),
"inj time [ms]": (end_delay - start_delay) * 1000,
"Vmn [mV]": [(sum_vmn / (3 + 2 * nb_stack - 1))],
"I [mA]": [(injection_current / (3 + 2 * nb_stack - 1))],
"R [ohm]": [(sum_vmn / (3 + 2 * nb_stack - 1) / (injection_current / (3 + 2 * nb_stack - 1)))],
"Ps [mV]": [(sum_ps / (3 + 2 * nb_stack - 1))],
"nbStack": [nb_stack],
"CPU temp [°C]": [cpu.temperature],
"Time [s]": [(-start_time + time.time())],
"Integer [-]": [integer]
# Dead time equivalent to the duration of the current injection pulse
})
output = output.round(2)
print(output.to_string())
"Vmn [mV]": (sum_vmn / (3 + 2 * nb_stack - 1)),
"I [mA]": (injection_current / (3 + 2 * nb_stack - 1)),
"R [ohm]": (sum_vmn / (3 + 2 * nb_stack - 1) / (injection_current / (3 + 2 * nb_stack - 1))),
"Ps [mV]": (sum_ps / (3 + 2 * nb_stack - 1)),
"nbStack": nb_stack,
"CPU temp [°C]": cpu.temperature,
"Time [s]": (-start_time + time.time()),
"Integer [-]": integer}
# output = output.round(2)
print(output) # .to_string())
time.sleep(1)
return output
......@@ -260,13 +255,14 @@ def append_and_save(data_path, last_measurement):
"""Save data"""
if path.isfile(data_path):
# Load data file and append data to it
with open(data_path, 'a') as f:
last_measurement.to_csv(f, header=False)
# with open(data_path, 'a') as f:
# last_measurement.to_csv(f, header=False)
pass
else:
# create data file and add headers
with open(data_path, 'a') as f:
last_measurement.to_csv(f, header=True)
# with open(data_path, 'a') as f:
# last_measurement.to_csv(f, header=True)
pass
"""
Main loop
......@@ -275,7 +271,7 @@ for g in range(0, pardict.get("nbr_meas")): # for time-lapse monitoring
current_measurement = run_measurement(pardict.get("stack"), pardict.get("injection_duration"),
OHMPI_CONFIG['R_shunt'], OHMPI_CONFIG['coef_p2'], OHMPI_CONFIG['coef_p3'])
append_and_save(pardict.get("export_path"), current_measurement)
msg = f'Resitivity: {current_measurement.iloc[-1]["R [ohm]"]:.2f} ohm'
msg = f'Resitivity: {current_measurement["R [ohm]"]:.2f} ohm'
msg_logger.info(msg)
mqtt_client.publish(measurement_topic, msg)
time.sleep(pardict.get("sequence_delay")) # waiting next measurement (time-lapse)
Pipfile
+ 10
− 7
View file @ 52b3c44c
......@@ -4,17 +4,20 @@ url = "https://pypi.org/simple"
verify_ssl = true
[dev-packages]
jupyterlab = "*"
sphinx-rtd-theme = "*"
recommonmark = "*"
sphinx-pdj-theme = "*"
[packages]
paho-mqtt = "*"
numpy = "*"
pandas = "*"
# cython = "*"
# pandas = "*"
paho-mqtt = "*"
pytz = "*"
six = "*"
gpiozero = "*"
adafruit-blinka = "*"
adafruit-circuitpython-ads1x15 = "*"
adafruit-circuitpython-tca9548a = "*"
adafruit-circuitpython-mcp230xx = "*"
termcolor ="*"
[requires]
python_version = "3.8"
python_version = "3.9"
basic_mqtt_ohmpi_console.ipynb
+ 111
− 13
View file @ 52b3c44c
%% Cell type:markdown id:606c11c0-3a80-4138-ac50-1da0bd01bef8 tags:
# A small code to test MQTT interface for ohmpi
%% Cell type:code id:daf2041b-1df9-42de-a385-f450a826c96f tags:
``` python
import paho.mqtt.client as mqtt
import time
```
%% Cell type:code id:14c42035 tags:
``` python
client_id = 'ohmpi_console_sn_0001'
measurements_topic = 'measurements_ohmpi_sn_0001'
client_id = 'ohmpi_sn_001'
control_topic = 'cmd_ohmpi_sn_001'
measurements_topic = 'measurements_ohmpi_sn_001'
```
%% Cell type:code id:391c6373-f7db-485e-b3dd-b1e04a37473a tags:
``` python
broker_address="mg3d-dev.umons.ac.be"
```
%% Cell type:code id:8fc857ba-bbcf-4f99-a30f-84fd14ddb2d0 tags:
``` python
client = mqtt.Client(client_id, protocol=4) #create new instance
```
%% Cell type:code id:24926751-62c6-4833-8d68-99279192d4e0 tags:
``` python
def on_message(client, userdata, message):
m = str(message.payload.decode("utf-8"))
print(f'message received {m}')
print(f'topic: {message.topic}')
print(f'qos: {message.qos}')
print(f'retain flag: {message.retain}')
client.publish(measurements_topic, f'{m} 45 ohm.m')
```
%% Cell type:code id:06e424ff-cd1d-4756-bf53-cfbca4628e73 tags:
``` python
client.connect(broker_address) #connect to broker
```
%% Output
0
%% Cell type:code id:f0b06a71-b0bf-4551-a044-94b1100a3a5d tags:
``` python
client.on_message = on_message
client.loop_start()
```
%% Cell type:code id:8e168d2d-25fa-49ac-9d03-dd0da5e61841 tags:
``` python
print("Subscribing to topic", measurements_topic)
client.subscribe(measurements_topic)
print("Subscribing to topic", control_topic)
client.subscribe(control_topic)
```
%% Output
Subscribing to topic measurements_ohmpi_sn_0001
Subscribing to topic cmd_ohmpi_sn_001
(0, 1)
%% Cell type:code id:eaa7d034-5383-4ece-a824-f763ce214760 tags:
``` python
time.sleep(60)
time.sleep(45)
```
%% Output
message received Resitivity: 215.22 ohm
topic: measurements_ohmpi_sn_0001
message received 21:26:23 : measure resistivity 0 with array 1 4 2 3
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received Resitivity: 214.94 ohm
topic: measurements_ohmpi_sn_0001
message received 21:26:24 : measure resistivity 1 with array 2 5 3 4
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:25 : measure resistivity 2 with array 3 6 4 5
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:26 : measure resistivity 3 with array 4 7 5 6
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:27 : measure resistivity 4 with array 5 8 6 7
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:28 : measure resistivity 5 with array 6 9 7 8
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:29 : measure resistivity 6 with array 7 10 8 9
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:30 : measure resistivity 7 with array 8 11 9 10
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:31 : measure resistivity 8 with array 9 12 10 11
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:32 : measure resistivity 9 with array 10 13 11 12
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:33 : measure resistivity 10 with array 11 14 12 13
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:34 : measure resistivity 11 with array 12 15 13 14
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:35 : measure resistivity 12 with array 13 16 14 15
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:36 : measure resistivity 13 with array 14 17 15 16
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:37 : measure resistivity 14 with array 15 18 16 17
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:38 : measure resistivity 15 with array 16 19 17 18
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:39 : measure resistivity 16 with array 17 20 18 19
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:40 : measure resistivity 17 with array 18 21 19 20
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:41 : measure resistivity 18 with array 19 22 20 21
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:42 : measure resistivity 19 with array 20 23 21 22
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:43 : measure resistivity 20 with array 21 24 22 23
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:44 : measure resistivity 21 with array 22 25 23 24
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:45 : measure resistivity 22 with array 23 26 24 25
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:46 : measure resistivity 23 with array 24 27 25 26
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:47 : measure resistivity 24 with array 25 28 26 27
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
message received 21:26:48 : measure resistivity 25 with array 26 29 27 28
topic: cmd_ohmpi_sn_001
qos: 0
retain flag: 0
%% Cell type:code id:9bd768aa-c4d3-429e-b667-6e981bd28353 tags:
``` python
client.loop_stop()
```
%% Cell type:code id:f9a0333a-c1ec-42a8-bd24-3dc466c51bb4 tags:
``` python
```
......
basic_mqtt_ohmpi_controller.ipynb
+ 665
− 253
View file @ 52b3c44c
This diff is collapsed.
ohmpi_param.json
+ 1
− 1
View file @ 52b3c44c
{
"nb_electrodes": 64,
"injection_duration": 4,
"injection_duration": 1,
"nbr_meas": 100,
"sequence_delay": 1,
"stack": 1,
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment