Pi-o-T: Prototyping IoT w/ Data Streams and Raspberry Pi (E. Grossman)

1.py

from pubnub.pnconfiguration import PNConfiguration
from pubnub.pubnub import PubNub
import RPi.GPIO as GPIO
import time
import sys


loopcount = 0

10.py

  distance = pulse_duration*17150

11.py

  distance = round(distance, 2)
  loopcount+=1

12.py

  print("Distance:",distance,"cm")
  print("Measured distance")
  message = {['distance', distance]}
  print pubnub.publish().channel(channel).message(message)
  time.sleep(1)

13.py

GPIO.cleanup()
sys.exit()

14.py

pnconfig = PNConfiguration()
 
pnconfig.subscribe_key = len(sys.argv) > 2 and sys.argv[2] or 'PASTE SUBKEY HERE'
pnconfig.publish_key = len(sys.argv) > 1 and sys.argv[1] or 'demo'
 
pubnub = PubNub(pnconfig)

15.py

subchannel = 'MotionDetector'

16.py

def callback(submessage, channel):

17.py

 if submessage["motion"] == 1:

18.py

GPIO.output(TRIG,False)
print("Waiting for sensor to settle.")

time.sleep(2)

19.py

print("Now subscribing.")

##Actually subscribe to the channel to receive the messages:##
pubnub.subscribe(subchannel, callback=callback, error=callback, connect=connect, reconnect=reconnect, disconnect=disconnect)

pubnub.subscribe().channels(subchannel).execute()

2.py

pnconfig = PNConfiguration()
 
pnconfig.subscribe_key = len(sys.argv) > 2 and sys.argv[2] or 'demo'
pnconfig.publish_key = len(sys.argv) > 1 and sys.argv[1] or 'demo'
 
pubnub = PubNub(pnconfig)
channel = 'Rangefinder'

3.py

GPIO.setmode(GPIO.BCM)

4.py

TRIG = 20
ECHO = 26

5.py

print("Distance Measurement in Progess")
GPIO.setup(TRIG,GPIO.OUT)

GPIO.setup(ECHO,GPIO.IN)`

6.py

GPIO.output(TRIG,False)
print("Waiting for sensor to settle.")

time.sleep(2)

7.py

while True:
   GPIO.output(TRIG, True)
   time.sleep(0.00001)
   GPIO.output(TRIG, False)

8.py

   print("before pulse start")  # debug statement
    pulse_start = time.time()  
    while GPIO.input(ECHO)==0:
        pulse_start = time.time()

9.py

    while GPIO.input(ECHO)==1:
        pulse_end = time.time()
    print("after pulse")  # debug statement
    pulse_duration = pulse_end - pulse_start