更新时间:2026-01-29 GMT+08:00
分享

更新数据加工 - UpdateDataTransformation

功能介绍

更新数据加工

调用方法

请参见如何调用API

授权信息

账号具备所有API的调用权限,如果使用账号下的IAM用户调用当前API,该IAM用户需具备调用API所需的权限,具体权限要求请参见权限和授权项

URI

PUT /v2/{project_id}/workspaces/{workspace_id}/siem/data-transformations/{data_transformation_id}

表1 路径参数

参数

是否必选

参数类型

描述

project_id

String

参数解释:

项目ID,用于明确项目归属,配置后可通过该ID查询项目下资产,可以通过调用API获取,也可以从控制台获取。获取项目ID

约束限制:

不涉及

取值范围:

不涉及

默认取值:

不涉及

workspace_id

String

工作空间ID

data_transformation_id

String

数据转换 ID

请求参数

表2 请求Header参数

参数

是否必选

参数类型

描述

X-Auth-Token

String

参数解释:

用户Token,通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。获取用户Token

约束限制:

不涉及

取值范围:

不涉及

默认取值:

不涉及

表3 请求Body参数

参数

是否必选

参数类型

描述

data_transformation_name

String

数据转换名称

description

String

数据转换描述

directory

String

directory 目录分组

script

String

Job Script 作业脚本

status

String

参数解释:

作业状态

  • ENABLED 启用

  • DISABLED 禁用

约束限制

不涉及

取值范围:

  • ENABLED

  • DISABLED

默认值

不涉及

belong

String

归属

job_mode

String

参数解释:

作业模式

  • STREAMING 流式处理

  • BATCH 批处理

  • SEARCH 检索

约束限制

不涉及

取值范围:

  • STREAMING

  • BATCH

  • SEARCH

默认值

不涉及

cu_quota_amount

Float

cu总量

job_mode_setting

IsapJobModeSettingDto object

作业模式设置数据传输对象

environment

String

参数解释:

环境类型

  • PROD 生产环境

  • TEST 测试环境

约束限制

不涉及

取值范围:

  • PROD

  • TEST

默认值

不涉及

output_table_id

String

UUID

output_table_ids

Array of strings

输出表ID列表

output_table_names

Array of strings

输出表名称列表

表4 IsapJobModeSettingDto

参数

是否必选

参数类型

描述

batch_overtime_interval

Integer

整型间隔时长

batch_overtime_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

batch_frequency_interval

Integer

整型间隔时长

batch_frequency_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

streaming_state_ttl_interval

Integer

整型间隔时长

streaming_state_ttl_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

streaming_checkpoint_ttl_interval

Integer

整型间隔时长

streaming_checkpoint_ttl_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

streaming_startup_mode

String

参数解释:

作业启动模式

  • UPGRADE 升级启动

  • REFRESH_NEW 全新启动

约束限制

不涉及

取值范围:

  • UPGRADE

  • REFRESH_NEW

默认值

不涉及

batch_overtime_strategy_interval

Integer

整型间隔时长

batch_overtime_strategy_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

search_delay_interval

Integer

整型间隔时长

search_delay_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

search_frequency_interval

Integer

整型间隔时长

search_frequency_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

search_overtime_interval

Integer

整型间隔时长

search_overtime_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

search_period_interval

Integer

整型间隔时长

search_period_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

search_table_id

String

UUID

search_table_name

String

表名称

field_not_null_policy

String

参数解释:

作业表非空字段处理策略

LOOSE 宽松

STRICT 严格

约束限制

不涉及

取值范围:

LOOSE

STRICT

默认值

LOOSE

dss_id

Integer

长整型间隔时长

响应参数

状态码:200

表5 响应Body参数

参数

参数类型

描述

data_transformation_id

String

UUID

data_transformation_name

String

数据转换名称

script

String

Job Script 作业脚本

status

String

参数解释:

作业状态

  • ENABLED 启用

  • DISABLED 禁用

约束限制

不涉及

取值范围:

  • ENABLED

  • DISABLED

默认值

不涉及

directory

String

directory 目录分组

description

String

