快速参考

• 维护者：
  Apache Storm

• 获取帮助：
  Apache Storm™ 社区

支持的标签及对应的Dockerfile链接

• 2.8.2-jre17, 2.8-jre17, 2.8.2, 2.8, latest

• 2.8.2-jre21, 2.8-jre21

快速参考（续）

• 问题提交地址：
  [***]

• 支持的架构：(更多信息)
  amd64, arm64v8

• 发布的镜像 artifact 详情：
  repo-info 仓库的 repos/storm/ 目录 (历史记录)
  （镜像元数据、传输大小等）

• 镜像更新：
  official-images 仓库的 library/storm 标签
  official-images 仓库的 library/storm 文件 (历史记录)

• 本描述的来源：
  docs 仓库的 storm/ 目录 (历史记录)

什么是 Apache Storm？

Apache Storm 是一个免费开源的分布式实时计算系统。Apache Storm 让可靠地处理无界数据流变得简单，它在实时处理领域的作用类似于 Hadoop 在批处理领域的作用。Apache Storm 简单易用，可与任何编程语言配合使用，且使用体验出色！

Apache Storm 有许多用例：实时分析、在线机器学***、持续计算、分布式 RPC、ETL 等。Apache Storm 速度很快：一项基准测试显示，每个节点每秒可处理超过一百万条元组。它具有可扩展性、容错性，能确保数据被处理，且易于设置和操作。

Apache Storm 可与您已在使用的队列和数据库技术集成。Apache Storm 拓扑消费数据流，并以任意复杂的方式处理这些流，根据需要在计算的每个阶段之间重新分区流。

***.org/wiki/Storm_(event_processor))

!logo

如何使用本镜像

在本地模式下运行拓扑

假设当前目录中有 topology.jar（拓扑 JAR 包）。

console
$ docker run -it -v $(pwd)/topology.jar:/topology.jar storm storm jar /topology.jar org.apache.storm.starter.ExclamationTopology

设置最小化 Storm 集群

1. Apache Zookeeper 是运行 Storm 集群的必备组件。首先启动它。由于 Zookeeper 采用“快速失败”机制，最好将其设置为始终重启。

   console
   $ docker run -d --restart always --name some-zookeeper zookeeper
   

2. Nimbus 守护进程必须与 Zookeeper 连接。它也是一个“快速失败”系统。

   console
   $ docker run -d --restart always --name some-nimbus --link some-zookeeper:zookeeper storm storm nimbus
   

3. 最后启动一个 Supervisor 节点。它将与 Nimbus 和 Zookeeper 通信。

   console
   $ docker run -d --restart always --name supervisor --link some-zookeeper:zookeeper --link some-nimbus:nimbus storm storm supervisor
   

4. 现在可以向集群提交拓扑了。

   console
   $ docker run --link some-nimbus:nimbus -it --rm -v $(pwd)/topology.jar:/topology.jar storm storm jar /topology.jar org.apache.storm.starter.WordCountTopology topology
   

5. （可选）您可以启动 Storm UI。

   console
   $ docker run -d -p 8080:8080 --restart always --name ui --link some-nimbus:nimbus storm storm ui
   

... 通过 docker compose

storm 的 compose.yaml 示例：

yaml
services:
  zookeeper:
    image: zookeeper
    container_name: zookeeper
    restart: always

  nimbus:
    image: storm
    container_name: nimbus
    command: storm nimbus
    depends_on:
      - zookeeper
    links:
      - zookeeper
    restart: always
    ports:
      - 6627:6627

  supervisor:
    image: storm
    container_name: supervisor
    command: storm supervisor
    depends_on:
      - nimbus
      - zookeeper
    links:
      - nimbus
      - zookeeper
    restart: always

运行 docker compose up 并等待其完全初始化。Nimbus 将在 http://localhost:6627 或 [***]（视情况而定）可用。

配置

本镜像使用 Apache Storm 的默认配置。有两种主要方式可以修改配置：

1. 使用命令行参数。

   console
   $ docker run -d --restart always --name nimbus storm storm nimbus -c storm.zookeeper.servers='["zookeeper"]'
   

2. 假设当前目录中有 storm.yaml，您可以将其挂载为卷。

   console
   $ docker run -it -v $(pwd)/storm.yaml:/conf/storm.yaml storm storm nimbus
   

日志

本镜像使用 默认日志配置。默认情况下，所有日志都存储在 /logs 目录中。

数据持久化

默认不持久化任何数据。为方便起见，镜像中包含 /data 和 /logs 目录，由 storm 用户拥有。您可以使用卷来持久化数据和日志。

console
$ docker run -it -v /logs -v /data storm storm nimbus

请注意，使用除预定义路径之外的其他路径可能会导致权限拒绝错误。这是因为出于安全原因，Storm 运行在非 root 用户 storm 下。

许可证

Apache Storm、Storm、Apache、Apache 羽毛徽标和 Apache Storm 项目徽标是 Apache 软件基金会的商标。

根据 Apache 许可证 2.0 版 授权。

参见 许可证信息。

与所有 Docker 镜像一样，这些镜像可能还包含其他受其他许可证约束的软件（如基础发行版中的 Bash 等，以及主要软件的任何直接或间接依赖项）。

一些能够自动检测到的额外许可证信息可能位于 repo-info 仓库的 storm/ 目录 中。

对于任何预构建镜像的使用，镜像用户有责任确保对本镜像的任何使用都符合其中包含的所有软件的相关许可证。