NebulaStream 执行引擎 Docker 镜像文档

1. 镜像概述和主要用途

本Docker镜像包含为Ubuntu系统编译的NebulaStream二进制文件，旨在提供便捷的NebulaStream流处理引擎部署方案。启动容器后，将自动运行NebulaStream Coordinator（协调器）和Worker（工作节点）服务，无需手动配置即可快速构建流处理环境。

2. 核心功能和特性

• 内置核心服务：容器启动后自动部署NebulaStream Coordinator和Worker服务，构成完整的流处理执行引擎。
• 默认逻辑流：预配置名为“exdra”的逻辑流，无需额外创建即可直接提交流处理查询。
• 多接口支持：支持通过Java客户端或REST接口与引擎交互，提交流处理任务。
• 便捷部署：基于Docker容器化设计，简化环境依赖配置，确保跨Ubuntu环境的一致性运行。

3. 使用场景和适用范围

使用场景

• 开发环境：快速搭建NebulaStream引擎，验证流处理逻辑正确性。
• 测试环境：部署轻量级实例，进行功能测试和性能评估。
• 轻量级生产环境：运行实时流处理任务，处理低至中等规模的数据流。

适用范围

• 需要通过Java客户端与NebulaStream交互的开发者。
• 需要通过REST接口提交流处理查询的应用场景。
• 基于Ubuntu系统的Docker环境。

4. 使用方法和配置说明

4.1 启动容器

通过以下命令启动NebulaStream执行引擎容器，映射服务端口以支持外部访问：

docker run -d -p 8081:8081 nebulastream/nes-executable-image:latest

参数说明：

• -d：后台运行容器。
• -p 8081:8081：端口映射，将容器内8081端口（NebulaStream服务端口）映射至主机8081端口，确保外部客户端可访问。
• nebulastream/nes-executable-image:latest：镜像名称及标签（默认使用最新版本）。

4.2 查看容器日志

容器启动后，可通过以下命令查看服务运行状态日志，确认Coordinator和Worker是否正常启动：

docker logs <container_name>

提示：通过docker ps命令可获取容器名称（<container_name>）。

4.3 提交查询

容器运行后，可通过Java客户端或REST接口向默认逻辑流“exdra”提交查询。

4.3.1 通过Java客户端提交查询

Java客户端可通过Maven中央仓库获取，在项目pom.xml中添加依赖：

<dependency>
    <groupId>stream.nebula</groupId>
    <artifactId>nebulastream-java-client</artifactId>
    <!-- 请使用最新版本，具体版本可查看Maven仓库 -->
    <version>[最新版本号]</version>
</dependency>

Maven仓库地址：[***]

4.3.2 通过REST接口提交查询

使用REST客户端（如curl、Postman等）访问主机8081端口，向NebulaStream服务提交查询请求。具体接口规范可参考NebulaStream官方文档。

5. 配置参数说明