stream_probe.py

from ripe.atlas.cousteau import AtlasStream
import json

def on_result_response(*args):
	print json.dumps(args[0], indent=2)

atlas_stream = AtlasStream()
atlas_stream.connect()

channel = "atlas_result"
atlas_stream.bind_channel(channel, on_result_response)

stream_parameters = {"prb": 14277}
atlas_stream.start_stream(stream_type="result", **stream_parameters)

atlas_stream.timeout()
atlas_stream.disconnect()