Things Bus: Difference between revisions
From Pumping Station One
| Line 92: | Line 92: | ||
Sensors send data like this: | Sensors send data like this: | ||
import zmq | |||
context = zmq.Context.instance() | |||
socket = context.socket(zmq.PUB) | socket = context.socket(zmq.PUB) | ||
socket.bind('tcp://*:5556') | socket.bind('tcp://*:5556') | ||
| Line 98: | Line 100: | ||
Neurons receive data like this: | Neurons receive data like this: | ||
import zmq | |||
context = zmq.Context.instance() | |||
sensor = context.socket(zmq.SUB) | sensor = context.socket(zmq.SUB) | ||
sensor.connect("tcp://sensor.tld:5556") | sensor.connect("tcp://sensor.tld:5556") | ||
| Line 105: | Line 109: | ||
Neurons send data like this: | Neurons send data like this: | ||
import zmq | |||
context = zmq.Context.instance() | |||
actuator = context.socket(zmq.PUSH) | actuator = context.socket(zmq.PUSH) | ||
actuator.connect('tcp://actuator.tld:5558') | actuator.connect('tcp://actuator.tld:5558') | ||
| Line 111: | Line 117: | ||
Actuators receive data like this: | Actuators receive data like this: | ||
import zmq | |||
context = zmq.Context.instance() | |||
socket = context.socket(zmq.PULL) | socket = context.socket(zmq.PULL) | ||
socket.bind('tcp://*:5558') | socket.bind('tcp://*:5558') | ||
