创建导出任务 - CreateExportTask
功能介绍
应用服务器可调用此接口创建资源导出任务。
-
同一个条件创建任务将会覆盖之前条件的任务结果文件(为了方便任务未执行完就导出后想重新导出完成任务的结果)。
-
单用户最多支持有50个导出任务,超出后将删除最先创建的导出任务。
-
单用户未完成的导出任务最多5个。
-
单用户下载导出文件最大速率为为30s一次。
调用方法
请参见如何调用API。
授权信息
账号具备所有API的调用权限,如果使用账号下的IAM用户调用当前API,该IAM用户需具备调用API所需的权限。
- 如果使用角色与策略授权,具体权限要求请参见权限和授权项。
- 如果使用身份策略授权,需具备如下身份策略权限。
授权项
访问级别
资源类型(*为必须)
条件键
别名
依赖的授权项
iotda:exporttasks:create
Write
-
g:EnterpriseProjectId
-
-
URI
POST /v5/iot/{project_id}/export-tasks
|
参数 |
是否必选 |
参数类型 |
描述 |
|---|---|---|---|
|
project_id |
是 |
String |
参数说明:项目ID。获取方法请参见 获取项目ID 。 |
请求参数
|
参数 |
是否必选 |
参数类型 |
描述 |
|---|---|---|---|
|
Instance-Id |
否 |
String |
参数说明:实例ID。物理多租下各实例的唯一标识,建议携带该参数,在使用专业版时必须携带该参数。您可以在IoTDA管理控制台界面,选择左侧导航栏“总览”页签查看当前实例的ID,具体获取方式请参考查看实例详情 。 |
|
参数 |
是否必选 |
参数类型 |
描述 |
|---|---|---|---|
|
resource_type |
是 |
String |
参数说明:导出源资源类型,支持批量任务导出类型。 取值范围:BatchTask。 |
|
resource_condition |
是 |
Object |
参数说明:资源过滤条件,Json格式,里面是(K,V)键值对,当resource_type为BatchTasks时填写填写key为task_id,value为BatchTask的task_id(task_id从批量任务接口获得)。当app_type为APP时,导出的结果也会在该app范围内,否则为租户级别筛选。 |
|
export_format |
否 |
String |
参数说明:导出格式。 取值范围:xls。 |
|
app_type |
否 |
String |
参数说明: 租户规则的生效范围,默认GLOBAL。 取值范围:
|
|
app_id |
否 |
String |
参数说明:资源空间ID。此参数为非必选参数,存在多资源空间的用户需要使用该接口时,可以携带该参数查询指定资源空间下的任务列表,不携带该参数则会查询该用户下所有任务列表。 取值范围:长度不超过36,只允许字母、数字、下划线(_)、连接符(-)的组合。 |
响应参数
状态码:201
|
参数 |
参数类型 |
描述 |
|---|---|---|
|
export_task_id |
String |
导出任务唯一id。 |
|
resource_type |
String |
导出的资源类型,目前只支持批量任务导出类型BatchTask。 |
|
resource_condition |
Object |
资源过滤条件,Json格式,里面是(K,V)键值对,当resource_type为BatchTask时填写填写key为task_id,value为BatchTask的task_id(task_id从批量任务接口获得)。 |
|
export_format |
String |
导出格式,目前只支持xls格式。 |
|
status |
String |
任务状态,状态分别有:Processing:执行中,Success:成功,Failed:失败。 |
|
export_count |
Long |
已导出的资源数量。 |
|
progress |
Integer |
导出任务的执行进度,取值范围为1-100,当100表示进度为100%,任务完成。 |
|
create_time |
String |
在物联网平台创建产品的时间,格式:yyyy-MM-dd'T'HH:mm:ss.SSS'Z',如2020-08-12T12:12:12.333Z。 |
|
end_time |
String |
导出任务的执行结束时间,格式:yyyy-MM-dd'T'HH:mm:ss.SSS'Z',如2020-08-12T12:12:12.333Z。 |
|
app_type |
String |
租户规则的生效范围,默认GLOBAL,取值如下:
|
|
app_id |
String |
应用ID。此参数为非必选参数,用于兼容平台老用户存在多应用的场景。存在多应用的用户需要使用该接口时,必须携带该参数指定创建的规则归属到哪个应用下,否则接口会提示错误。如果用户存在多应用,同时又不想携带该参数,可以联系华为技术支持对用户数据做应用合并。 |
请求示例
创建导出任务。
POST https://{endpoint}/v5/iot/{project_id}/export-tasks
{
"resource_type" : "BatchTask",
"resource_condition" : {
"task_id" : "5f433ce0c24389024365fdfa"
},
"export_format" : "xls",
"app_type" : "APP",
"app_id" : "jeQDJQZltU8iKgFFoW060F5SGZka"
}
响应示例
状态码:201
Created
{
"export_task_id" : "jeQDJQZltU8iKgFFoW060F5SGZka",
"resource_type" : "BatchTask",
"resource_condition" : {
"task_id" : "32822e5744a45ede319d2c50"
},
"export_format" : "xls",
"status" : "Processing",
"export_count" : 10000,
"progress" : "98,",
"create_time" : "2020-08-12T12:12:12.333Z",
"end_time" : "2020-08-12T12:12:12.333Z",
"app_type" : "string",
"app_id" : "string"
}
SDK代码示例
SDK代码示例如下。
创建导出任务。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 |
package com.huaweicloud.sdk.test; import com.huaweicloud.sdk.core.auth.ICredential; import com.huaweicloud.sdk.core.auth.AbstractCredentials; import com.huaweicloud.sdk.core.auth.BasicCredentials; import com.huaweicloud.sdk.core.exception.ConnectionException; import com.huaweicloud.sdk.core.exception.RequestTimeoutException; import com.huaweicloud.sdk.core.exception.ServiceResponseException; import com.huaweicloud.sdk.core.region.Region; import com.huaweicloud.sdk.iotda.v5.*; import com.huaweicloud.sdk.iotda.v5.model.*; public class CreateExportTaskSolution { public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment String ak = System.getenv("CLOUD_SDK_AK"); String sk = System.getenv("CLOUD_SDK_SK"); // ENDPOINT:请在控制台的"总览"界面的"平台接入地址"中查看“应用侧”的https接入地址。 String iotdaEndpoint = "<YOUR ENDPOINT>"; String projectId = "{project_id}"; ICredential auth = new BasicCredentials() .withProjectId(projectId) // 标准版/企业版需要使用衍生算法,基础版请删除配置"withDerivedPredicate"; .withDerivedPredicate(AbstractCredentials.DEFAULT_DERIVED_PREDICATE) // Used in derivative ak/sk authentication scenarios .withAk(ak) .withSk(sk); IoTDAClient client = IoTDAClient.newBuilder() .withCredential(auth) // 标准版/企业版:需自行创建Region对象,基础版:请使用IoTDARegion的region对象,如"withRegion(IoTDARegion.CN_NORTH_4)" .withRegion(new Region("cn-north-4", iotdaEndpoint)) .build(); CreateExportTaskRequest request = new CreateExportTaskRequest(); AddExportTask body = new AddExportTask(); body.withAppId("jeQDJQZltU8iKgFFoW060F5SGZka"); body.withAppType("APP"); body.withExportFormat("xls"); body.withResourceCondition("{\"task_id\":\"5f433ce0c24389024365fdfa\"}"); body.withResourceType("BatchTask"); request.withBody(body); try { CreateExportTaskResponse response = client.createExportTask(request); System.out.println(response.toString()); } catch (ConnectionException e) { e.printStackTrace(); } catch (RequestTimeoutException e) { e.printStackTrace(); } catch (ServiceResponseException e) { e.printStackTrace(); System.out.println(e.getHttpStatusCode()); System.out.println(e.getRequestId()); System.out.println(e.getErrorCode()); System.out.println(e.getErrorMsg()); } } } |
创建导出任务。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 |
# coding: utf-8 import os from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdkcore.auth.credentials import DerivedCredentials from huaweicloudsdkcore.region.region import Region as coreRegion from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdkiotda.v5 import * if __name__ == "__main__": # The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. # In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] # ENDPOINT:请在控制台的"总览"界面的"平台接入地址"中查看“应用侧”的https接入地址,下面创建Client时需要使用自行创建的Region对象,基础版:请选择IoTDAClient中的Region对象 如: IoTDAClient.new_builder().with_region(IoTDARegion.CN_NORTH_4) endpoint = "<YOUR ENDPOINT>"; projectId = "{project_id}" credentials = BasicCredentials(ak, sk, projectId).with_derived_predicate(DerivedCredentials.get_default_derived_predicate()) client = IoTDAClient.new_builder() \ .with_credentials(credentials) \ .with_region(coreRegion(id="cn-north-4", endpoint=endpoint)) \ .build() try: request = CreateExportTaskRequest() request.body = AddExportTask( app_id="jeQDJQZltU8iKgFFoW060F5SGZka", app_type="APP", export_format="xls", resource_condition="{\"task_id\":\"5f433ce0c24389024365fdfa\"}", resource_type="BatchTask" ) response = client.create_export_task(request) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) |
创建导出任务。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 |
package main import ( "fmt" "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic" iotda "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/iotda/v5" "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/iotda/v5/model" region "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/region" core_auth "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth" ) func main() { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak := os.Getenv("CLOUD_SDK_AK") sk := os.Getenv("CLOUD_SDK_SK") // endpoint:请在控制台的"总览"界面的"平台接入地址"中查看"应用侧"的https接入地址 endpoint := "<YOUR ENDPOINT>" projectId := "{project_id}" auth := basic.NewCredentialsBuilder(). WithAk(ak). WithSk(sk). WithProjectId(projectId). // 企业版/标准版需要使用衍生算法,基础版请删除该配置"WithDerivedPredicate" WithDerivedPredicate(core_auth.GetDefaultDerivedPredicate()). // Used in derivative ak/sk authentication scenarios Build() client := iotda.NewIoTDAClient( iotda.IoTDAClientBuilder(). // 标准版/企业版需要自行创建region,基础版使用IoTDARegion中的region对象 WithRegion(region.NewRegion("cn-north-4", endpoint)). WithCredential(auth). Build()) request := &model.CreateExportTaskRequest{} appIdAddExportTask:= "jeQDJQZltU8iKgFFoW060F5SGZka" appTypeAddExportTask:= "APP" exportFormatAddExportTask:= "xls" var resourceConditionAddExportTask interface{} = "{\"task_id\":\"5f433ce0c24389024365fdfa\"}" request.Body = &model.AddExportTask{ AppId: &appIdAddExportTask, AppType: &appTypeAddExportTask, ExportFormat: &exportFormatAddExportTask, ResourceCondition: &resourceConditionAddExportTask, ResourceType: "BatchTask", } response, err := client.CreateExportTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } |
更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
状态码
|
状态码 |
描述 |
|---|---|
|
201 |
Created |
|
400 |
Bad Request |
|
403 |
FORBIDDEN |
错误码
请参见错误码。