Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
7d8d8b1c6a
|
|||
ffbda52c36
|
22
deployment/instances/udi/soil/config.json
Normal file
22
deployment/instances/udi/soil/config.json
Normal 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"
|
||||||
|
}
|
||||||
|
}
|
@ -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
1
migration/.gitignore
vendored
Normal file
@ -0,0 +1 @@
|
|||||||
|
.venv
|
29
migration/migrate-level.py
Normal file
29
migration/migrate-level.py
Normal 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()
|
||||||
|
|
2
migration/requirements.txt
Normal file
2
migration/requirements.txt
Normal file
@ -0,0 +1,2 @@
|
|||||||
|
loguru==0.7.2
|
||||||
|
psycopg2==2.9.9
|
Reference in New Issue
Block a user