Update Pipe

eventbridgepipes_update_pipe

R Documentation

Update an existing pipe

Description

Update an existing pipe. When you call update_pipe, EventBridge only the updates fields you have specified in the request; the rest remain unchanged. The exception to this is if you modify any Amazon Web Services-service specific fields in the SourceParameters, EnrichmentParameters, or TargetParameters objects. For example, DynamoDBStreamParameters or EventBridgeEventBusParameters. EventBridge updates the fields in these objects atomically as one and overrides existing values. This is by design, and means that if you don't specify an optional field in one of these Parameters objects, EventBridge sets that field to its system-default value during the update.

For more information about pipes, see Amazon EventBridge Pipes in the Amazon EventBridge User Guide.

Usage

eventbridgepipes_update_pipe(Name, Description, DesiredState,
  SourceParameters, Enrichment, EnrichmentParameters, Target,
  TargetParameters, RoleArn, LogConfiguration, KmsKeyIdentifier)

Arguments

Name

[required] The name of the pipe.

Description

A description of the pipe.

DesiredState

The state the pipe should be in.

SourceParameters

The parameters required to set up a source for your pipe.

Enrichment

The ARN of the enrichment resource.

EnrichmentParameters

The parameters required to set up enrichment on your pipe.

Target

The ARN of the target resource.

TargetParameters

The parameters required to set up a target for your pipe.

For more information about pipe target parameters, including how to use dynamic path parameters, see Target parameters in the Amazon EventBridge User Guide.

RoleArn

[required] The ARN of the role that allows the pipe to send data to the target.

LogConfiguration

The logging configuration settings for the pipe.

KmsKeyIdentifier

The identifier of the KMS customer managed key for EventBridge to use, if you choose to use a customer managed key to encrypt pipe data. The identifier can be the key Amazon Resource Name (ARN), KeyId, key alias, or key alias ARN.

To update a pipe that is using the default Amazon Web Services owned key to use a customer managed key instead, or update a pipe that is using a customer managed key to use a different customer managed key, specify a customer managed key identifier.

To update a pipe that is using a customer managed key to use the default Amazon Web Services owned key, specify an empty string.

For more information, see Managing keys in the Key Management Service Developer Guide.

Value

A list with the following syntax:

list(
  Arn = "string",
  Name = "string",
  DesiredState = "RUNNING"|"STOPPED",
  CurrentState = "RUNNING"|"STOPPED"|"CREATING"|"UPDATING"|"DELETING"|"STARTING"|"STOPPING"|"CREATE_FAILED"|"UPDATE_FAILED"|"START_FAILED"|"STOP_FAILED"|"DELETE_FAILED"|"CREATE_ROLLBACK_FAILED"|"DELETE_ROLLBACK_FAILED"|"UPDATE_ROLLBACK_FAILED",
  CreationTime = as.POSIXct(
    "2015-01-01"
  ),
  LastModifiedTime = as.POSIXct(
    "2015-01-01"
  )
)

Request syntax

