def walk(iden, key, value):
    channel.basic_publish(exchange='', routing_key='dtrace',
                          body=str({key[0]: value}))
Walker which sends on the data to RabbitMQ as the DTrace probes fire.
dataset/ETHPy150Open tmetsch/python-dtrace/examples/amqp/send.py/walk