可用的源 内置源 预定义的源插件 源的使用 可用的源 在 eKuiper 源代码中，有内置源和扩展源。 内置源 用户可以直接使用标准 eKuiper 实例中的内置源。内置源的列表如下。 Mqtt source ：从mqtt主题读取数据。 Neuron source : 从本地 Neuron 实例读取数据。 EdgeX source : 从...

Upload a configuration file Upload by a file Upload by content Show uploaded file list Delete an uploaded file The eKuiper REST api for configuration file uploads allows you ...

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 ...

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 ...

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...

Native Plugin Naming Version Setup the plugin developing environment Plugin development State storage Runtime dependencies Native Plugin eKuiper allows user to customize t...

Cross-compile binaries Cross-compile binaries Notice: eKuiper plugins bases on Golang, and due to Golang restrictions, CGO_ENABLED flag must be set to 0 to use the Golang cros...

Portable 插件 Go SDK 插件开发 Symbols 插件主程序 打包发布 Portable 插件 Go SDK 用户可利用 GO SDK 来开发 portable 插件，这个 SDK 提供了类似原生插件的 API，另外它提供了启动函数，用户只需填充插件信息即可。 插件开发 Symbols 由于 portable 插件 GO S...

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