Skip to content
Snippets Groups Projects
Commit 2c817e6f authored by Bert Palm's avatar Bert Palm :bug:
Browse files

fix getting parser in mqtt ingest and adding missing api types

parent 77bcd836
No related branches found
No related tags found
1 merge request!294Configdb and mqtt parsing fixes
insert into config_db.ext_api_type (name)
values ('tsystems'::varchar(200)),
('uba'::varchar(200));
...@@ -14,7 +14,7 @@ from timeio.errors import UserInputError ...@@ -14,7 +14,7 @@ from timeio.errors import UserInputError
from timeio.journaling import Journal from timeio.journaling import Journal
from timeio.databases import DBapi from timeio.databases import DBapi
from timeio.feta import Thing from timeio.feta import Thing
from timeio.parser import get_parser from timeio.parser import get_parser, MqttDataParser
logger = logging.getLogger("mqtt-ingest") logger = logging.getLogger("mqtt-ingest")
journal = Journal("Parser") journal = Journal("Parser")
...@@ -41,12 +41,11 @@ class ParseMqttDataHandler(AbstractHandler): ...@@ -41,12 +41,11 @@ class ParseMqttDataHandler(AbstractHandler):
logger.info(f"get thing") logger.info(f"get thing")
mqtt_user = message.topic.split("/")[1] mqtt_user = message.topic.split("/")[1]
thing = Thing.from_mqtt_user_name(mqtt_user) thing = Thing.from_mqtt_user_name(mqtt_user, dsn=self.configdb_dsn)
thing_uuid = thing.uuid thing_uuid = thing.uuid
logger.info(f"get parser") logger.info(f"get parser")
p = thing.s3_store.file_parser parser: MqttDataParser = get_parser(thing.mqtt.mqtt_device_type.name, None)
parser = get_parser(p.file_parser_type, p.params)
logger.info(f"parsing rawdata") logger.info(f"parsing rawdata")
try: try:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment