从安装到部署：Nussknacker完整入门教程（附Docker快速启动指南）

【免费下载链接】nussknackerLow-code tool for automating actions on real time data | Stream processing for the users.项目地址: https://gitcode.com/gh_mirrors/nu/nussknacker

Nussknacker是一款强大的低代码工具，专为实时数据处理和流处理自动化设计，让用户无需深入编程即可构建复杂的数据处理流程。本教程将带您从环境准备到成功部署第一个Nussknacker应用，通过Docker快速启动方案，即使是新手也能轻松上手。

📋 准备工作：安装前的环境检查

在开始Nussknacker之旅前，请确保您的系统满足以下要求：

• Docker Engine (20.10.0+) 和 Docker Compose (v2+)
• 至少4GB可用内存（推荐8GB以上）
• Git工具（用于克隆项目代码）

您可以通过以下命令检查Docker是否已正确安装：

docker --version docker compose version

⚡ Docker快速启动：3步搭建完整环境

Nussknacker提供了预配置的Docker Compose方案，包含所有必要组件（设计器、Flink、Kafka等），让您无需手动配置复杂依赖。

1️⃣ 克隆项目代码库

git clone https://gitcode.com/gh_mirrors/nu/nussknacker cd nussknacker/examples/installation

2️⃣ 启动服务集群

项目提供了一键启动脚本，会自动拉取所需镜像并启动所有服务：

./start.sh

首次启动可能需要5-10分钟下载镜像，请耐心等待。启动成功后，所有服务将在后台运行。

3️⃣ 验证服务状态

通过Docker Compose命令检查所有服务是否正常运行：

docker compose ps

当看到所有服务状态为Up且健康检查通过时，说明环境已准备就绪。

🌐 访问Nussknacker设计器

服务启动后，打开浏览器访问以下地址即可进入Nussknacker设计界面：

http://localhost:8080

首次登录时，您将看到Nussknacker的主界面，左侧是组件面板，中央是流程设计画布，右侧是场景详情面板。

Nussknacker设计器主界面Nussknacker设计器主界面，展示了空场景状态下的组件面板和场景操作区

🧩 认识Nussknacker核心组件

Nussknacker提供了丰富的预制组件，涵盖数据处理的各个环节。点击顶部导航栏的Components按钮，可查看所有可用组件：

Nussknacker组件列表Nussknacker组件列表，展示了按类别分组的流处理组件

主要组件类别包括：

• Sources：数据输入源（如Kafka、CSV文件、事件生成器）
• Processors：数据处理节点（如过滤、转换、聚合）
• Sinks：数据输出目标（如数据库、消息队列）
• Enrichers：数据增强组件（如数据库查询、API调用）

🚀 创建并部署第一个场景

让我们通过创建一个简单的事件处理场景，体验Nussknacker的核心功能：

步骤1：创建新场景

1. 点击界面右上角的**+ New Scenario**按钮
2. 输入场景名称（如first-scenario）并选择Streaming处理模式
3. 点击Create按钮进入设计界面

步骤2：添加事件生成器组件

从左侧组件面板的Sources分类中，拖拽Event Generator到画布中央：

• 双击组件打开配置窗口
• 设置事件生成频率（如每1分钟生成一条事件）
• 在JSON模板中定义事件结构：

{ "sampleField": "#{UTIL.uuid}", "datetime": "#{DATE.now}", "type": "example", "value": 100 }

事件生成器配置窗口事件生成器配置窗口，展示了时间调度和JSON模板设置

步骤3：添加过滤组件

1. 从Processors分类中拖拽Filter组件到画布
2. 连接Event Generator的输出到Filter的输入
3. 配置过滤条件：value > 50（只保留value字段大于50的事件）

步骤4：部署场景

1. 点击界面右侧的Save按钮保存场景
2. 点击Deploy按钮部署场景到Flink集群
3. 在部署确认窗口中点击Deploy完成部署

步骤5：查看运行状态

部署后，您可以：

• 在Metrics标签页查看实时处理指标
• 在Flink控制台（http://localhost:8081）查看作业状态
• 在Grafana仪表板（http://localhost:8080/grafana）查看详细监控数据

⚙️ 高级配置与自定义

Nussknacker支持通过配置文件进行深度自定义，主要配置文件位于：

• 应用配置：examples/installation/designer/application-customizations.conf
• Docker Compose配置：examples/installation/docker-compose.yml

常见自定义场景包括：

• 调整资源限制（内存、CPU）
• 配置外部Kafka集群连接
• 添加自定义组件
• 集成身份验证系统

📚 学习资源与文档

官方提供了丰富的学习资源帮助您深入掌握Nussknacker：

• 详细文档：docs/OSS_docs
• 组件参考：docs/components
• 开发指南：docs/developers_guide

🔧 常见问题解决

Q: 服务启动后无法访问设计器？

A: 检查Docker服务是否正常运行，通过docker compose logs designer查看应用日志，确认是否有端口冲突。

Q: 部署场景时提示Flink连接失败？

A: 确认Flink服务是否正常启动，可通过docker compose logs flink-jobmanager检查Flink日志。

Q: 如何更新Nussknacker版本？

A: 修改examples/installation/.env文件中的NUSSKNACKER_VERSION变量，然后重新运行./start.sh。

🎯 总结

通过本教程，您已成功搭建Nussknacker环境并创建了第一个流处理场景。Nussknacker的低代码特性让实时数据处理变得简单直观，无论是数据分析还是业务流程自动化，都能大幅提升开发效率。

现在，您可以开始探索更多高级功能，如：

• 构建复杂事件处理流程
• 集成外部数据源和API
• 使用AI组件进行数据增强
• 实现实时监控和告警

祝您在Nussknacker的使用旅程中收获更多！

【免费下载链接】nussknackerLow-code tool for automating actions on real time data | Stream processing for the users.项目地址: https://gitcode.com/gh_mirrors/nu/nussknacker