查询指定 task 的详情信息和执行进度
字段名 | 类型 | 必须 | 说明 |
---|---|---|---|
task_id | string | 是 | 任务ID,在创建任务时返回 |
from volcengine.viking_db import * if __name__ == '__main__': vikingdb_service = VikingDBService() vikingdb_service.set_ak() vikingdb_service.set_sk() task = vikingdb_service.get_task("**************")
属性 | 类型 | 说明 |
---|---|---|
task_id | string | 任务ID |
task_type | string | 任务类型 |
task_status | string | 任务状态 |
update_person | string | 任务更新人 |
update_time | string | 任务信息更新时间 |
create_time | string | 任务信息创建时间 |
process_info | map | 任务处理信息,例如进度等 |
task_params | map | 任务配置信息,用户填入 |
data_import | 数据导入任务 |
---|---|
data_export | 数据导出任务 |
filter_update | 数据过滤更新任务 |
filter_delete | 数据过滤删除任务 |
init | queued | confirm | confirmed | running | done | fail |
---|---|---|---|---|---|---|
初始化中 | 排队中 | 需要人工确认 | 已确认 | 执行中 | 完成 | 失败 |
字段 | 类型 | 说明 |
---|---|---|
task_progress | string | 任务进度 例如50% |
err_msg | string | 任务错误信息 |
sampled_data | list | 采样5条数据用于展示 |
sampled_timestamp | int64 | 采样的时间戳,后写入的数据不会被处理 |
scan_data_count | int64 | 当前扫描数据量 |
total_data_count | int64 | collection 数据总条数(预估) |
total_filter_count | int64 | 已经过滤出的数据 |