zmq-feed

zmq-feed

#
# Sample script to connect to CIRCL datafeeds
# Requirements:
#  - Recent version of ZMQ (and the associated Python library)
#  - Access to the feed (you need to provide a static IP address to
#  [email protected])
#

import sys
import zmq

port = "5556"

context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect ("tcp://crf.circl.lu:%s" % port)

topicfilter = "102"
socket.setsockopt(zmq.SUBSCRIBE, topicfilter)

while True:
    message = socket.recv()
    try:
        topic, paste, messagedata = message.split()
    except ValueError:
        print "Empty paste :" + message
        continue
    print paste, messagedata