Pipe

pipes.services.k8s.aws/v1alpha1

Metadata#

An object that represents a pipe. Amazon EventBridgePipes connect event sources to targets and reduces the need for specialized knowledge and integration code.

Spec#

description: string
desiredState: string
enrichment: string
enrichmentParameters: 
  httpParameters: 
    headerParameters: {}
    pathParameterValues:
    - string
    queryStringParameters: {}
  inputTemplate: string
name: string
roleARN: string
source: string
sourceParameters: 
  activeMQBrokerParameters: 
    batchSize: integer
    credentials: 
      basicAuth: string
    maximumBatchingWindowInSeconds: integer
    queueName: string
  dynamoDBStreamParameters: 
    batchSize: integer
    deadLetterConfig: 
      arn: string
    maximumBatchingWindowInSeconds: integer
    maximumRecordAgeInSeconds: integer
    maximumRetryAttempts: integer
    onPartialBatchItemFailure: string
    parallelizationFactor: integer
    startingPosition: string
  filterCriteria: 
    filters:
    - pattern: string
  kinesisStreamParameters: 
    batchSize: integer
    deadLetterConfig: 
      arn: string
    maximumBatchingWindowInSeconds: integer
    maximumRecordAgeInSeconds: integer
    maximumRetryAttempts: integer
    onPartialBatchItemFailure: string
    parallelizationFactor: integer
    startingPosition: string
    startingPositionTimestamp: string
  managedStreamingKafkaParameters: 
    batchSize: integer
    consumerGroupID: string
    credentials: 
      clientCertificateTLSAuth: string
      saslSCRAM512Auth: string
    maximumBatchingWindowInSeconds: integer
    startingPosition: string
    topicName: string
  rabbitMQBrokerParameters: 
    batchSize: integer
    credentials: 
      basicAuth: string
    maximumBatchingWindowInSeconds: integer
    queueName: string
    virtualHost: string
  selfManagedKafkaParameters: 
    additionalBootstrapServers:
    - string
    batchSize: integer
    consumerGroupID: string
    credentials: 
      basicAuth: string
      clientCertificateTLSAuth: string
      saslSCRAM256Auth: string
      saslSCRAM512Auth: string
    maximumBatchingWindowInSeconds: integer
    serverRootCaCertificate: string
    startingPosition: string
    topicName: string
    vpc: 
      securityGroup:
      - string
      subnets:
      - string
  sqsQueueParameters: 
    batchSize: integer
    maximumBatchingWindowInSeconds: integer
tags: {}
target: string
targetParameters: 
  batchJobParameters: 
    arrayProperties: 
      size: integer
    containerOverrides: 
      command:
      - string
      environment:
      - name: string
        value: string
      instanceType: string
      resourceRequirements:
      - type_: string
        value: string
    dependsOn:
    - jobID: string
      type_: string
    jobDefinition: string
    jobName: string
    parameters: {}
    retryStrategy: 
      attempts: integer
  cloudWatchLogsParameters: 
    logStreamName: string
    timestamp: string
  ecsTaskParameters: 
    capacityProviderStrategy:
    - base: integer
      capacityProvider: string
      weight: integer
    enableECSManagedTags: boolean
    enableExecuteCommand: boolean
    group: string
    launchType: string
    networkConfiguration: 
      awsVPCConfiguration: 
        assignPublicIP: string
        securityGroups:
        - string
        subnets:
        - string
    overrides: 
      containerOverrides:
        command:
        - string
        cpu: integer
        environment:
        - name: string
          value: string
        environmentFiles:
        - type_: string
          value: string
        memory: integer
        memoryReservation: integer
        name: string
        resourceRequirements:
        - type_: string
          value: string
      cpu: string
      ephemeralStorage: 
        sizeInGiB: integer
      executionRoleARN: string
      inferenceAcceleratorOverrides:
      - deviceName: string
        deviceType: string
      memory: string
      taskRoleARN: string
    placementConstraints:
    - expression: string
      type_: string
    placementStrategy:
    - field: string
      type_: string
    platformVersion: string
    propagateTags: string
    referenceID: string
    tags:
    - key: string
      value: string
    taskCount: integer
    taskDefinitionARN: string
  eventBridgeEventBusParameters: 
    detailType: string
    endpointID: string
    resources:
    - string
    source: string
    time: string
  httpParameters: 
    headerParameters: {}
    pathParameterValues:
    - string
    queryStringParameters: {}
  inputTemplate: string
  kinesisStreamParameters: 
    partitionKey: string
  lambdaFunctionParameters: 
    invocationType: string
  redshiftDataParameters: 
    database: string
    dbUser: string
    secretManagerARN: string
    sqls:
    - string
    statementName: string
    withEvent: boolean
  sageMakerPipelineParameters: 
    pipelineParameterList:
    - name: string
      value: string
  sqsQueueParameters: 
    messageDeduplicationID: string
    messageGroupID: string
  stepFunctionStateMachineParameters: 
    invocationType: string