数据转换描述

job_mode

String

参数解释:

作业模式

  • STREAMING 流式处理

  • BATCH 批处理

  • SEARCH 检索

约束限制

不涉及

取值范围:

  • STREAMING

  • BATCH

  • SEARCH

默认值

不涉及

job_mode_setting

IsapJobModeSettingVo object

作业模式设置

process_status

String

参数解释:

作业处理状态

  • COMPLETED 已完成

  • CREATING 创建中

  • UPDATING 更新中

  • ENABLING 启用中

  • DISABLING 停用中

  • DELETING 删除中

  • CREATE_FAILED 创建失败

  • UPDATE_FAILED 更新失败

  • ENABLE_FAILED 启用失败

  • DISABLE_FAILED 停用失败

  • DELETE_FAILED 删除失败

  • RECOVERING 恢复中

约束限制

不涉及

取值范围:

  • COMPLETED

  • CREATING

  • UPDATING

  • ENABLING

  • DISABLING

  • DELETING

  • CREATE_FAILED

  • UPDATE_FAILED

  • ENABLE_FAILED

  • DISABLE_FAILED

  • DELETE_FAILED

  • RECOVERING

默认值

不涉及

process_error

String

参数解释:

数据加工处理错误

  • NONE 无

约束限制

不涉及

取值范围:

  • NONE

默认值

不涉及

environment

String

参数解释:

环境类型

  • PROD 生产环境

  • TEST 测试环境

约束限制

不涉及

取值范围:

  • PROD

  • TEST

默认值

不涉及

output_table_id

String

UUID

output_table_name

String

表名称

output_table_ids

Array of strings

输出表ID列表

output_table_names

Array of strings

输出表名称列表

create_by

String

创建者

create_time

Integer

毫秒时间戳

update_by

String

更新者

update_time

Integer

毫秒时间戳

delete_time

Integer

毫秒时间戳

表6 IsapJobModeSettingVo

参数

参数类型

描述

batch_overtime_interval

Integer

整型间隔时长

batch_overtime_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

batch_frequency_interval

Integer

整型间隔时长

batch_frequency_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

streaming_state_ttl_interval

Integer

整型间隔时长

streaming_state_ttl_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

streaming_checkpoint_ttl_interval

Integer

整型间隔时长

streaming_checkpoint_ttl_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

streaming_startup_mode

String

参数解释:

作业启动模式

  • UPGRADE 升级启动

  • REFRESH_NEW 全新启动

约束限制

不涉及

取值范围:

  • UPGRADE

  • REFRESH_NEW

默认值

不涉及

batch_overtime_strategy_interval

Integer

整型间隔时长

batch_overtime_strategy_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

search_delay_interval

Integer

整型间隔时长

search_delay_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

search_frequency_interval

Integer

整型间隔时长

search_frequency_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

search_overtime_interval

Integer

整型间隔时长

search_overtime_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

search_period_interval

Integer

整型间隔时长

search_period_unit

String

参数解释:

时间单位

  • MINUTE 分钟

  • HOUR 小时

  • DAY 天

  • MONTH 月

约束限制

不涉及

取值范围:

  • MINUTE

  • HOUR

  • DAY

  • MONTH

默认值

不涉及

search_table_id

String

UUID

search_table_name

String

表名称

field_not_null_policy

String

参数解释:

作业表非空字段处理策略

LOOSE 宽松

STRICT 严格

约束限制

不涉及

取值范围:

LOOSE

STRICT

默认值

LOOSE

请求示例

更新数据加工作业

https://{endpoint}//v2/{project_id}/workspaces/{workspace_id}/siem/data-transformations/{data_transformation_id}

{
  "data_transformation_name" : "job_liubiao_test6",
  "script" : "SELECT * FROM s_sec_test;",
  "status" : "DISABLED",
  "directory" : "",
  "description" : "test",
  "belong" : "SYSTEM",
  "environment" : "PROD",
  "cu_quota_amount" : 1,
  "output_table_ids" : [ "2a750856-48b9-4628-b892-1281febc54f5" ],
  "output_table_names" : [ "s_sec_mudi_6" ],
  "job_mode" : "STREAMING",
  "job_mode_setting" : {
    "streaming_state_ttl_interval" : 10,
    "streaming_state_ttl_unit" : "MINUTE",
    "streaming_checkpoint_ttl_interval" : 10,
    "streaming_checkpoint_ttl_unit" : "MINUTE",
    "streaming_startup_mode" : "REFRESH_NEW"
  }
}

