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)