| # This Python file uses the following encoding: utf-8 | |
| import storm | |
| from random import random | |
| class TesterBolt(storm.Bolt): | |
| def initialize(self, conf, context): | |
| storm.emit(['bolt initializing']) | |
| def process(self, tup): | |
| word = tup.values[0]; | |
| if (random() < 0.75): | |
| storm.emit([word + 'lalala'], anchors=[tup]) | |
| storm.ack(tup) | |
| else: | |
| storm.log(word + ' randomly skipped!') | |
| TesterBolt().run() |