流管理 创建流 显示流 描述流 删除流 查询流 流管理 eKuiper 流命令行工具可用于管理流，例如创建、描述、显示和删除流定义。 创建流 该命令用于创建流。有关流定义的更多详细信息，请参考流 。 create stream $stream_name '$stream_def' | create stream - f $st...

Register external services parameter Service file format Display external services Describe external services Delete external services Update external services Display all e...

边缘处理 边缘处理 使用 Neuron 和 eKuiper 进行边缘处理允许在网络边缘进行数据处理和分析，更接近数据源。 这显着减少了与将数据发送到集中式云进行处理相关的延迟。 可以更快地获得实时洞察和行动，从而加快关键应用程序的响应时间。 通过在边缘处理数据，Neuron 和 eKuiper 可以在将数据发送到云端或中央服务器之前过滤和聚合数据。 ...

Zmq Source Compile & deploy plugin Configuration Global configurations server Override the default settings Sample usage Zmq Source The source will subscribe to a Zero Mq ...

SMDT Smart Industrial Gateway GBOX-66X1 GBOX-68IE 3588D SMDT Smart Industrial Gateway As a technology company with full-stack capabilities of “algorithm + IoT hardware + soft...

表 表内容更新 表的使用 更多信息 表 在 eKuiper 中，表是源数据在当前时间的快照。相比于普通的数据库表，eKuiper 中的表会随着时间而变化。 表的数据源既可以是无界的也可以是有界的。对于有界数据源来说，其表的内容为静态的。若表的数据源为无界数据流，则其内容会动态变化。 表内容更新 当前，表的内容更新仅支持追加。用户创建表时，可...

交叉编译二进制文件 交叉编译二进制文件 Go 语言支持交叉编译多种目标平台的二进制文件。eKuiper 项目也支持标准的 Go 语言交叉编译。由于 eKuiper 依赖 sqlite，因此 CGO_ENABLE 必须设置为1。在交叉编译时，必须安装核指定目标系统的 gcc 工具链。 安装目标系统 gcc 工具链。 修改 Makefile 添加 G...

流管理 创建流 显示流 描述流 删除流 查询流 流管理 eKuiper 流命令行工具可用于管理流，例如创建、描述、显示和删除流定义。 创建流 该命令用于创建流。有关流定义的更多详细信息，请参考流 。 create stream $stream_name '$stream_def' | create stream - f $st...

Register external services parameter Service file format Display external services Describe external services Delete external services Update external services Display all e...

基于时间的流式处理 时间的概念 事件时间和水印 基于时间的流式处理 流数据是一个随时间变化的数据序列，其中时间是数据的一个固有属性。在流处理中，时间在计算中起着重要的作用。例如，在做基于某些时间段（通常称为窗口）的聚合时，定义时间的概念是很重要的。 时间的概念 我们关心的时间通常有两个类型。 事件时间，即事件实际发生的时间。通常情况下，事件...