[Question] understandings of eKuiper

[guowei-gong]

Hi，这是我对 ekuiper 的一些理解，说的不对的地方请斧正。感谢。

1. 没有 ekuiper 时，数据规则放在 EMQX 云端进行，此时流量实际已经打到了云端。
   有 ekuiper 时，ekuiper 运行在设备端，也就是边缘端，在边缘端定义了数据规则，将过滤后的数据打到 EMQX，节约了带宽、流量。
2. ekupier 创建的是流。发送到主题的数据，会被这个流订阅并处理。
3. 定义流，其实就像关系型数据库中定义一张表。
4. ekuiper 的加工数据可以通过 Go 进行扩展。

[ngjaying]

这几点都是基于处理 MQTT 数据并与 EMQ 协同，没有问题。不过，eKuiper 本身并不依附 EMQX 或者 MQTT，流的类型可以是别的协议，甚至是扩展私有协议。扩展的部分处理数据处理函数之外，还可以是数据连接的部分包括输入的source和输出的sink。

[guowei-gong]

感觉你想要的是接入本地的数据源，而不是云端的 EMQX。本地其实也有轻量化的MQTT broker 比如 NanoMQ，或者如果本地的数据本身是别的协议产生的，也可以用 eKuiper 直接接入。

欢迎加入微信群讨论，下面有链接： https://github.com/lf-edge/ekuiper/tree/master/docs/en_US#get-help

amazing! 是的，我好像没有正确的理解我的需求，不过我的关注点一直在 source。

[guowei-gong]

按照您的回复，目前 EMQX 被看做是一个数据源吗？如果这样，我发起这篇讨论的观点好像出现了错误，观点如下：

1. 没有 ekuiper 时，数据规则放在 EMQX 云端进行，此时流量实际已经打到了云端。
   有 ekuiper 时，ekuiper 运行在设备端，也就是边缘端，在边缘端定义了数据规则，将过滤后的数据打到 EMQX，节约了带宽、流量。

此时的数据都会打到 EMQX，何来引入了 ekuiper 反而节约了带宽、流量这个说法呢？

[ngjaying]

1. EMQX是一个MQTT broker，是MQTT协议的消息汇聚。 eKuiper 这边只是有 MQTT source， MQTT sink 跟别的 source 和 sink都是并列的关系，也不关心具体的MQTT broker 实现。
2. 物联网场景中，边缘端通常由各种设备/传感器等产生数据。这些数据量特别大，单独看又不是特别重要。eKuiper的作用就是在边缘端就近对这些数据进行处理，过滤啊，转换啊，聚合啊，这样只提取出有用的数据传到云端，相比全量上传就是节约了带宽。这边假设的是数据源和 eKuiper 都部署在边缘端，数据到 eKuiper 不需要经过外网，没有带宽消耗。

[ngjaying]

一般 eKuiper source端接的是边缘的数据，sink端发到边缘或云端。如果数据本身就来自云端，把eKuiper部署到同样的云端位置就行了

[guowei-gong]

感谢您的帮助 :-)