Compare commits

...

2 Commits

Author SHA1 Message Date
7d8d8b1c6a soil hottis
All checks were successful
ci/woodpecker/push/woodpecker Pipeline was successful
ci/woodpecker/tag/woodpecker Pipeline was successful
2023-12-24 11:05:37 +01:00
ffbda52c36 migration stuff
All checks were successful
ci/woodpecker/push/woodpecker Pipeline was successful
2023-12-23 22:57:27 +01:00
5 changed files with 69 additions and 12 deletions

View File

@ -0,0 +1,22 @@
{
"mqtt": {
"broker": "ssl://eu1.cloud.thethings.network:8883",
"username": "de-hottis-app01@ttn",
"password": "ENV",
"tlsEnable": "true"
},
"topicMappings": [
{
"topics": [ "v3/#" ],
"handler": "TTN",
"id": "TTN0",
"config": {
"attributes": {
}
}
}
],
"archiver": {
"dir": "/archive"
}
}

View File

@ -1,12 +1,15 @@
U2FsdGVkX1/33mRN8ZtRceOCaBsRfu4TFhEmQgf1hF6sSZ43vsWOY77WrnlNEhF7 U2FsdGVkX18F3lXFVDFOS8Q3iGZsIPmMr9CvSshg1t4VTJ8fVlJ6LbFwT3SD1x4a
l3Tb7zNWOz9X0wijuoap7ZveIqHd/3kboKIHN+zdXbKO2HjkxTHPTt1Ot+t+jdbH Z2IdRTWT8wPG7Y9w4c3xbfFZywsJbxyrY+i3Lh7qvpsj7CXiWGOahdj5Pqu1UE3g
CAkNJmhrgcUbciMKe1k5MB7Xyd2A/jZUUxgFnXBeGE/q4UL1hWV+uqK1lqGjw5C9 3PiMpmfyeHKn30hRhupO6jL7kzxJEV8uov/sUh7H+76/R1h5oBBxJEhCl9nPrrf8
Z+SzGIWuXX6DuXPFgPA6wNgqeU05ZU1ufimISt/a2VIhyTxiCVFPVrBHKIHCGnsT 7QaxFeJzogjHu+szvkOM5WylE/PuPv53OGF+7+6R5rK5v25pWlIhuUPg3CKk1qBg
x6sdFkDGsxPoWRiSDWCf3dM2q378crKoWCvZViU+DFVlsKULoztDaazs5Zs9vn3l Ice6q2j5vQe1u+wEdJbxsvbwIdAQC8r6flPuwUeMfLe/Myiuo7v03Re45XKVCQAx
YulsiFwVVaYYeIBNtr0pYOCDy55gh1c11Tmf2B2EXXR9R6QMLu/5FSHheQi0UGMo H+i5Gh50KHqfoZliLeH0ShNSHPNh7zjuBF01o1/Y6KbKDga8G8FjGMn11kjkMCqX
BH2dYHS/STb1CJX5HNazEyJtA6clMtEBHyOfnX3OfASe2KhUbTPY8PaP796APO5I KxdF6Fp1up02n4UTk0+m1ekEc2bk+NZ71xb/iBdsZtyK9POj2ZAuxrjxJZH2FzQ+
gVIL6doszhRI7lTcAh/HImc4LL7Vb9aWUyeHONjPp7HJmn88Ykan3o4pQ3KBnzLQ 5lh/AgyH1LC8ms4KL5HjPLEIHQIkD/MJCnti/hQ7ZpoqFBRnTmRdv9w+pC/aXlmb
rxQKT46ZggW54z0n8+HesTngGRjDKWsovJG+w5ldD1IQpi3iMJhd/Dk/yUiBYpD3 en6I8Mv82qe1sdVlyoiTAqL1flfUjd+yICUE04g/M9NPYidhc+FZrsqyeVfSJYOh
P7gGkxF4aQgf6RUCyf4nBGf3HwOBXddEHkI1KFRDAEMDdIUpVkBoV+Tq0yJWr26f eDl4owAUjzJuDBkuFAX1PHwKglNcIx/rNaxF8ROSDyv59Qzzi84U3xmfm4JqGp2X
ijMIrwJkC99diQaGKDamxlY5dh18GaleCP3tXpXKOexKyRyH6gPr45MWL0ySwhNv 2DAMT2Du8fP/cpRrwWQNtFN7a0FxOnmhDO6SAZoDisEeWR3r+2KsnR6ztKWgGWHK
m/f7Leu/IcdXGsjsE4PtnGxJS0RLhI6Nlf6OZ1VfuA3wFRASmChlkPTWMq2ot6/q uTsb/g8fwx/KH2RsPukmiX7s8aTWcS5DyADNF8VgWKa3BU1icDlku+gMCINyHA9k
iLR7qzBDXzZPLXj+tm7DjLnZYe2w2Ih7A3ZWsNI6Fp7wFFfqH3TYEM38VZWpzQmz
gGa3vuIohn0Mt6JHeZ9zHc8wYruBhjeU16VHawP12jBSnFQnP/FeJq/WpUMW3YDY
c8jsXokMCKUNubnzsmeQgiL0721IfB6+KdiGMucZZkQ=

1
migration/.gitignore vendored Normal file
View File

@ -0,0 +1 @@
.venv

View File

@ -0,0 +1,29 @@
import psycopg2
from loguru import logger
try:
srcConn = psycopg2.connect(database="level_monitoring_berresheim")
srcConn.autocommit = False
with srcConn.cursor() as srcCur:
srcCur.execute("select time, application_name, raw_level, level, status, battery from measurement_t")
for srcObj in srcCur:
timestamp = srcObj[0]
deviceName = srcObj[1]
rawLevel = srcObj[2]
level = srcObj[3]
status = srcObj[4]
battery = srcObj[5]
logger.info(f"{timestamp=}, {deviceName=}, {rawLevel=}, {level=}, {status=}, {battery=}")
destTime = timestamp
destApplication = "de-hottis-level-monitoring"
destDevice = "eui-a84041a2c18341d6"
destAttributes = '{"ApplicationId":"de-hottis-level-monitoring", "DeviceType":"dragino-ldds75", "Hint": "Migrated"}'
destValues = '{"Battery":{"unit":"V","label":"Battery","value":' + str(battery) + ',"variable":"Voltage"}, "Distance":{"unit":mm","label":"Distance","variable":"Level","value":' + str(rawLevel) + '}, "CorrectedDistance":{"unit":"mm", "label":"CorrectedDistance", "variable":"Level","value":' + str(level) + '}}'
logger.info(f"{destTime=}, {destApplication=}, {destDevice=}, {destAttributes=}, {destValues=}")
finally:
if srcConn:
srcConn.close()

View File

@ -0,0 +1,2 @@
loguru==0.7.2
psycopg2==2.9.9