响应示例

状态码:200

成功

{
  "create_by" : "test_account",
  "create_time" : 1726822643601,
  "delete_time" : 0,
  "description" : "test",
  "directory" : "",
  "environment" : "PROD",
  "job_mode" : "STREAMING",
  "job_mode_setting" : {
    "field_not_null_policy" : "LOOSE",
    "streaming_checkpoint_ttl_interval" : 10,
    "streaming_checkpoint_ttl_unit" : "MINUTE",
    "streaming_startup_mode" : "REFRESH_NEW",
    "streaming_state_ttl_interval" : 10,
    "streaming_state_ttl_unit" : "MINUTE"
  },
  "output_table_ids" : [ "2a750856-48b9-4628-b892-1281febc54f5" ],
  "output_table_names" : [ "s_sec_mudi_6" ],
  "process_error" : "NONE",
  "process_status" : "UPDATING",
  "script" : "SELECT * FROM s_sec_test;",
  "status" : "DISABLED",
  "update_by" : "test_user",
  "update_time" : 1768293934298
}

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
package com.huaweicloud.sdk.test;

import com.huaweicloud.sdk.core.auth.ICredential;
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.secmaster.v2.region.SecMasterRegion;
import com.huaweicloud.sdk.secmaster.v2.*;
import com.huaweicloud.sdk.secmaster.v2.model.*;


public class UpdateDataTransformationSolution {

    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");
        String projectId = "{project_id}";

        ICredential auth = new BasicCredentials()
                .withProjectId(projectId)
                .withAk(ak)
                .withSk(sk);

        SecMasterClient client = SecMasterClient.newBuilder()
                .withCredential(auth)
                .withRegion(SecMasterRegion.valueOf("<YOUR REGION>"))
                .build();
        UpdateDataTransformationRequest request = new UpdateDataTransformationRequest();
        request.withWorkspaceId("{workspace_id}");
        request.withDataTransformationId("{data_transformation_id}");
        try {
            UpdateDataTransformationResponse response = client.updateDataTransformation(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
# coding: utf-8

import os
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdksecmaster.v2.region.secmaster_region import SecMasterRegion
from huaweicloudsdkcore.exceptions import exceptions
from huaweicloudsdksecmaster.v2 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"]
    projectId = "{project_id}"

    credentials = BasicCredentials(ak, sk, projectId)

    client = SecMasterClient.new_builder() \
        .with_credentials(credentials) \
        .with_region(SecMasterRegion.value_of("<YOUR REGION>")) \
        .build()

    try:
        request = UpdateDataTransformationRequest()
        request.workspace_id = "{workspace_id}"
        request.data_transformation_id = "{data_transformation_id}"
        response = client.update_data_transformation(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
package main

import (
	"fmt"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
    secmaster "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/secmaster/v2"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/secmaster/v2/model"
    region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/secmaster/v2/region"
)

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")
    projectId := "{project_id}"

    auth := basic.NewCredentialsBuilder().
        WithAk(ak).
        WithSk(sk).
        WithProjectId(projectId).
        Build()

    client := secmaster.NewSecMasterClient(
        secmaster.SecMasterClientBuilder().
            WithRegion(region.ValueOf("<YOUR REGION>")).
            WithCredential(auth).
            Build())

    request := &model.UpdateDataTransformationRequest{}
	request.WorkspaceId = "{workspace_id}"
	request.DataTransformationId = "{data_transformation_id}"
	response, err := client.UpdateDataTransformation(request)
	if err == nil {
        fmt.Printf("%+v\n", response)
    } else {
        fmt.Println(err)
    }
}

更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。

状态码

状态码

描述

200

成功

错误码

请参见错误码

相关文档