Update Pipeline

opensearchingestion_update_pipeline

R Documentation

Updates an OpenSearch Ingestion pipeline

Description

Updates an OpenSearch Ingestion pipeline. For more information, see Updating Amazon OpenSearch Ingestion pipelines.

Usage

opensearchingestion_update_pipeline(PipelineName, MinUnits, MaxUnits,
  PipelineConfigurationBody, LogPublishingOptions, BufferOptions,
  EncryptionAtRestOptions)

Arguments

PipelineName	[required] The name of the pipeline to update.
MinUnits	The minimum pipeline capacity, in Ingestion Compute Units (ICUs).
MaxUnits	The maximum pipeline capacity, in Ingestion Compute Units (ICUs)
PipelineConfigurationBody	The pipeline configuration in YAML format. The command accepts the pipeline configuration as a string or within a .yaml file. If you provide the configuration as a string, each new line must be escaped with ⁠\\n⁠.
LogPublishingOptions	Key-value pairs to configure log publishing.
BufferOptions	Key-value pairs to configure persistent buffering for the pipeline.
EncryptionAtRestOptions	Key-value pairs to configure encryption for data that is written to a persistent buffer.

Value

A list with the following syntax:

list(
  Pipeline = list(
    PipelineName = "string",
    PipelineArn = "string",
    MinUnits = 123,
    MaxUnits = 123,
    Status = "CREATING"|"ACTIVE"|"UPDATING"|"DELETING"|"CREATE_FAILED"|"UPDATE_FAILED"|"STARTING"|"START_FAILED"|"STOPPING"|"STOPPED",
    StatusReason = list(
      Description = "string"
    ),
    PipelineConfigurationBody = "string",
    CreatedAt = as.POSIXct(
      "2015-01-01"
    ),
    LastUpdatedAt = as.POSIXct(
      "2015-01-01"
    ),
    IngestEndpointUrls = list(
      "string"
    ),
    LogPublishingOptions = list(
      IsLoggingEnabled = TRUE|FALSE,
      CloudWatchLogDestination = list(
        LogGroup = "string"
      )
    ),
    VpcEndpoints = list(
      list(
        VpcEndpointId = "string",
        VpcId = "string",
        VpcOptions = list(
          SubnetIds = list(
            "string"
          ),
          SecurityGroupIds = list(
            "string"
          ),
          VpcAttachmentOptions = list(
            AttachToVpc = TRUE|FALSE,
            CidrBlock = "string"
          ),
          VpcEndpointManagement = "CUSTOMER"|"SERVICE"
        )
      )
    ),
    BufferOptions = list(
      PersistentBufferEnabled = TRUE|FALSE
    ),
    EncryptionAtRestOptions = list(
      KmsKeyArn = "string"
    ),
    VpcEndpointService = "string",
    ServiceVpcEndpoints = list(
      list(
        ServiceName = "OPENSEARCH_SERVERLESS",
        VpcEndpointId = "string"
      )
    ),
    Destinations = list(
      list(
        ServiceName = "string",
        Endpoint = "string"
      )
    ),
    Tags = list(
      list(
        Key = "string",
        Value = "string"
      )
    )
  )
)

Request syntax

svc$update_pipeline(
  PipelineName = "string",
  MinUnits = 123,
  MaxUnits = 123,
  PipelineConfigurationBody = "string",
  LogPublishingOptions = list(
    IsLoggingEnabled = TRUE|FALSE,
    CloudWatchLogDestination = list(
      LogGroup = "string"
    )
  ),
  BufferOptions = list(
    PersistentBufferEnabled = TRUE|FALSE
  ),
  EncryptionAtRestOptions = list(
    KmsKeyArn = "string"
  )
)