The synaps.cep.unpack_bolt Module

class UnpackMessageBolt

Bases: synaps.cep.storm.BasicBolt

BOLT_NAME = 'UnpackMessageBolt'

get_alarm_metric_key(alarmkey)

get_metric_key(message)

initialize(stormconf, context)

process(tup)