Untitled

import paho.mqtt.client as mqtt
import random
import time
from datetime import datetime

# MQTT settings
broker_address = "192.168.1.102"
topic = "CPU4"
client_id = "RaspiLoRa"1
port = 1883  # Default MQTT port

# Callback function when the client connects to the broker
def on_connect(client, userdata, flags, rc):
    if rc == 0:
        print("Connected successfully to broker")
    else:
        print(f"Connection failed with code {rc}")

# Callback function when a message is published
def on_publish(client, userdata, mid):
    print("Message published")

# Function to generate the payload
def generate_payload():
    # Random integer between 1 and 4
    adc_number = random.randint(1, 4)
    
    # 16 random float values with two decimal precision
    float_values = [f"{random.uniform(0, 100):.2f}" for _ in range(16)]
    
    # 10 random binary values (0 or 1)
    binary_values = [str(random.randint(0, 1)) for _ in range(10)]
    
    # Current date in YYYY:MM:DD format
    current_date = datetime.now().strftime("%Y:%m:%d")
    
    # Current timestamp in HH:MM:SS format
    current_time = datetime.now().strftime("%H:%M:%S")
    
    # Constructing the message without '#' between float and binary values
    message = f"CPU4#ADC{adc_number}#{','.join(float_values)},{','.join(binary_values)}#{current_date}#{current_time}"
    
    return message

# Create a new MQTT client instance
client = mqtt.Client(client_id)

# Assign the callback functions
client.on_connect = on_connect
client.on_publish = on_publish

# Connect to the MQTT broker
client.connect(broker_address, port)

# Start the loop
client.loop_start()

try:
    # Send messages periodically
    while True:
        message = generate_payload()
        result = client.publish(topic, message)
        
        # Wait for the message to be sent and processed
        result.wait_for_publish()
        
        print(f"Message sent: {message}")
        
        # Wait for 5 seconds before sending the next message
        time.sleep(5)

except KeyboardInterrupt:
    print("Terminating program...")

# Stop the loop and disconnect from the broker
client.loop_stop()
client.disconnect()