svc$update_pipe(
  Name = "string",
  Description = "string",
  DesiredState = "RUNNING"|"STOPPED",
  SourceParameters = list(
    FilterCriteria = list(
      Filters = list(
        list(
          Pattern = "string"
        )
      )
    ),
    KinesisStreamParameters = list(
      BatchSize = 123,
      DeadLetterConfig = list(
        Arn = "string"
      ),
      OnPartialBatchItemFailure = "AUTOMATIC_BISECT",
      MaximumBatchingWindowInSeconds = 123,
      MaximumRecordAgeInSeconds = 123,
      MaximumRetryAttempts = 123,
      ParallelizationFactor = 123
    ),
    DynamoDBStreamParameters = list(
      BatchSize = 123,
      DeadLetterConfig = list(
        Arn = "string"
      ),
      OnPartialBatchItemFailure = "AUTOMATIC_BISECT",
      MaximumBatchingWindowInSeconds = 123,
      MaximumRecordAgeInSeconds = 123,
      MaximumRetryAttempts = 123,
      ParallelizationFactor = 123
    ),
    SqsQueueParameters = list(
      BatchSize = 123,
      MaximumBatchingWindowInSeconds = 123
    ),
    ActiveMQBrokerParameters = list(
      Credentials = list(
        BasicAuth = "string"
      ),
      BatchSize = 123,
      MaximumBatchingWindowInSeconds = 123
    ),
    RabbitMQBrokerParameters = list(
      Credentials = list(
        BasicAuth = "string"
      ),
      BatchSize = 123,
      MaximumBatchingWindowInSeconds = 123
    ),
    ManagedStreamingKafkaParameters = list(
      BatchSize = 123,
      Credentials = list(
        SaslScram512Auth = "string",
        ClientCertificateTlsAuth = "string"
      ),
      MaximumBatchingWindowInSeconds = 123
    ),
    SelfManagedKafkaParameters = list(
      BatchSize = 123,
      MaximumBatchingWindowInSeconds = 123,
      Credentials = list(
        BasicAuth = "string",
        SaslScram512Auth = "string",
        SaslScram256Auth = "string",
        ClientCertificateTlsAuth = "string"
      ),
      ServerRootCaCertificate = "string",
      Vpc = list(
        Subnets = list(
          "string"
        ),
        SecurityGroup = list(
          "string"
        )
      )
    )
  ),
  Enrichment = "string",
  EnrichmentParameters = list(
    InputTemplate = "string",
    HttpParameters = list(
      PathParameterValues = list(
        "string"
      ),
      HeaderParameters = list(
        "string"
      ),
      QueryStringParameters = list(
        "string"
      )
    )
  ),
  Target = "string",
  TargetParameters = list(
    InputTemplate = "string",
    LambdaFunctionParameters = list(
      InvocationType = "REQUEST_RESPONSE"|"FIRE_AND_FORGET"
    ),
    StepFunctionStateMachineParameters = list(
      InvocationType = "REQUEST_RESPONSE"|"FIRE_AND_FORGET"
    ),
    KinesisStreamParameters = list(
      PartitionKey = "string"
    ),
    EcsTaskParameters = list(
      TaskDefinitionArn = "string",
      TaskCount = 123,
      LaunchType = "EC2"|"FARGATE"|"EXTERNAL",
      NetworkConfiguration = list(
        awsvpcConfiguration = list(
          Subnets = list(
            "string"
          ),
          SecurityGroups = list(
            "string"
          ),
          AssignPublicIp = "ENABLED"|"DISABLED"
        )
      ),
      PlatformVersion = "string",
      Group = "string",
      CapacityProviderStrategy = list(
        list(
          capacityProvider = "string",
          weight = 123,
          base = 123
        )
      ),
      EnableECSManagedTags = TRUE|FALSE,
      EnableExecuteCommand = TRUE|FALSE,
      PlacementConstraints = list(
        list(
          type = "distinctInstance"|"memberOf",
          expression = "string"
        )
      ),
      PlacementStrategy = list(
        list(
          type = "random"|"spread"|"binpack",
          field = "string"
        )
      ),
      PropagateTags = "TASK_DEFINITION",
      ReferenceId = "string",
      Overrides = list(
        ContainerOverrides = list(
          list(
            Command = list(
              "string"
            ),
            Cpu = 123,
            Environment = list(
              list(
                name = "string",
                value = "string"
              )
            ),
            EnvironmentFiles = list(
              list(
                type = "s3",
                value = "string"
              )
            ),
            Memory = 123,
            MemoryReservation = 123,
            Name = "string",
            ResourceRequirements = list(
              list(
                type = "GPU"|"InferenceAccelerator",
                value = "string"
              )
            )
          )
        ),
        Cpu = "string",
        EphemeralStorage = list(
          sizeInGiB = 123
        ),
        ExecutionRoleArn = "string",
        InferenceAcceleratorOverrides = list(
          list(
            deviceName = "string",
            deviceType = "string"
          )
        ),
        Memory = "string",
        TaskRoleArn = "string"
      ),
      Tags = list(
        list(
          Key = "string",
          Value = "string"
        )
      )
    ),
    BatchJobParameters = list(
      JobDefinition = "string",
      JobName = "string",
      ArrayProperties = list(
        Size = 123
      ),
      RetryStrategy = list(
        Attempts = 123
      ),
      ContainerOverrides = list(
        Command = list(
          "string"
        ),
        Environment = list(
          list(
            Name = "string",
            Value = "string"
          )
        ),
        InstanceType = "string",
        ResourceRequirements = list(
          list(
            Type = "GPU"|"MEMORY"|"VCPU",
            Value = "string"
          )
        )
      ),
      DependsOn = list(
        list(
          JobId = "string",
          Type = "N_TO_N"|"SEQUENTIAL"
        )
      ),
      Parameters = list(
        "string"
      )
    ),
    SqsQueueParameters = list(
      MessageGroupId = "string",
      MessageDeduplicationId = "string"
    ),
    HttpParameters = list(
      PathParameterValues = list(
        "string"
      ),
      HeaderParameters = list(
        "string"
      ),
      QueryStringParameters = list(
        "string"
      )
    ),
    RedshiftDataParameters = list(
      SecretManagerArn = "string",
      Database = "string",
      DbUser = "string",
      StatementName = "string",
      WithEvent = TRUE|FALSE,
      Sqls = list(
        "string"
      )
    ),
    SageMakerPipelineParameters = list(
      PipelineParameterList = list(
        list(
          Name = "string",
          Value = "string"
        )
      )
    ),
    EventBridgeEventBusParameters = list(
      EndpointId = "string",
      DetailType = "string",
      Source = "string",
      Resources = list(
        "string"
      ),
      Time = "string"
    ),
    CloudWatchLogsParameters = list(
      LogStreamName = "string",
      Timestamp = "string"
    ),
    TimestreamParameters = list(
      TimeValue = "string",
      EpochTimeUnit = "MILLISECONDS"|"SECONDS"|"MICROSECONDS"|"NANOSECONDS",
      TimeFieldType = "EPOCH"|"TIMESTAMP_FORMAT",
      TimestampFormat = "string",
      VersionValue = "string",
      DimensionMappings = list(
        list(
          DimensionValue = "string",
          DimensionValueType = "VARCHAR",
          DimensionName = "string"
        )
      ),
      SingleMeasureMappings = list(
        list(
          MeasureValue = "string",
          MeasureValueType = "DOUBLE"|"BIGINT"|"VARCHAR"|"BOOLEAN"|"TIMESTAMP",
          MeasureName = "string"
        )
      ),
      MultiMeasureMappings = list(
        list(
          MultiMeasureName = "string",
          MultiMeasureAttributeMappings = list(
            list(
              MeasureValue = "string",
              MeasureValueType = "DOUBLE"|"BIGINT"|"VARCHAR"|"BOOLEAN"|"TIMESTAMP",
              MultiMeasureAttributeName = "string"
            )
          )
        )
      )
    )
  ),
  RoleArn = "string",
  LogConfiguration = list(
    S3LogDestination = list(
      BucketName = "string",
      BucketOwner = "string",
      OutputFormat = "json"|"plain"|"w3c",
      Prefix = "string"
    ),
    FirehoseLogDestination = list(
      DeliveryStreamArn = "string"
    ),
    CloudwatchLogsLogDestination = list(
      LogGroupArn = "string"
    ),
    Level = "OFF"|"ERROR"|"INFO"|"TRACE",
    IncludeExecutionData = list(
      "ALL"
    )
  ),
  KmsKeyIdentifier = "string"
)