Mongo Storm库 Mongo Storm库使您可以在Storm拓扑中利用MongoDB。 它包括两个主要组成部分。 MongoDB操作日志和任何受MongoDB限制的集合的出水口，如果您希望减少从出水口传输的数据量，则可以将文档过滤到特定的touples。 或者，您可以发出整个文档。 它是线程化且非阻塞的。 插入/更新螺栓，可让您将元组映射到MongoDB实例中的新文档或现有文档。 封顶式出水口示例 封顶的集合签名如下所示，还有其他变体，因为一些选项是可选的，例如查询和映射器。 M