Advertisement
Guest User

Untitled

a guest
Mar 20th, 2019
67
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.93 KB | None | 0 0
  1. import redis
  2. import time
  3.  
  4.  
  5. def read_messageq():
  6. r = redis.StrictRedis(host='192.168.1.48', port=6379, db=0)
  7.  
  8. p = r.pubsub()
  9. p.subscribe('startScripts')
  10. PAUSE = True
  11.  
  12. while PAUSE:
  13. print("Waiting For redisStarter...")
  14. # Checks for message
  15. message = p.get_message()
  16. if message:
  17. # Get data from message
  18. command = message['data']
  19.  
  20. # Checks for START message
  21. if command == b'START':
  22. PAUSE = False
  23.  
  24. time.sleep(1)
  25.  
  26. print("Permission to start...")
  27.  
  28.  
  29. if __name__ == '__main__':
  30. read_messageq()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement