Updating a Pipeline
Function
This API is used to update a pipeline.
Calling Method
For details, see Calling APIs.
URI
PUT /v2/{project_id}/workspaces/{workspace_id}/siem/pipes/{pipe_id}
|
Parameter |
Mandatory |
Type |
Description |
|---|---|---|---|
|
project_id |
Yes |
String |
Definition Project ID, which is used to specify the project that a resource belongs to. You can query the resources of a project by project ID. You can obtain the project ID from the API or console. Obtaining the Project ID Constraints N/A Range N/A Default Value N/A |
|
workspace_id |
Yes |
String |
Workspace ID. |
|
pipe_id |
Yes |
String |
Pipeline ID. |
Request Parameters
|
Parameter |
Mandatory |
Type |
Description |
|---|---|---|---|
|
X-Auth-Token |
Yes |
String |
Definition User token. You can obtain it by calling the IAM API for obtaining a user token. The user token is the value of X-Subject-Token in the response header. Obtaining a User Token Constraints N/A Range N/A Default Value N/A |
|
Parameter |
Mandatory |
Type |
Description |
|---|---|---|---|
|
pipe_alias |
No |
String |
Pipeline alias. |
|
description |
No |
String |
Pipeline description. |
|
directory |
No |
String |
Directory group. |
|
category |
No |
String |
Definition Pipeline directory. Constraints N/A Range Default Value N/A |
Response Parameters
Status code: 200
|
Parameter |
Type |
Description |
|---|---|---|
|
project_id |
String |
Project ID. |
|
workspace_id |
String |
UUID |
|
pipe_id |
String |
UUID |
|
pipe_name |
String |
Pipeline name. |
|
pipe_alias |
String |
Pipeline alias. |
|
category |
String |
Definition Pipeline directory. Constraints N/A Range Default Value N/A |
|
directory |
String |
Directory group. |
|
description |
String |
Pipeline description. |
|
process_status |
String |
Definition Job processing status. Constraints N/A Range Default Value N/A |
|
process_error |
String |
Definition Pipeline processing error. Constraints N/A Range Default Value N/A |
|
owner_type |
String |
Definition Pipeline owner type. Constraints N/A Range Default Value N/A |
|
resources |
Array of PipeResource objects |
Pipeline resource. |
|
schema |
PipeSchema object |
Pipeline mode. |
|
create_time |
Integer |
Timestamp, in ms. |
|
update_time |
Integer |
Timestamp, in ms. |
|
delete_time |
Integer |
Timestamp, in ms. |
|
Parameter |
Type |
Description |
|---|---|---|
|
columns |
Array of TableColumnForIsapPipe objects |
Pipeline column. |
|
watermark_column |
String |
Pipeline watermark column. |
|
watermark_interval |
Float |
Pipeline watermark interval. |
|
time_filter |
String |
Pipeline filtering column. |
|
Parameter |
Type |
Description |
|---|---|---|
|
column_name |
String |
Table column name. |
|
column_data_type |
String |
Definition Column data type. Constraints N/A Range Default Value N/A |
|
column_data_type_setting |
String |
Column data type settings. |
|
column_type |
String |
Definition Column field type. Constraints N/A Range Default Value N/A |
|
column_type_setting |
String |
Column type settings. |
|
default_value |
String |
Default value of a column. |
|
nullable |
Boolean |
Whether a column can be empty. |
|
array |
Boolean |
Array or not. |
|
depth |
Long |
Column depth. |
|
parent_name |
String |
Column name. |
|
own_name |
String |
Column name. |
Example Requests
Update the pipeline description.
https://{endpoint}//v2/{project_id}/workspaces/{workspace_id}/siem/pipes/{pipe_id}
{
"description" : "test_description"
}
Example Responses
Status code: 200
Request succeeded.
{
"category" : "STREAMING_TO_INDEX",
"create_time" : 1754998254580,
"delete_time" : 0,
"description" : "test",
"directory" : "",
"owner_type" : "USER",
"pipe_alias" : "test",
"pipe_id" : "7bdb801d-a761-451e-97bb-5c1d172ee442",
"pipe_name" : "cp1_0812",
"process_error" : "NONE",
"process_status" : "COMPLETED",
"project_id" : "c796dfc5f1644915ae072b7642a2cd93",
"resources" : [ ],
"schema" : {
"columns" : [ {
"array" : false,
"column_data_type" : "TIMESTAMP",
"column_data_type_setting" : "3",
"column_name" : "ctime",
"column_type" : "PHYSICAL",
"column_type_setting" : "",
"depth" : 0,
"nullable" : true,
"own_name" : "ctime",
"parent_name" : ""
}, {
"array" : false,
"column_data_type" : "INT",
"column_data_type_setting" : "",
"column_name" : "age",
"column_type" : "PHYSICAL",
"column_type_setting" : "",
"depth" : 0,
"nullable" : true,
"own_name" : "age",
"parent_name" : ""
} ],
"time_filter" : "ctime",
"watermark_column" : "ctime",
"watermark_interval" : 5
},
"update_time" : 1768383374003,
"workspace_id" : "5317af6c-aea0-4bd2-bd6b-08de5fd3b155"
}
SDK Sample Code
The SDK sample code is as follows.
Update the pipeline description.
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 |
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 UpdatePipeSolution { 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(); UpdatePipeRequest request = new UpdatePipeRequest(); request.withWorkspaceId("{workspace_id}"); request.withPipeId("{pipe_id}"); UpdatePipeRequestBody body = new UpdatePipeRequestBody(); body.withDescription("test_description"); request.withBody(body); try { UpdatePipeResponse response = client.updatePipe(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()); } } } |
Update the pipeline description.
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 |
# 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 = UpdatePipeRequest() request.workspace_id = "{workspace_id}" request.pipe_id = "{pipe_id}" request.body = UpdatePipeRequestBody( description="test_description" ) response = client.update_pipe(request) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) |
Update the pipeline description.
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 |
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.UpdatePipeRequest{} request.WorkspaceId = "{workspace_id}" request.PipeId = "{pipe_id}" descriptionUpdatePipeRequestBody:= "test_description" request.Body = &model.UpdatePipeRequestBody{ Description: &descriptionUpdatePipeRequestBody, } response, err := client.UpdatePipe(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } |
For SDK sample code of more programming languages, see the Sample Code tab in API Explorer. SDK sample code can be automatically generated.
Status Codes
|
Status Code |
Description |
|---|---|
|
200 |
Request succeeded. |
Error Codes
See Error Codes.
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.
For any further questions, feel free to contact us through the chatbot.
Chatbot