Docs

# 如何将自定义的插件展示在管理控制台的安装列表

# 概览

eKuiper 提供了插件的扩展机制，用户可以基于扩展接口来实现自定义的插件。在管理控制台上，用户可以直接通过界面进行插件的安装。如果读者有自定义的插件，也想出现在管理控制台的安装列表中，该文章可以给读者一些参考。

# 插件元数据

插件元数据是一个 json 格式文件，用于描述插件的信息。这些信息会展示在管理控制台上，同时用于管理控制台生成插件配置页面。

# 元数据格式

插件元数据为 json 格式文件，不同的插件类型支持不同的属性。

源（Source）

Source 元数据的详细配置请参考 source 元数据配置。配置文件的示例如下：

{
  "about": {
    "trial": true,
    "author": {
      "name": "yourname",
      "email": "your@email.com",
      "company": "your company",
      "website": "https://www.your.website"
    },
    "helpUrl": {
      "en_US": "https://yourwebsite/help_en_US.md",
      "zh_CN": "https://yourwebsite/help_zh_CN.md"
    },
    "description": {
      "en_US": "your description",
      "zh_CN": "描述"
    }
  },
  "properties": {
    "default": [
      {
        "name": "prop1",
        "default": 1000,
        "optional": false,
        "control": "text",
        "type": "int",
        "hint": {
          "en_US": "The description",
          "zh_CN": "参数用法描述"
        },
        "label": {
          "en_US": "prop display name",
          "zh_CN": "参数显示名称"
        }
      }
    ]
  }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

Source 元数据的配置参数主要由两部分组成：

about

描述插件的基本信息，包括插件作者，帮助文件，描述等。所有属性都支持多语言描述。插件安装后，在管理控制台的流管理页面选择流类型时，将会展示插件元数据中定义的信息。选中插件之后，界面上将展示元数据定义的帮助文档链接。

plugin abouot

properties

描述插件的可配置属性信息，包括参数的信息以及如何进行界面展示。Source 的属性信息通过对应的配置文件指定，且配置文件中可指定多个配置组，详细请见Source 配置文档。在元数据文件中，properties下可对应有多个配置组名，如例子中的default；每个配置组下又有多个属性的元数据。

在管理控制台的流管理页面，点击源配置，展开任意的源，则可展示元数据的所有配置组。

plugin conf group

点击任一配置组，可查看配置组参数。点击添加符号，则可进入如下图参数配置页面。参数配置的展示名称，控件等信息均来自元数据json文件的定义。

source configure

动作（Sink）

Sink 元数据配置与 Source 基本相同。详细配置请参考 sink 元数据配置。

Sink 元数据的配置参数主要也由两部分组成：

about

描述插件的基本信息，包括插件作者，帮助文件，描述等。所有属性都支持多语言描述。插件安装后，在管理控制台的规则创建页面，在动作模块点击添加按钮，在弹出窗口中，点击下拉框进行 sink 选择。在下拉框中将列出插件元数据中定义的信息。

sink about

properties

描述插件的可配置属性信息，包括参数的信息以及如何进行界面展示。与 Source 不同的时，Sink 的属性不保存在配置文件里，而是在规则创建时进行配置。对应的元数据配置中，Sink 不再有配置组概念。在管理控制台的规则创建页面，添加动作弹出窗口中，选中插件后将展示帮助文档链接以及元数据中定义的属性。需要注意的时，Sink 有一些共同属性，在所有 Sink 中都会展示。

sink config

函数（Functions）

Function 元数据详细配置请参考 sink 元数据配置。其中，about 部分与 Source 和 Sink 完全相同。function 部分配置了函数的名称，样例和提示信息，用于新建规则的 SQL 编辑器中进行代码提示。

function about

# 插件编译打包格式

插件的开发，编译和打包请参考插件开发教程。自定义插件要展示在管理控制台，需要遵循如下原则：

  1. 插件元数据文件名应当与插件名字相同，且为 json 文件，例如mySource.json。
  2. 插件元数据文件应当放在打包的 zip 文件的跟目录下。

# 发布至 Web 服务器

在 etc/kuiper.yaml 中，有一个 pluginHosts 配置项，用户可以在这里配置服务器列表。除了官方的插件发布地址之外，用户可以在这里加入自己本地的插件发布地址。但是插件发布时候对目录的结构和内容有要求。部署服务应为

https://$host/$folder/$version/$os/$type/$plugin.zip
1

例如： https://127.0.0.1:9090/kuiper-plugins/1.3.1/debian/sinks/file.zip

其中：

  1. $version: 插件编译所用的 eKuiper 版本号
  2. $os: 插件编译所用的操作系统。在默认 eKuiper Docker 镜像中编译的插件，该值为 debian.
  3. $type: 插件类型，可为sources, sinks, functions.

# 限制

由于Go语言插件机制的限制，插件的编译环境必须与eKuiper环境相同。因此，建议插件在eKuiper相同版本的Docker 容器中进行编译。同时，由于alpine 环境部分库缺失，不建议在上面运行插件。因此，若需要插件安装运行，建议使用如下容器：

  • eKuiper: 使用 slim 镜像，例如 1.3.1-slim
  • 插件：使用对应版本默认镜像进行编译，例如 1.3.1

# 总结

eKuiper 控制台提供了自定义插件的展示机制。用户只需要在自定义插件包中添加插件元数据文件即可。同时，用户可以自定义插件仓库，从而方便地从控制台进行插件的安装和使用。

← 接口介绍 →

本页导航