initial commit

.idea/.gitignore

+# Default ignored files
+/shelf/
+/workspace.xml
+# Editor-based HTTP Client requests
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml

.idea/misc.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectRootManager" version="2" languageLevel="JDK_19" project-jdk-name="Python 3.11" project-jdk-type="Python SDK">
+    <output url="file://$PROJECT_DIR$/out" />
+  </component>
+</project>
\ No newline at end of file

.idea/modules.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/mqtt-app.iml" filepath="$PROJECT_DIR$/.idea/mqtt-app.iml" />
+    </modules>
+  </component>
+</project>
\ No newline at end of file

.idea/mqtt-app.iml

+<?xml version="1.0" encoding="UTF-8"?>
+<module type="JAVA_MODULE" version="4">
+  <component name="NewModuleRootManager" inherit-compiler-output="true">
+    <exclude-output />
+    <content url="file://$MODULE_DIR$" />
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>
\ No newline at end of file

.idea/vcs.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$" vcs="Git" />
+  </component>
+</project>
\ No newline at end of file

deployment.yml

+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: my-mqtt-app
+  labels:
+    app: my-mqtt-app
+spec:
+  replicas: 1
+  template:
+    metadata:
+      name: my-mqtt-app-pod
+      labels:
+        app: my-mqtt-app-pod
+    spec:
+      containers:
+        - name: my-receiver
+          image: scharfenberg/test-receiver-mqtt
+          imagePullPolicy: IfNotPresent
+      restartPolicy: Always
+  selector:
+    matchLabels:
+      app: my-mqtt-app-pod

receiver/.idea/.gitignore

+# Default ignored files
+/shelf/
+/workspace.xml
+# Editor-based HTTP Client requests
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml

receiver/.idea/misc.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectRootManager">
+    <output url="file://$PROJECT_DIR$/out" />
+  </component>
+</project>
\ No newline at end of file

receiver/.idea/modules.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/test-deployment-2.iml" filepath="$PROJECT_DIR$/test-deployment-2.iml" />
+    </modules>
+  </component>
+</project>
\ No newline at end of file

receiver/Dockerfile

+# syntax=docker/dockerfile:1
+
+FROM python:3.8-slim-buster
+WORKDIR /app
+
+COPY requirements.txt requirements.txt
+RUN pip3 install -r requirements.txt
+
+COPY . .
+
+CMD ["python3", "-u","./app.py"]
\ No newline at end of file

receiver/app.py

+import paho.mqtt.client as mqtt
+## receiving here
+TOPIC = "mqtt/kubernetes"
+BROKER_ADDRESS = "broker.hivemq.com"
+PORT = 1883
+import re
+def calulcate_result(numbers):
+    num = re.findall('[0-9]+',numbers)
+    result = int(num[0]) + int(num[1])
+    return result
+
+def on_message(client, userdata, message):
+    msg = str(message.payload.decode("utf-8"))
+    ##print("message received:", msg)
+    print("result of these numbers:", calulcate_result(msg))
+    ##print("message topic ", message.topic)
+
+def on_connect(client, userdata, flags, rc):
+    print("Connected to MQTT Broker: " + BROKER_ADDRESS)
+    client.subscribe(TOPIC)
+
+if __name__ == "__main__":
+    client = mqtt.Client()
+    client.on_connect = on_connect
+    client.on_message = on_message
+
+    client.connect(BROKER_ADDRESS,PORT, 60)
+
+    client.loop_forever()
\ No newline at end of file

receiver/requirements.txt

+regex
+paho-mqtt
\ No newline at end of file

receiver/test-deployment-2.iml

+<?xml version="1.0" encoding="UTF-8"?>
+<module type="PYTHON_MODULE" version="4">
+  <component name="NewModuleRootManager" inherit-compiler-output="true">
+    <exclude-output />
+    <content url="file://$MODULE_DIR$" />
+    <orderEntry type="jdk" jdkName="Python 3.11" jdkType="Python SDK" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>
\ No newline at end of file

requirements.txt

+regex
+paho-mqtt
\ No newline at end of file

sender/.idea/.gitignore

+# Default ignored files
+/shelf/
+/workspace.xml
+# Editor-based HTTP Client requests
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml

sender/.idea/misc.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectRootManager">
+    <output url="file://$PROJECT_DIR$/out" />
+  </component>
+</project>
\ No newline at end of file

sender/.idea/modules.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/test-deployment.iml" filepath="$PROJECT_DIR$/test-deployment.iml" />
+    </modules>
+  </component>
+</project>
\ No newline at end of file

sender/Dockerfile

+# syntax=docker/dockerfile:1
+
+FROM python:3.8-slim-buster
+WORKDIR /app
+
+COPY requirements.txt requirements.txt
+RUN pip3 install -r requirements.txt
+
+COPY . .
+
+CMD ["python3", "-u","./app.py"]
\ No newline at end of file

sender/app.py

+## sending here
+import time
+import paho.mqtt.client as mqtt
+import random as rand
+TOPIC = "mqtt/kubernetes"
+BROKER_ADDRESS = "broker.hivemq.com"
+PORT = 1883
+QOS = 1
+
+def generateNumbers():
+    first_number = rand.randrange(0,10000)
+    second_number = rand.randrange(0,10000)
+    print("SENDING: ", str([first_number, second_number]))
+    return str([first_number, second_number])
+
+
+if __name__ == "__main__":
+    client = mqtt.Client()
+
+    LAST_WILL = "Verbindung beendet!"
+    client.will_set(TOPIC, LAST_WILL, qos=QOS, retain=False)
+
+    client.connect(BROKER_ADDRESS,PORT,60)
+    client.loop_start()
+    print("Connected to MQTT Broker: "+ BROKER_ADDRESS)
+    for x in range(100):
+        DATA = generateNumbers()
+        client.publish(TOPIC, DATA, qos=QOS)
+        time.sleep(5)
+

sender/requirements.txt

+regex
+paho-mqtt
\ No newline at end of file