apache-storm - Spout 或 Bolt 能否访问在拓扑中已知的 ID？

Question

是否有可供 Storm Spout 或 Bolt 访问其 ID 的 API？我指的ID是String传递给 setSpout或 setBolt类中的方法 backtype.storm.topology.TopologyBuilder .

出于日志记录的目的访问此字符串会很有用。

Answer 1

您可以在 bolt 的准备方法中对传递的拓扑上下文使用 getThisComponentId() :

@Override
public void prepare(Map config, TopologyContext context, OutputCollector collector) {
    this.collector = collector;

    String componentId = context.getThisComponentId();
}

并在喷口的开放方法中。

还有一个更通用的方法 getComponentId(int taskId) 返回任何给定任务的组件 ID。