• Linux platform version 1.4.0 or later.
• Windows platform version 1.0.0 or later. || **targetParameters.ecsTaskParameters.overrides.containerOverrides.[].environmentFiles.[].type_**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.overrides.containerOverrides.[].environmentFiles.[].value**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.overrides.containerOverrides.[].memory**
  Optional | **integer**
  | | **targetParameters.ecsTaskParameters.overrides.containerOverrides.[].memoryReservation**
  Optional | **integer**
  | | **targetParameters.ecsTaskParameters.overrides.containerOverrides.[].name**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.overrides.containerOverrides.[].resourceRequirements**
  Optional | **array**
  | | **targetParameters.ecsTaskParameters.overrides.containerOverrides.[].resourceRequirements.[]**
  Required | **object**
  The type and amount of a resource to assign to a container. The supported resource types are GPUs and Elastic Inference accelerators. For more information, see Working with GPUs on Amazon ECS (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/ecs-gpu.html) or Working with Amazon Elastic Inference on Amazon ECS (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/ecs-inference.html) in the Amazon Elastic Container Service Developer Guide || **targetParameters.ecsTaskParameters.overrides.containerOverrides.[].resourceRequirements.[].type_**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.overrides.containerOverrides.[].resourceRequirements.[].value**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.overrides.cpu**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.overrides.ephemeralStorage**
  Optional | **object**
  The amount of ephemeral storage to allocate for the task. This parameter is used to expand the total amount of ephemeral storage available, beyond the default amount, for tasks hosted on Fargate. For more information, see Fargate task storage (https://docs.aws.amazon.com/AmazonECS/latest/userguide/using_data_volumes.html) in the Amazon ECS User Guide for Fargate.
  This parameter is only supported for tasks hosted on Fargate using Linux platform version 1.4.0 or later. This parameter is not supported for Windows containers on Fargate. | | **targetParameters.ecsTaskParameters.overrides.ephemeralStorage.sizeInGiB**
  Optional | **integer**
  | | **targetParameters.ecsTaskParameters.overrides.executionRoleARN**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.overrides.inferenceAcceleratorOverrides**
  Optional | **array**
  | | **targetParameters.ecsTaskParameters.overrides.inferenceAcceleratorOverrides.[]**
  Required | **object**
  Details on an Elastic Inference accelerator task override. This parameter is used to override the Elastic Inference accelerator specified in the task definition. For more information, see Working with Amazon Elastic Inference on Amazon ECS (https://docs.aws.amazon.com/AmazonECS/latest/userguide/ecs-inference.html) in the Amazon Elastic Container Service Developer Guide. || **targetParameters.ecsTaskParameters.overrides.inferenceAcceleratorOverrides.[].deviceName**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.overrides.inferenceAcceleratorOverrides.[].deviceType**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.overrides.memory**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.overrides.taskRoleARN**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.placementConstraints**
  Optional | **array**
  | | **targetParameters.ecsTaskParameters.placementConstraints.[]**
  Required | **object**
  An object representing a constraint on task placement. To learn more, see Task Placement Constraints (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/task-placement-constraints.html) in the Amazon Elastic Container Service Developer Guide. || **targetParameters.ecsTaskParameters.placementConstraints.[].expression**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.placementConstraints.[].type_**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.placementStrategy**
  Optional | **array**
  | | **targetParameters.ecsTaskParameters.placementStrategy.[]**
  Required | **object**
  The task placement strategy for a task or service. To learn more, see Task Placement Strategies (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/task-placement-strategies.html) in the Amazon Elastic Container Service Service Developer Guide. || **targetParameters.ecsTaskParameters.placementStrategy.[].field**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.placementStrategy.[].type_**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.platformVersion**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.propagateTags**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.referenceID**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.tags**
  Optional | **array**
  | | **targetParameters.ecsTaskParameters.tags.[]**
  Required | **object**
  A key-value pair associated with an Amazon Web Services resource. In EventBridge, rules and event buses support tagging. || **targetParameters.ecsTaskParameters.tags.[].key**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.tags.[].value**
  Optional | **string**
  | | **targetParameters.ecsTaskParameters.taskCount**
  Optional | **integer**
  | | **targetParameters.ecsTaskParameters.taskDefinitionARN**
  Optional | **string**
  | | **targetParameters.eventBridgeEventBusParameters**
  Optional | **object**
  The parameters for using an EventBridge event bus as a target. | | **targetParameters.eventBridgeEventBusParameters.detailType**
  Optional | **string**
  | | **targetParameters.eventBridgeEventBusParameters.endpointID**
  Optional | **string**
  | | **targetParameters.eventBridgeEventBusParameters.resources**
  Optional | **array**
  | | **targetParameters.eventBridgeEventBusParameters.resources.[]**
  Required | **string**
  || **targetParameters.eventBridgeEventBusParameters.source**
  Optional | **string**
  | | **targetParameters.eventBridgeEventBusParameters.time**
  Optional | **string**
  | | **targetParameters.httpParameters**
  Optional | **object**
  These are custom parameter to be used when the target is an API Gateway REST APIs or EventBridge ApiDestinations. | | **targetParameters.httpParameters.headerParameters**
  Optional | **object**
  | | **targetParameters.httpParameters.pathParameterValues**
  Optional | **array**
  | | **targetParameters.httpParameters.pathParameterValues.[]**
  Required | **string**
  || **targetParameters.httpParameters.queryStringParameters**
  Optional | **object**
  | | **targetParameters.inputTemplate**
  Optional | **string**
  | | **targetParameters.kinesisStreamParameters**
  Optional | **object**
  The parameters for using a Kinesis stream as a source. | | **targetParameters.kinesisStreamParameters.partitionKey**
  Optional | **string**
  | | **targetParameters.lambdaFunctionParameters**
  Optional | **object**
  The parameters for using a Lambda function as a target. | | **targetParameters.lambdaFunctionParameters.invocationType**
  Optional | **string**
  | | **targetParameters.redshiftDataParameters**
  Optional | **object**
  These are custom parameters to be used when the target is a Amazon Redshift cluster to invoke the Amazon Redshift Data API ExecuteStatement. | | **targetParameters.redshiftDataParameters.database**
  Optional | **string**
  // Redshift Database | | **targetParameters.redshiftDataParameters.dbUser**
  Optional | **string**
  // Database user name | | **targetParameters.redshiftDataParameters.secretManagerARN**
  Optional | **string**
  // For targets, can either specify an ARN or a jsonpath pointing to the ARN. | | **targetParameters.redshiftDataParameters.sqls**
  Optional | **array**
  // A list of SQLs. | | **targetParameters.redshiftDataParameters.sqls.[]**
  Required | **string**
  || **targetParameters.redshiftDataParameters.statementName**
  Optional | **string**
  // A name for Redshift DataAPI statement which can be used as filter of // ListStatement. | | **targetParameters.redshiftDataParameters.withEvent**
  Optional | **boolean**
  | | **targetParameters.sageMakerPipelineParameters**
  Optional | **object**
  The parameters for using a SageMaker pipeline as a target. | | **targetParameters.sageMakerPipelineParameters.pipelineParameterList**
  Optional | **array**
  | | **targetParameters.sageMakerPipelineParameters.pipelineParameterList.[]**
  Required | **object**
  Name/Value pair of a parameter to start execution of a SageMaker Model Building Pipeline. || **targetParameters.sageMakerPipelineParameters.pipelineParameterList.[].name**
  Optional | **string**
  | | **targetParameters.sageMakerPipelineParameters.pipelineParameterList.[].value**
  Optional | **string**
  | | **targetParameters.sqsQueueParameters**
  Optional | **object**
  The parameters for using a Amazon SQS stream as a source. | | **targetParameters.sqsQueueParameters.messageDeduplicationID**
  Optional | **string**
  | | **targetParameters.sqsQueueParameters.messageGroupID**
  Optional | **string**
  | | **targetParameters.stepFunctionStateMachineParameters**
  Optional | **object**
  The parameters for using a Step Functions state machine as a target. | | **targetParameters.stepFunctionStateMachineParameters.invocationType**
  Optional | **string**
  |

Status#

ackResourceMetadata: 
  arn: string
  ownerAccountID: string
  region: string
conditions:
- lastTransitionTime: string
  message: string
  reason: string
  status: string
  type: string
creationTime: string
currentState: string
lastModifiedTime: string
stateReason: string