暴雨流喷流处理中nextTuple方法的几个问题

Question

我正在Storm之上开发一些数据分析算法，对Storm的内部设计有一些疑问。我想模拟一个传感器数据在Storm中的产生和处理，因此我使用Spout通过在Spout的nextTuple方法中设置Hibernate方法，将传感器数据以恒定的时间间隔推送到后续的螺栓中。但从实验结果来看，喷口并没有按规定的速率推送数据。在实验中，系统中没有瓶颈螺栓。

Answer 1

我有一个类似的用例，我实现它的方法是使用tick_tuple

Config tickConfig = new Config();                                       
tickConfig.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 15);
...
...
builder.setBolt("storage_bolt", new S3Bolt(), 4).fieldsGrouping("shuffle_bolt", new Fields("hash")).addConfigurations(tickConfig);

然后在我的storage_bolt中（注意它是用python编写的，但您会有一个想法），我检查消息是否为tick_tuple，然后执行我的代码：

def process(self, tup): 
    if tup.stream == '__tick':                                              
        # Your logic that need to be executed every 15 seconds,
        # or what ever you specified in tickConfig.
        # NOTE: the maximum time is 600 s.                                            
        storm.ack(tup)                                                      
        return