【文件属性】：
文件名称：storm-python-example:使用 Python ShellBolts 通过 Storm 处理 Kafka 消息的示例
文件大小：61.83MB
文件格式：ZIP
更新时间：2021-07-04 23:55:18
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
要手动构建