文件名称：storm-python-example:使用 Python ShellBolts 通过 Storm 处理 Kafka 消息的示例
文件大小：61.83MB
文件格式：ZIP
更新时间：2024-07-24 17:41:58
Java
一个允许动态风暴拓扑定义的项目。 请参阅示例topology.properties 文件。 使用提供的 target/storm-python-example.jar，您可以添加新的 Python bolts，而无需重新构建 jar。 为了让 Storm 能够将 Python 脚本作为 bolt 执行，脚本需要在 /resources 目录下的 jar 中可用。 mkdir resources mv myBoltScript.py resources/ jar uf storm-python-example-1.0-SNAPSHOT.jar resources/myBoltScript.py 唯一可用的喷口类型是 kafka 喷口。 当前可用的螺栓类型有：PyBolts（Python bolt）、HBaseBolts、PhoenixBolts 和 HDFSBolts 要手动构建