eKuiper REST api 允许您管理外部服务,例如注册、删除和列出服务,列出外部函数等。
该API接受JSON内容以创建新的外部服务。
POST http://localhost:9081/services
文件在http服务器上时的请求示例:
{
"name":"random",
"file":"http://127.0.0.1/services/sample.zip"
}
文件在eKuiper所在服务器上时的请求示例:
{
"name":"random",
"file":"file:///var/services/sample.zip"
}
名为 sample.zip 的源的示例 zip 文件
该 API 用于显示服务器中为定义的所有外部服务。
GET http://localhost:9081/services
响应示例:
["sample","sample2"]
该 API 用于打印外部服务的详细定义。
GET http://localhost:9081/services/{name}
路径参数 name
是外部服务的名称。
该 API 用于删除外部服务,服务之下定义的所有函数都将被删除。
DELETE http://localhost:9081/services/{name}
该 API 用于更新外部服务,其参数与服务注册相同。
PUT http://localhost:9081/services/{name}
{
"name":"random",
"file":"http://127.0.0.1/services/sample.zip"
}
每个服务可包含多个函数。该 API 用于展示所有外部函数的可用于 SQL 的函数名称。
GET http://localhost:9081/services/functions
结果样例:
["func1","func2"]
该 API 用于展示定义此外部函数的服务名称。
GET http://localhost:9081/services/functions/{name}
结果样例:
{
"name": "funcName",
"serviceName": "serviceName"
}