Module Expr Str Import alias Import alias Import alias Assign NameStore Str Assign NameStore Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr keyword Str Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr keyword Str FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr keyword Str keyword Str keyword Call NameLoad Dict SubscriptLoad NameLoad Index Num NameLoad decorator_list FunctionDef arguments args defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list If CompareEq NameLoad Str body Expr Call NameLoad Expr Call AttributeLoad NameLoad attr
N/A N/A 
Use the Python DTrace consumer and push the data through AMQP as the DTrace
probes fire.

Created on Mar 31, 2012

@author: tmetsch
 N/A dtrace N/A pika N/A time N/A SCRIPT syscall:::entry { @num[execname] = count(); } N/A connection N/A N/A pika BlockingConnection N/A N/A pika ConnectionParameters host localhost N/A channel N/A N/A connection channel N/A N/A N/A channel queue_declare queue dtrace walk N/A N/A iden key value N/A N/A N/A 
    Walker which sends on the data to RabbitMQ as the DTrace probes fire.
     N/A N/A N/A channel basic_publish exchange routing_key dtrace body N/A str N/A N/A key N/A 0 value N/A run_dtrace N/A N/A N/A N/A N/A 
    Runs a DTrace script for 5 seconds...
     N/A thr N/A N/A dtrace DTraceConsumerThread SCRIPT walk_func walk N/A N/A N/A thr start N/A N/A N/A time sleep 5 N/A N/A N/A thr stop N/A N/A N/A thr join N/A N/A N/A __name__ __main__ N/A N/A N/A run_dtrace N/A N/A N/A connection close