用于按条件过滤数据集内的数据进行批量删除操作。
包括三个接口：

• /task/create 创建离线任务
• /task/update 更新任务状态
• /task/info 查询任务运行信息

创建删除任务(create)

/task/create 用于在指定的数据集 Collection 按条件创建条件过滤删除任务。

请求接口

请求参数

{
    "user_id":[1,2,3]，
    "city":["beijing"]
}

响应消息

更新任务状态(update)

/task/update 用于对离线任务进行人工确认操作。
在条件过滤删除任务完成数据扫描后，需进行人工确认。经确认后，才会正式开始删除操作，且删除后数据不可恢复。
如果不需要人工确认环节，可以在创建删除任务时将“need_confirm”设置为“false”。

请求接口

请求参数

响应消息

任务运行信息(info)

/task/info用于查询任务状态、任务进度等离线任务的详细信息。

请求接口

请求参数

响应消息

• 任务状态说明

错误码说明

在使用条件删除 collection 数据时，首先需要创建一个collection，假设现有一个名为 example 的 collection，有 user_id 和 city 两个field。

第一步，创建删除任务

对 example 执行条件删除，设置条件 user_id 为5或9，并且 city 为 beijing 的数据。创建成功后会返回 task_id。

from volcengine.auth.SignerV4 import SignerV4
from volcengine.Credentials import Credentials
from volcengine.base.Request import Request
import requests, json

def prepare_request(method, path, ak, sk, params=None, data=None, doseq=0):
    request = Request()
    request.set_method(method)
    request.set_host("api-vikingdb.volces.com")
    request.set_path(path)
    mheaders = {
        'Accept': 'application/json',
        'Content-Type': 'application/json',
    }
    request.set_headers(mheaders)
    if params:
        request.set_query(params)
    if data:
        request.set_body(json.dumps(data))
    credentials = Credentials(ak, sk, 'air', 'cn-north-1')
    SignerV4.sign(request, credentials)
    return request

DOMAIN = "api-vikingdb.volces.com"
AK = "****"
SK = "****"
task_type = "filter_delete"

task_param = {
    "collection_name": "example",
    "filter" : {
        "user_id": [5,9],
        "city": ["beijing"]
    }
}

req_info = prepare_request(method = "POST", 
                    path = "/api/task/create",
                    ak = AK, 
                    sk = SK,
                    data ={"task_type":task_type, "task_params":task_param})
r = requests.request(method=req_info.method,
        url="http://{}{}".format(DOMAIN, req_info.path),
        headers=req_info.headers,
        data=req_info.body
    )
task_id = json.loads(r.text)['data']['task_id']

第二步，获取任务信息

输入 task_id 可以查看任务的运行信息，若数据扫描完成后，任务状态会扭转为 confirm，需要进行人工确认。

req_info = prepare_request(method = "POST", 
                    path = "/api/task/info",
                    ak = AK, 
                    sk = SK,
                    data ={"task_id":task_id})
r = requests.request(method=req_info.method,
        url="http://{}{}".format(DOMAIN, req_info.path),
        headers=req_info.headers,
        data=req_info.body
    )
print(r.text)

第三步，对条件过滤删除数据任务进行人工确认

删除的数据不可恢复，如果不需要人工确认环节，创建条件删除任务时把 need_confirm 设为 false 即可。
人工确认完成后会执行数据删除，可通过步骤二查看任务进度。

req_info = prepare_request(method = "POST", 
                    path = "/api/task/update",
                    ak = AK, 
                    sk = SK,
                    data ={"task_id":task_id, "task_status":"confirmed"})
r = requests.request(method=req_info.method,
        url="http://{}{}".format(DOMAIN, req_info.path),
        headers=req_info.headers,
        data=req_info.body
    )
print(r.text)