PiCode/main_1.py at main · cuthbert86/PiCode · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

from helper import GetTemperature, connect_to_wifi, WifiServer, to_json
import usocket
import socket
from time import time, sleep
import network
import time
from simple import MQTTClient
import machine
#from picozero import pico_temp_sensor
from machine import Pin
import micropython
import ustruct as struct
import json
import random
import socket


Self_Name = 'PW_1'
ssidAP         = 'CuthbertWifi' #Enter the router name
passwordAP     = '999'  # Enter the router password
local_IP       = '192.168.1.1'
gateway        = '192.168.1.1'
subnet         = '255.255.255.0'
dns            = '8.8.8.8'
sta_if = network.WLAN(network.STA_IF)
ap_if = network.WLAN(network.AP_IF)
adcpin = 4
sensor = machine.ADC(adcpin)
sock = usocket
SSID = 'BB'
PASSWORD = ''
# SERVER_HOSTNAME = "e5d2174059b64286bd5f243dd055355a.s1.eu.hivemq.cloud:8884/mqtt"

USER = "Cuthbert"
#PASSWORD = 'Cbaines123!'
wlan = network.WLAN(network.STA_IF)
TOPIC = "test_data"
mqtt = MQTTClient
#sending = broker_address
BROKER = "192.168.1.17"
PORT = 1883  # Topic to publish to
CLIENT_ID = "Cuthbert"
Temperature = GetTemperature()
json_string = '{"Name": "device_id", "temp":"27"}'
data1 = json.loads(json_string)


ip = connect_to_wifi()
gateway1 = WifiServer('CuthbertWifi', '999')
client = MQTTClient(CLIENT_ID, BROKER)
start_time = time.time()
duration = 4000
try:
    print("Connecting to MQTT broker...")
    client.connect()
    print("Connected to MQTT broker.")

    while (time.time() - start_time) < duration:

        Temperature = GetTemperature()
        json_result = to_json(Temperature)
        print (json_result)
#        client.publish(TOPIC, json_result)
        time.sleep(10)  # Publish every 5 seconds
        Temperature = GetTemperature()
        json_result = to_json(Temperature)
        print(json_result)
 #       client.publish(TOPIC, json_result)
        time.sleep(10)
        Temperature = GetTemperature()
        json_result = to_json(Temperature)
        print (json_result)
  #      client.publish(TOPIC, json_result)
        Temperature = GetTemperature()
        json_result = to_json(Temperature)
        print (json_result)
  #      client.publish(TOPIC, json_result)

except Exception as e:
    print("An error occurred:", e)
    client.disconnect()
    wlan.disconnect()