The eKuiper REST api for schemas allows you to manage schemas, such as create, show, drop and describe schemas.
Create a schema
The API accepts a JSON content and create a schema. Each schema type has a standalone endpoint. Currently, only one schema type protobuf
is supported. Schema is identified by its name, so the name must be unique for each type.
POST http://localhost:9081/schemas/protobuf
Schema content inside request body:
{
"name": "schema1",
"content": "message Book {required string title = 1; required int32 price = 2;}"
}
Schema content in a file:
{
"name": "schema2",
"file": "file:///tmp/ekuiper/internal/schema/test/test2.proto"
}
Schema with static plugin:
{
"name": "schema2",
"file": "file:///tmp/ekuiper/internal/schema/test/test2.proto",
"soFile": "file:///tmp/ekuiper/internal/schema/test/so.proto"
}
Parameters
- name:the unique name of the schema.
- schema content, use
file
orcontent
parameter to specify. After schema created, the schema content will be written into filedata/schemas/$shcema_type/$schema_name
.file: the url of the schema file. The url can be
http
orhttps
scheme orfile
scheme to refer to a local file path of the eKuiper server. The referenced file can be either a single schema file or a zip archive.- Single schema file: The file extension must match the corresponding schema type. For example: .proto for protobuf schema.
- Zip archive: The zip file must contain a single primary schema file at its root. Optionally, the zip file can also contain a folder with the same name as the schema (without the extension) to hold supporting files. Any other files or folders within the zip archive will be ignored. Example: For a schema named test, the test.zip file should have the following structure:
texttest.zip/ ├── test.proto (Primary schema file) └── test/ (Optional folder for supporting files) ├── helper.proto └── config.json
- content: the text content of the schema.
- soFile:The so file of the static plugin. Detail about the plugin creation, please check customize format.
Show schemas
The API is used for displaying all schemas defined in the server.
GET http://localhost:9081/schemas/protobuf
Response Sample:
["schema1","schema2"]
Describe a schema
The API is used for print the detailed definition of a schema.
GET http://localhost:9081/schemas/protobuf/{name}
Path parameter name
is name of the schema.
Response Sample:
{
"type": "protobuf",
"name": "schema1",
"content": "message Book {required string title = 1; required int32 price = 2;}",
"file": "ekuiper\\etc\\schemas\\protobuf\\schema1.proto"
}
Delete a schema
The API is used for dropping the schema.
DELETE http://localhost:9081/schemas/protobuf/{name}
Update a schema
The API is used for updating the schema. The request body is the same as creating a schema.
PUT http://localhost:9081/schemas/protobuf/{name}
{
"name": "schema2",
"file": "http://ahot.com/test2.proto"
}