3,430
edits
Changes
From Pumping Station One
→A simple example
#!/usr/bin/env python
#!/usr/bin/env python
import zmq
import zmq
context = zmq.Context.instance()
context = zmq.Context.instance()
# Create a zmq socket that will SUBscribe to door nodes.
door_socket = context.socket(zmq.SUB)
door_socket = context.socket(zmq.SUB)
door_socket.connect("tcp://frontdoor.pumpingstationone.org:5556")
door_socket.connect("tcp://frontdoor.pumpingstationone.org:5556")
door_socket.setsockopt(zmq.SUBSCRIBE, b"door.state.unlock")
door_socket.setsockopt(zmq.SUBSCRIBE, b"door.state.unlock")
# create a zmq socket that will PUSH data to our IRC actuator node.
zirc_socket = context.socket(zmq.PUSH)
zirc_socket = context.socket(zmq.PUSH)
zirc_socket.connect('tcp://sally.ad.pumpingstationone.org:5558')
zirc_socket.connect('tcp://sally.ad.pumpingstationone.org:5558')
# Loop forever
while True:
while True:
# Read messages from the doors
topic, message = door_socket.recv_multipart()
# Send the message to the irc channel
zirc.send(message)
== Alpha Quality: thingsbus python + zeromq system ==
== Alpha Quality: thingsbus python + zeromq system ==
