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

1.py

from 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, message)
  time.sleep(1)

13.py

GPIO.cleanup()
sys.exit()

14.py

publish_key = len(sys.argv) > 1 and sys.argv[1] or 'demo'
subscribe_key = len(sys.argv) > 2 and sys.argv[2] or 'PASTE SUBKEY HERE'
secret_key = len(sys.argv) > 3 and sys.argv[3] or 'demo'
cipher_key = len(sys.argv) > 4 and sys.argv[4] or ''
ssl_on = len(sys.argv) > 5 and bool(sys.argv[5]) or False

pubnub = Pubnub(publish_key=publish_key, subscribe_key=subscribe_key,secret_key=secret_key, cipher_key=cipher_key, ssl_on=ssl_on)

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)

2.py

Publish_key = len(sys.argv) > 1 and sys.argv[1] or 'demo'
subscribe_key = len(sys.argv) > 2 and sys.argv[2] or 'demo'
secret_key = len(sys.argv) > 3 and sys.argv[3] or 'demo'
cipher_key = len(sys.argv) > 4 and sys.argv[4] or ''
ssl_on = len(sys.argv) > 5 and bool(sys.argv[5]) or False

pubnub = Pubnub(publish_key=publish_key, subscribe_key=subscribe_key,secret_key=secret_key, cipher_key=cipher_key, ssl_on=ssl_on)
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