overview.md 2.5 KB
数据源
在 eKuiper 源代码中，有内置源和扩展源。
读入模式
源连接器提供了与外部系统的连接，以便将数据加载进来。关于数据加载机制，有两种模式。
- 扫描：像一个由事件驱动的流一样，一个一个地加载数据事件。这种模式的源可以用在流或扫描表中。
- 查找：在需要时引用外部内容，只用于查找表。
每个源将支持一种或两种模式。在源页面上，如果支持该模式，会有一个徽章显示。
内置源
用户可以直接使用标准 eKuiper 实例中的内置源。内置源的列表如下。
- Mqtt source：从mqtt 主题读取数据。
- Neuron source: 从本地 Neuron 实例读取数据。
- EdgeX source: 从 EdgeX foundry 读取数据。
- Http pull source：从 http 服务器中拉取数据。
- Http push source：通过 http 推送数据到 eKuiper。
- Redis source: 从 Redis 中查询数据，用作查询表。
- File source：从文件中读取数据，通常用作表格。
- Memory source：从 eKuiper 内存主题读取数据以形成规则管道。
预定义的源插件
我们已经开发了一些官方的源码插件。这些插件可以在 eKuiper 的源代码中找到，用户需要手动构建它们。关于如何构建和使用，请查看每个源的文档。
这些插件有预编译的二进制文件，用于主流的cpu架构，如AMD或ARM。预编译建的插件托管在 https://packages.emqx.net/kuiper-plugins/$version/$os/sources/$type_$arch.zip 。例如，要获得 debian amd64 的 zmq 源插件，请从 https://packages.emqx.net/kuiper-plugins/1.4.4/debian/sources/zmq_amd64.zip 安装。
预定义的源插件列表：
- SQL source: 定期从关系数据库中拉取数据。
- Random source: 一个生成随机数据的源，用于测试。
- Zero MQ source：从 Zero MQ 读取数据。
源的使用
用户通过流或者表的方式来使用源。在创建的流属性中，需要把类型 TYPE 属性设置成所需要的源的名字。用户还可以在创建流的过程中，配置各种源通用的属性，例如解码类型（默认为 JSON）等来改变源的行为。创建流支持的通用属性和创建语法，请参考流规格。