Sink Extension Developing Develop a sink Parse dynamic properties Package the sink Usage Sink Extension Sink feed data from eKuiper into external systems. eKuiper has built...

编解码 格式 模式 模式注册 模式注册表 API 编解码 eKuiper 计算过程中使用的是基于 Map 的数据结构，因此 source/sink 连接外部系统的过程中，通常需要进行编解码以转换格式。在 source/sink 中，都可以通过配置参数 format 和 schemaId 来指定使用的编解码方案。 格式 编解码的格式分为两...

使用 eKuiper 处理 Protocol Buffers 数据 模式注册（Schema Registry） 读取 Protobuf 数据 写入 Protobuf 数据 总结 进一步阅读 使用 eKuiper 处理 Protocol Buffers 数据 LF Edge eKuiper 通过 source 和 sink 连接各种通信协议，例...

Timely Stream Processing Notion of time Event time and watermark Timely Stream Processing Streaming data is a sequence of data over time, in which time is a intrinsic attribut...

InfluxDB Sink Compile & deploy plugin Properties Sample usage /tmp/influxRule.txt /tmp/influxPlugin.txt plugins/go.mod InfluxDB Sink The sink will publish the result into ...

eKuiper 提供了一种类似于 SQL 的查询语言，用于对事件流执行转换和计算。 本文介绍eKuiper 查询语言的语法、用法和最佳实践。 流规格 查询语言元素 窗口 内置函数 扩展 插件扩展 外部服务扩展

eKuiper 由 Golang 开发，可以在不同的操作系统上运行。 有关如何安装和操作 eKuiper 的信息，请参见下面的文档。 编译说明 安装说明 配置文件 Cli 管理 UI 管理 rest api 管理

如何使用 meta 函数抽取在 EdgeX 消息总线中发送的其它信息? EdgeX 消息总线上收到的消息模型 突破性变化 eKuiper 中的 EdgeX 数据模型 总结 如何使用 meta 函数抽取在 EdgeX 消息总线中发送的其它信息? 当数据被发布到 EdgeX 消息总线的时候，除了真正的设备发出的值之外，还包含了一些额外的值，例如事件...

eKuiper 提供了一种类似于 SQL 的查询语言，用于对事件流执行转换和计算。 本文介绍eKuiper 查询语言的语法、用法和最佳实践。 流规格 查询语言元素 窗口 内置函数 扩展 插件扩展 外部服务扩展

CentOS 从 ZIP 文件安装 CentOS 本文件描述如何在 CentOS 上安装。 从 ZIP 文件安装 解压安装包。 unzip kuiper-centos7-v0.0.1.zip 运行 kuiper 来验证 eKuiper 是否已成功安装。 # cd kuiper # bin/kuiper --version kui...