Kuiper 插件命令行工具使您可以管理插件,例如创建,显示和删除插件。 请注意,删除插件将需要重新启动kuiper 才能生效。 要更新插件,请执行以下操作:
该命令用于创建插件。 插件的定义以 JSON 格式指定。
create plugin $plugin_type $plugin_name $plugin_json | create plugin $plugin_type $plugin_name -f $plugin_def_file
插件可以通过两种方式创建。
示例:
# bin/kuiper create plugin source random {"file":"http://127.0.0.1/plugins/sources/random.zip"}
该命令创建一个名为 random
的源插件。
-f
选项指定插件定义即可。示例:
# bin/kuiper create plugin sink plugin1 -f /tmp/plugin1.txt
以下是 plugin1.txt
的内容。
{
"file":"http://127.0.0.1/plugins/sources/random.zip"
}
["source", "sink", "functions"]
Random
,则此插件的名称为 Random
。该命令用于显示服务器中为插件类型定义的所有插件。
show plugins function
示例:
# bin/kuiper show plugins function
function1
function2
该命令用于打印插件的详细定义。
describe plugin $plugin_type $plugin_name
示例:
# bin/kuiper describe plugin source plugin1
{
"name": "plugin1",
"version": "1.0.0"
}
该命令用于删除插件。
drop plugin $plugin_type $plugin_name -s $stop
其中,-s $stop
是可选的布尔参数。 如果将其设置为 true,则 Kuiper 服务器将停止,以使删除生效。 用户将需要手动重新启动它。
示例:
# bin/kuiper drop plugin source random
Plugin random is dropped.