使用处理器
Yao 提供一组数据原子操作、网络请求、流程控制等一系列的处理器。这些处理器可以在命令行、Widget、Script、云函数和 Studio 脚本中使用。
处理器支持自定义,可以通过编写 Flow、Script、GRPC 插件或自定义 Widget 方式扩展。
约定
- 示例中约定应用根目录为
/data/app, 实际编写时需替换为应用根目录。 - 示例中约定服务器地址为
http://127.0.0.1:5099, 实际编写时需自行替换。 - 示例中约定 Studio 服务器地址为
http://127.0.0.1:5077, 实际编写时需自行替换。 - 使用
<>标识自行替换的内容。 例如:icon-<图标名称>, 实际编写时应替换为:icon-foo,icon-bar...
处理器
处理器由名称、参数表和返回值构成。可以理解为是一个功能函数 ProcessName( ...args:Any[] ) Any,
名称: <命名空间>.<名称>
参数表: [...Args]
返回值: Any
处理器清单:
| 处理器 | 说明 |
|---|---|
| models.* | 数据模型原子操作 |
| schemas.* | 数据表结构操作 |
| stores.* | 数据存储 |
| fs.* | 文件系统 |
| http.* | HTTP 请求 |
| session.* | 会话数据 |
| encoding.* | 编码解码 |
| crypto.* | 加密解密 |
| ssl.* | 签名校验 |
| utils.* | 一组实用程序 |
| flows.* | 使用 Flow 编写的处理器 |
| scripts.* | 使用 Script 脚本编写的处理器 |
| plugins.* | 使用 GRPC 插件编写处理器 |
| widgets.* | 自定义 Widget 导出的的处理器 |
内建 Widgets 的处理器:
| Widget | 处理器 | 说明 |
|---|---|---|
| App | yao.app.* | App Widget 处理器 |
| Login | yao.login.* | Login Widget 处理器 |
| Table | yao.table.* | Table Widget 处理器 |
| Form | yao.form.* | Form Widget 处理器 |
| Chart | yao.chart.* | Chart Widget 处理器 |
| Import | imports.* | Import Widget 数据导入处理器 |
| Task | tasks.* | Task Widget 并发任务处理器 |
| Schedule | schedules.* | Schedule Widget 异步任务处理器 |
使用方式
在命令行中使用
可以使用 run 命令,运行处理器 yao run <process> [args...]。
bash
yao run models.product.Paginate '::{}' 1 2在 DSL 中使用
可在 YAO DSL (API, Flow, Table, Chart 等) 中使用处理器, 可参考对应 Widget 文档。
在 API DSL 中使用
jsonc
{
// ...
"paths": [
{
"path": "/search",
"method": "GET",
"process": "models.product.Paginate",
"in": [":query-param", "$query.page", "$quey.pagesize"], // 参数表
"out": { "status": 200, "type": "application/json" }
}
]
// ...
}在 Flow DSL 中使用
jsonc
{
// ...
"nodes": [
{
"name": "宠物",
"process": "models.product.Find",
"args": [1, { "select": ["id", "name"] }]
},
{
"name": "打印",
"process": "utils.fmt.Print",
"args": ["{{$res.宠物}}"]
}
]
// ...
}在 Table DSL 中使用
jsonc
{
// ...
"action": {
"bind": { "table": "product" },
"search": {
"guard": "-",
"process": "scripts.product.Search",
"default": [null, 1, 2]
},
"save": {
"guard": "bearer-jwt,scripts.product.Guard"
},
"after:search": "scripts.hook.BeforeSearch",
"after:search": "scripts.hook.AfterSearch"
}
// ...
}在脚本中使用
可以在 Script, 云函数, Stuido 脚本中,使用 Process(name, ...args) 函数,调用处理器
在 Script 中使用
/data/app/scripts/demo.js
javascript
function GetProduct(id) {
return Process('models.product.Find', id, { select: ['id', 'name'] });
}运行调试
bash
yao run scripts.demo.GetProduct 1在云函数中使用
/data/app/services/demo.js
javascript
function GetProduct(id) {
return Process('models.product.Find', id, { select: ['id', 'name'] });
}运行调试
bash
yao run utils.jwt.Make 1 '::{"id":1, "name":"Admin"}' '::{"issuer":"yao"}'bash
curl -X POST http://127.0.0.1:5099/api/__yao/app/service/demo \
-H 'Content-Type: application/json' \
-H 'Authorization: Bearer <JWT>' \
-d '{ "method":"GetProduct", "args":[1]}'在 Studio 中使用
/data/app/studio/demo.js
javascript
function GetProduct(id) {
return Process('models.product.Find', id, { select: ['id', 'name'] });
}运行调试
bash
yao studio run demo.GetProduct 1bash
# JWT 可以通过管理后台, 管理员登录接口获取
curl -X POST http://127.0.0.1:5077/service/demo \
-H 'Content-Type: application/json' \
-H 'Authorization: Bearer <Studio JWT>' \
-d '{ "method":"GetProduct", "args":[1]}'