Scheduler管理
服务状态
初始化部署后默认后台任务是没有打开的，如果需要可以Clustermgr管理章节打开。
提示
只有主节点才会显示均衡、下线、修盘、巡检以及手动迁移任务状态，所有Scheduler节点状态都包含删除、修补任务。
curl http://127.0.0.1:9800/stats # 查看本机的节点状态
curl http://127.0.0.1:9800/leader/stats/ # 查看主节点状态
响应示例
{
"balance": {
"enable": true,
"finishing_cnt": 0,
"preparing_cnt": 0,
"stats_per_min": {
"data_amount_byte": "[0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B]",
"finished_cnt": "[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0]",
"shard_cnt": "[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0]"
},
"worker_doing_cnt": 0
},
"blob_delete": {
"enable": true,
"err_stats": null,
"failed_per_min": "[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0]",
"success_per_min": "[4967 3984 4965 3956 3034 3978 2005 1932 960 3043 3041 2970 1993 3048 2966 2994 4100 6069 6957 6019]",
"total_err_cnt": 0
},
"disk_drop": {
"dropped_tasks_cnt": 0,
"dropping_disk_id": 0,
"enable": true,
"finishing_cnt": 0,
"preparing_cnt": 0,
"stats_per_min": {
"data_amount_byte": "[0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B]",
"finished_cnt": "[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0]",
"shard_cnt": "[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0]"
},
"total_tasks_cnt": 0,
"worker_doing_cnt": 0
},
"disk_repair": {
"enable": true,
"finishing_cnt": 0,
"preparing_cnt": 0,
"repaired_tasks_cnt": 0,
"repairing_disk_id": 0,
"stats_per_min": {
"data_amount_byte": "[0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B]",
"finished_cnt": "[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0]",
"shard_cnt": "[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0]"
},
"total_tasks_cnt": 0,
"worker_doing_cnt": 0
},
"manual_migrate": {
"finishing_cnt": 0,
"preparing_cnt": 0,
"stats_per_min": {
"data_amount_byte": "[0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B 0.000B]",
"finished_cnt": "[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0]",
"shard_cnt": "[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0]"
},
"worker_doing_cnt": 0
},
"shard_repair": {
"enable": true,
"err_stats": null,
"failed_per_min": "[0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0]",
"success_per_min": "[0 0 0 0 0 0 1 0 0 0 1 0 1 0 0 0 0 0 0 0]",
"total_err_cnt": 0
},
"volume_inspect": {
"enable": true,
"finished_per_min": "[48 63 50 43 39 73 58 48 42 29 52 58 61 85 55 78 59 55 78 80]",
"time_out_per_min": "[17 10 10 14 14 6 3 3 16 30 11 4 5 2 1 1 2 4 3 0]"
}
}
手动迁移chunk
特殊情况下可以设置手动迁移某个chunk。
注意
这里只能指定迁移的数据源，目标由Clustermgr分配。
curl -X POST --header 'Content-Type: application/json' -d '{"vuid": 4395630596,"direct_download": false}' "http://127.0.0.1:9800/manual/migrate/task/add"
参数说明
| 参数 | 类型 | 描述 |
|---|---|---|
| vuid | uint64 | chunk id |
| direct_download | bool | 源chunk是否允许直接下载（源vuid所在数据如果损坏，则会通过纠删码修复的方式） |
查询后台任务
可以通过此命名查询某个后台任务的详细信息，如任务基本信息以及任务的执行状态信息。
curl http://127.0.0.1:9800/task/detail/:type/:id
# curl http://127.0.0.1:9800/task/detail/balance/balance-2678-387752-cg08egoi5d8une4a6cp0
参数说明
| 参数 | 类型 | 描述 |
|---|---|---|
| type | string | disk_repir/balance/disk_drop/manual_migrate id |
| id | string | 后台任务id |
响应示例
{
"stat": {
"done_count": 1045,
"done_size": 856426665,
"progress": 5,
"total_count": 17552,
"total_size": 14473209599
},
"task": {
"code_mode": 12,
"ctime": "2023-03-02 19:23:47.09638336 +0800 CST m=+80.601918285",
"destination": {
"disk_id": 6027,
"host": "http://127.0.0.1:8889",
"vuid": 1665382175735812
},
"finish_advance_reason": "",
"forbidden_direct_download": false,
"mtime": "2023-03-02 19:23:48.251012267 +0800 CST m=+81.756547201",
"source_disk_id": 2678,
"source_idc": "test",
"source_vuid": 1665382175735811,
"sources": [
{
"disk_id": 2939,
"host": "http://127.0.0.1:8889",
"vuid": 1665382158958593
},
{
"disk_id": 2678,
"host": "http://127.0.0.1:8889",
"vuid": 1665382175735811
},
{
"disk_id": 4467,
"host": "http://127.0.0.1:8889",
"vuid": 1665382192513026
},
{
"disk_id": 5987,
"host": "http://127.0.0.1:8889",
"vuid": 1665382209290243
},
{
"disk_id": 6190,
"host": "http://127.0.0.1:8889",
"vuid": 1665382226067459
},
{
"disk_id": 2744,
"host": "http://127.0.0.1:8889",
"vuid": 1665382242844678
},
{
"disk_id": 6276,
"host": "http://127.0.0.1:8889",
"vuid": 1665382259621892
},
{
"disk_id": 6095,
"host": "http://127.0.0.1:8889",
"vuid": 1665382276399106
},
{
"disk_id": 5823,
"host": "http://127.0.0.1:8889",
"vuid": 1665382293176325
},
{
"disk_id": 6315,
"host": "http://127.0.0.1:8889",
"vuid": 1665382309953539
},
{
"disk_id": 5918,
"host": "http://127.0.0.1:8889",
"vuid": 1665382326730756
},
{
"disk_id": 6278,
"host": "http://127.0.0.1:8889",
"vuid": 1665382343507971
},
{
"disk_id": 6138,
"host": "http://127.0.0.1:8889",
"vuid": 1665382360285186
},
{
"disk_id": 5411,
"host": "http://127.0.0.1:8889",
"vuid": 1665382377062403
}
],
"state": 2,
"task_id": "balance-2678-387752-cg08egoi5d8une4a6cp0",
"task_type": "balance",
"worker_redo_cnt": 0
}
}
在github上编辑