Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import redis
- import time
- def read_messageq():
- r = redis.StrictRedis(host='192.168.1.48', port=6379, db=0)
- p = r.pubsub()
- p.subscribe('startScripts')
- PAUSE = True
- while PAUSE:
- print("Waiting For redisStarter...")
- # Checks for message
- message = p.get_message()
- if message:
- # Get data from message
- command = message['data']
- # Checks for START message
- if command == b'START':
- PAUSE = False
- time.sleep(1)
- print("Permission to start...")
- if __name__ == '__main__':
- read_messageq()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement