Add mqtt_authentication_credentials to .json files

Add worker-mqtt-user-ingest for MQTT-User creation

crns-demo/crns-01.json

@@ -13,6 +13,10 @@
   "raw_data_storage": {
     "bucket_name": "crns01-b3b16570-5e55-11ec-902c-54e1ad7c5c19",
     "username":  "crns01-b3b16570-5e55-11ec-902c-54e1ad7c5c19",
+//    "password": "CHANGE ME!"
+  },
+  "mqtt_authentication_credentials": {
+    "username": "ufzcrns_520a6d265e5511ec991454e1ad7c5c19",
 //    "password": "CHANGE ME!"
   },
   "properties": {
@@ -30,4 +34,4 @@
       }
     ]
   }
-}
\ No newline at end of file
+}

crns-demo/crns-02.json

@@ -13,6 +13,10 @@
   "raw_data_storage": {
     "bucket_name": "crns02-147522c0-5e56-11ec-8030-54e1ad7c5c19",
     "username":  "crns02-147522c0-5e56-11ec-8030-54e1ad7c5c19",
+//    "password": "CHANGE ME!"
+  },
+  "mqtt_authentication_credentials": {
+    "username": "ufzcrns_520a6d265e5511ec991454e1ad7c5c19",
 //    "password": "CHANGE ME!"
   },
   "properties": {
@@ -30,4 +34,4 @@
       }
     ]
   }
-}
\ No newline at end of file
+}

crns-demo/crns-03.json

@@ -13,6 +13,10 @@
   "raw_data_storage": {
     "bucket_name": "crns03-7ff34ed2-5e56-11ec-9b0a-54e1ad7c5c19",
     "username":  "crns03-7ff34ed2-5e56-11ec-9b0a-54e1ad7c5c19",
+//    "password": "CHANGE ME!"
+  },
+  "mqtt_authentication_credentials": {
+    "username": "ufzcrns_520a6d265e5511ec991454e1ad7c5c19",
 //    "password": "CHANGE ME!"
   },
   "properties": {
@@ -30,4 +34,4 @@
       }
     ]
   }
-}
\ No newline at end of file
+}

crns-demo/crns-04.json

@@ -13,6 +13,10 @@
   "raw_data_storage": {
     "bucket_name": "crns04-a1bfc93c-5e56-11ec-9837-54e1ad7c5c19",
     "username":  "crns04-a1bfc93c-5e56-11ec-9837-54e1ad7c5c19",
+//    "password": "CHANGE ME!"
+  },
+  "mqtt_authentication_credentials": {
+    "username": "ufzcrns_520a6d265e5511ec991454e1ad7c5c19",
 //    "password": "CHANGE ME!"
   },
   "properties": {
@@ -30,4 +34,4 @@
       }
     ]
   }
-}
\ No newline at end of file
+}

crns-demo/crns-05.json

@@ -13,6 +13,10 @@
   "raw_data_storage": {
     "bucket_name": "crns05-bca189a2-5e56-11ec-957a-54e1ad7c5c19",
     "username":  "crns05-bca189a2-5e56-11ec-957a-54e1ad7c5c19",
+//    "password": "CHANGE ME!"
+  },
+  "mqtt_authentication_credentials": {
+    "username": "ufzcrns_520a6d265e5511ec991454e1ad7c5c19",
 //    "password": "CHANGE ME!"
   },
   "properties": {
@@ -30,4 +34,4 @@
       }
     ]
   }
-}
\ No newline at end of file
+}

docker-compose.yml

@@ -185,6 +185,28 @@ services:
         ?Please define an postgres password!}@${CREATEDB_POSTGRES_HOST:\
         -database}/${CREATEDB_POSTGRES_DATABASE:-postgres}"
 
+  worker-mqtt-user-ingest:
+    image: "git.ufz.de:4567/rdm-software/\
+        timeseries-management/tsm-dispatcher/dispatcher:latest"
+    restart: on-failure
+    depends_on:
+      - mqtt-broker
+      - database
+    command:
+      - --topic
+      - thing_creation
+      - --mqtt-broker
+      - mqtt-broker:1883
+      - --mqtt-user
+      - ${MQTT_INGEST_USER:?Please define a mqtt user!}
+      - --mqtt-password
+      - ${MQTT_INGEST_PASSWORD:?Please define a mqtt password!}
+      - run-create-mqtt-user-action-service
+      - "postgresql://${CREATEDB_POSTGRES_USER:\
+        ?Please define an postgres user!}:${CREATEDB_POSTGRES_PASSWORD:\
+        ?Please define an postgres password!}@${CREATEDB_POSTGRES_HOST:\
+        -database}/${CREATEDB_POSTGRES_DATABASE:-postgres}"
+
 
   basic-demo-scheduler:
     image: "git.ufz.de:4567/rdm-software/timeseries-management/\

mqtt-thing-event-msg.json

@@ -15,6 +15,10 @@
     "username":  "crns05-bca189a2-5e56-11ec-957a-54e1ad7c5c19",
     "password": "R3eKIIxZWtYlC9s9ZIEeWc4peH4OebiHWE252xQF"
   },
+  "mqtt_authentication_credentials": {
+    "username": "seefo_envimo_cr6_test_001",
+    "password": "ehah7ohDoophiliegoC9vaog2ievahqu9poohein"
+  },
   "description": "manually generated test message (msg1)",
   "properties": {
     "default_parser": "campbell_cr6",

mqtt-thing-event-msg2.json

@@ -15,6 +15,10 @@
     "username":  "crns04-bca189a2-5e56-11ec-957a-54e1ad7c5c19",
     "password": "R3eKIIxZWtYlC9s9ZIEeWc4peH4OebiHWE252xQF"
   },
+  "mqtt_authentication_credentials": {
+    "username": "seefo_envimo_cr6_test_002",
+    "password": "ehah7ohDoophiliegoC9vaog2ievahqu9poohein"
+  },
   "description": "manually generated test message (msg2)",
   "properties": {
     "default_parser": "campbell_cr6",

thing-event-msg.json

@@ -15,6 +15,10 @@
     "username":  "thedoors-057d8bba-40b3-11ec-a337-125e5a40a849",
     "password": "R3eKIIxZWtYlC9s9ZIEeWc4peH4OebiHWE252xQF"
   },
+  "mqtt_authentication_credentials": {
+    "username": "thedoors",
+    "password": "openit"
+  },
   "description": "some foo with bar",
   "properties": {
     "default_parser": "CsvParser",