Databend Blog
·
使用LF Edge eKuiper将IoT流数据发送到Databend
💡
原文英文，约800词，阅读约需3分钟。
📝
内容提要
本文介绍了如何使用eKuiper将IoT流处理数据写入Databend。eKuiper是一个轻量级的IoT数据分析和流处理引擎，支持SQL和图形规则引擎。本文提供了创建Databend Sink规则的步骤，并演示了如何将数据从文件数据源成功导入Databend。
🎯
关键要点
- eKuiper是EMQ下的流处理软件，体积小且功能强大，广泛应用于工业物联网、车载网络和公共数据分析等领域。
- eKuiper是一个轻量级的IoT数据分析和流处理引擎，旨在为边缘设备提供流处理软件框架。
- eKuiper支持通过Golang和Python扩展源、SQL函数和Sink，允许用户将分析结果发送到各种外部系统。
- Databend已集成到eKuiper插件中作为Sink，提供将IoT流处理数据写入Databend的示例。
- 构建eKuiper和Databend SQL插件的步骤包括克隆eKuiper代码库、构建Sink插件和复制插件到构建目录。
- 在Databend中创建目标表'ekuiper_test'，以便存储从eKuiper发送的数据。
- eKuiper提供两种管理流、规则和目标的方式：通过ekuiper-manager Docker镜像的可视化管理界面或使用CLI工具。
- 创建流的步骤包括配置文件数据源并在终端中创建流以从JSON文件中检索数据。
- 创建Databend Sink规则的过程涉及定义数据流的处理逻辑，并通过SQL查询将数据发送到外部系统。
- 创建规则后，符合条件的数据会立即发送到目标，成功将数据从文件数据源导入Databend。
➡️
