import paho.mqtt.client as mqttClient
import time, random, RPi.GPIO as GPIO
GPIO.setwarnings(False)
GPIO.setmode(GPIO.BOARD)
def on_connect(client, userdata, flags, rc):
if rc == 0:
print("Connected to broker")
global Connected
Connected = True
else:
print("Connection failed")
Connected = False
def setupgpio():
GPIO.setup(LED_RED, GPIO.OUT)
GPIO.setup(LED_yellow, GPIO.OUT)
GPIO.setup(LED_GREEN, GPIO.OUT)
def alloff (val):
GPIO.output (LED_RED, LEDOFF)
GPIO.output (LED_yellow, LEDOFF)
GPIO.output (LED_GREEN, LEDOFF)
time.sleep(val)
def allon (val):
GPIO.output (LED_RED, LEDON)
GPIO.output (LED_yellow, LEDON)
GPIO.output (LED_GREEN, LEDON)
time.sleep(val)
def red (val):
GPIO.output (LED_RED, LEDON)
GPIO.output (LED_yellow, LEDOFF)
GPIO.output (LED_GREEN, LEDOFF)
time.sleep(val)
def redamber (val):
GPIO.output (LED_RED, LEDON)
GPIO.output (LED_yellow, LEDON)
GPIO.output (LED_GREEN, LEDOFF)
time.sleep(val)
def yellow (val):
GPIO.output (LED_RED, LEDOFF)
GPIO.output (LED_yellow, LEDOFF)
GPIO.output (LED_GREEN, LEDON)
time.sleep(val)
def green (val):
GPIO.output (LED_RED, LEDOFF)
GPIO.output (LED_yellow, LEDOFF)
GPIO.output (LED_GREEN, LEDON)
time.sleep(val)
broker_address= "broker name"
port = 1883
user = "user name"
password = "pwd"
LED_RED = 7
LED_yellow = 11
LED_GREEN = 13
LEDOFF = 0
LEDON = 1
client = mqttClient.Client()
client.username_pw_set(user, password=password)
client.on_connect= on_connect
client.connect(broker_address, port=port)
client.loop_start()
while Connected != True:
time.sleep(0)
def basicSequence (val):
count=0
while count <val:
red (3)
print("sig: " +str(count))
client.publish("/topic/signals", count)
time.sleep(0)
def basicSequence (val):
collect= 0
while collect <val:
redamber (1)
print("sign: " +str(collect))
client.publish("/topic/signals", collect)
time.sleep(0)
def basicSequence (val):
conn= 0
while conn <val:
green (5)
print("signa: " +str(conn))
client.publish("/topic/signals", conn)
time.sleep(0)
def basicSequence (val):
coy= 0
while coy <val:
yellow (3)
print("signal: " +str(coy))
client.publish("/topic/signals", coy)
time.sleep(0)
try:
while True:
setupgpio()
alloff(0)
basicSequence (5)
except KeyboardInterrupt:
GPIO.cleanup()
exit()
please help me in loop i am trying to run this program in raspberry pi by sending msg
|
please help me in loop i am trying to run this program in raspberry pi by sending msg
|
|
Jan-27-2020, 02:20 PM
what problem do you have? post the full traceback (if any) - in error tags
If you can't explain it to a six year old, you don't understand it yourself, Albert Einstein
How to Ask Questions The Smart Way: link and another link Create MCV example Debug small programs
Jan-27-2020, 02:32 PM
actually i am not a programmer, thats why i am stuck in this thing. i make this program for traffic signals where it runs periodically red,yellow and green. now i want this to run with mqtt on real time while the signal is red it send messages to subscribers and when its yellow or green it send messages when it flashes green or yellow. so i am struggling in my loop i could't manage to run with mqtt.
|
|
|
Users browsing this thread: 1 Guest(s)
