создание-трубы

  create-pipe
--name <value>
[--description <value>]
[--desired-state <value>]
--source <value>
[--source-parameters <value>]
[--enrichment <value>]
[--enrichment-parameters <value>]
--target <value>
[--target-parameters <value>]
--role-arn <value>
[--tags <value>]
[--log-configuration <value>]
[--kms-key-identifier <value>]
[--cli-input-json | --cli-input-yaml]
[--generate-cli-skeleton <value>]
[--debug]
[--endpoint-url <value>]
[--no-verify-ssl]
[--no-paginate]
[--output <value>]
[--query <value>]
[--profile <value>]
[--region <value>]
[--version <value>]
[--color <value>]
[--no-sign-request]
[--ca-bundle <value>]
[--cli-read-timeout <value>]
[--cli-connect-timeout <value>]
[--cli-binary-format <value>]
[--no-cli-pager]
[--cli-auto-prompt]
[--no-cli-auto-prompt]

{
  "FilterCriteria": {
    "Filters": [
      {
        "Pattern": "string"
      }
      ...
    ]
  },
  "KinesisStreamParameters": {
    "BatchSize": integer,
    "DeadLetterConfig": {
      "Arn": "string"
    },
    "OnPartialBatchItemFailure": "AUTOMATIC_BISECT",
    "MaximumBatchingWindowInSeconds": integer,
    "MaximumRecordAgeInSeconds": integer,
    "MaximumRetryAttempts": integer,
    "ParallelizationFactor": integer,
    "StartingPosition": "TRIM_HORIZON"|"LATEST"|"AT_TIMESTAMP",
    "StartingPositionTimestamp": timestamp
  },
  "DynamoDBStreamParameters": {
    "BatchSize": integer,
    "DeadLetterConfig": {
      "Arn": "string"
    },
    "OnPartialBatchItemFailure": "AUTOMATIC_BISECT",
    "MaximumBatchingWindowInSeconds": integer,
    "MaximumRecordAgeInSeconds": integer,
    "MaximumRetryAttempts": integer,
    "ParallelizationFactor": integer,
    "StartingPosition": "TRIM_HORIZON"|"LATEST"
  },
  "SqsQueueParameters": {
    "BatchSize": integer,
    "MaximumBatchingWindowInSeconds": integer
  },
  "ActiveMQBrokerParameters": {
    "Credentials": {
      "BasicAuth": "string"
    },
    "QueueName": "string",
    "BatchSize": integer,
    "MaximumBatchingWindowInSeconds": integer
  },
  "RabbitMQBrokerParameters": {
    "Credentials": {
      "BasicAuth": "string"
    },
    "QueueName": "string",
    "VirtualHost": "string",
    "BatchSize": integer,
    "MaximumBatchingWindowInSeconds": integer
  },
  "ManagedStreamingKafkaParameters": {
    "TopicName": "string",
    "StartingPosition": "TRIM_HORIZON"|"LATEST",
    "BatchSize": integer,
    "MaximumBatchingWindowInSeconds": integer,
    "ConsumerGroupID": "string",
    "Credentials": {
      "SaslScram512Auth": "string",
      "ClientCertificateTlsAuth": "string"
    }
  },
  "SelfManagedKafkaParameters": {
    "TopicName": "string",
    "StartingPosition": "TRIM_HORIZON"|"LATEST",
    "AdditionalBootstrapServers": ["string", ...],
    "BatchSize": integer,
    "MaximumBatchingWindowInSeconds": integer,
    "ConsumerGroupID": "string",
    "Credentials": {
      "BasicAuth": "string",
      "SaslScram512Auth": "string",
      "SaslScram256Auth": "string",
      "ClientCertificateTlsAuth": "string"
    },
    "ServerRootCaCertificate": "string",
    "Vpc": {
      "Subnets": ["string", ...],
      "SecurityGroup": ["string", ...]
    }
  }
}

InputTemplate=string,HttpParameters={PathParameterValues=[string,string],HeaderParameters={KeyName1=string,KeyName2=string},QueryStringParameters={KeyName1=string,KeyName2=string}}

{
  "InputTemplate": "string",
  "HttpParameters": {
    "PathParameterValues": ["string", ...],
    "HeaderParameters": {"string": "string"
      ...},
    "QueryStringParameters": {"string": "string"
      ...}
  }
}

{
  "InputTemplate": "string",
  "LambdaFunctionParameters": {
    "InvocationType": "REQUEST_RESPONSE"|"FIRE_AND_FORGET"
  },
  "StepFunctionStateMachineParameters": {
    "InvocationType": "REQUEST_RESPONSE"|"FIRE_AND_FORGET"
  },
  "KinesisStreamParameters": {
    "PartitionKey": "string"
  },
  "EcsTaskParameters": {
    "TaskDefinitionArn": "string",
    "TaskCount": integer,
    "LaunchType": "EC2"|"FARGATE"|"EXTERNAL",
    "NetworkConfiguration": {
      "awsvpcConfiguration": {
        "Subnets": ["string", ...],
        "SecurityGroups": ["string", ...],
        "AssignPublicIp": "ENABLED"|"DISABLED"
      }
    },
    "PlatformVersion": "string",
    "Group": "string",
    "CapacityProviderStrategy": [
      {
        "capacityProvider": "string",
        "weight": integer,
        "base": integer
      }
      ...
    ],
    "EnableECSManagedTags": true|false,
    "EnableExecuteCommand": true|false,
    "PlacementConstraints": [
      {
        "type": "distinctInstance"|"memberOf",
        "expression": "string"
      }
      ...
    ],
    "PlacementStrategy": [
      {
        "type": "random"|"spread"|"binpack",
        "field": "string"
      }
      ...
    ],
    "PropagateTags": "TASK_DEFINITION",
    "ReferenceId": "string",
    "Overrides": {
      "ContainerOverrides": [
        {
          "Command": ["string", ...],
          "Cpu": integer,
          "Environment": [
            {
              "name": "string",
              "value": "string"
            }
            ...
          ],
          "EnvironmentFiles": [
            {
              "type": "s3",
              "value": "string"
            }
            ...
          ],
          "Memory": integer,
          "MemoryReservation": integer,
          "Name": "string",
          "ResourceRequirements": [
            {
              "type": "GPU"|"InferenceAccelerator",
              "value": "string"
            }
            ...
          ]
        }
        ...
      ],
      "Cpu": "string",
      "EphemeralStorage": {
        "sizeInGiB": integer
      },
      "ExecutionRoleArn": "string",
      "InferenceAcceleratorOverrides": [
        {
          "deviceName": "string",
          "deviceType": "string"
        }
        ...
      ],
      "Memory": "string",
      "TaskRoleArn": "string"
    },
    "Tags": [
      {
        "Key": "string",
        "Value": "string"
      }
      ...
    ]
  },
  "BatchJobParameters": {
    "JobDefinition": "string",
    "JobName": "string",
    "ArrayProperties": {
      "Size": integer
    },
    "RetryStrategy": {
      "Attempts": integer
    },
    "ContainerOverrides": {
      "Command": ["string", ...],
      "Environment": [
        {
          "Name": "string",
          "Value": "string"
        }
        ...
      ],
      "InstanceType": "string",
      "ResourceRequirements": [
        {
          "Type": "GPU"|"MEMORY"|"VCPU",
          "Value": "string"
        }
        ...
      ]
    },
    "DependsOn": [
      {
        "JobId": "string",
        "Type": "N_TO_N"|"SEQUENTIAL"
      }
      ...
    ],
    "Parameters": {"string": "string"
      ...}
  },
  "SqsQueueParameters": {
    "MessageGroupId": "string",
    "MessageDeduplicationId": "string"
  },
  "HttpParameters": {
    "PathParameterValues": ["string", ...],
    "HeaderParameters": {"string": "string"
      ...},
    "QueryStringParameters": {"string": "string"
      ...}
  },
  "RedshiftDataParameters": {
    "SecretManagerArn": "string",
    "Database": "string",
    "DbUser": "string",
    "StatementName": "string",
    "WithEvent": true|false,
    "Sqls": ["string", ...]
  },
  "SageMakerPipelineParameters": {
    "PipelineParameterList": [
      {
        "Name": "string",
        "Value": "string"
      }
      ...
    ]
  },
  "EventBridgeEventBusParameters": {
    "EndpointId": "string",
    "DetailType": "string",
    "Source": "string",
    "Resources": ["string", ...],
    "Time": "string"
  },
  "CloudWatchLogsParameters": {
    "LogStreamName": "string",
    "Timestamp": "string"
  },
  "TimestreamParameters": {
    "TimeValue": "string",
    "EpochTimeUnit": "MILLISECONDS"|"SECONDS"|"MICROSECONDS"|"NANOSECONDS",
    "TimeFieldType": "EPOCH"|"TIMESTAMP_FORMAT",
    "TimestampFormat": "string",
    "VersionValue": "string",
    "DimensionMappings": [
      {
        "DimensionValue": "string",
        "DimensionValueType": "VARCHAR",
        "DimensionName": "string"
      }
      ...
    ],
    "SingleMeasureMappings": [
      {
        "MeasureValue": "string",
        "MeasureValueType": "DOUBLE"|"BIGINT"|"VARCHAR"|"BOOLEAN"|"TIMESTAMP",
        "MeasureName": "string"
      }
      ...
    ],
    "MultiMeasureMappings": [
      {
        "MultiMeasureName": "string",
        "MultiMeasureAttributeMappings": [
          {
            "MeasureValue": "string",
            "MeasureValueType": "DOUBLE"|"BIGINT"|"VARCHAR"|"BOOLEAN"|"TIMESTAMP",
            "MultiMeasureAttributeName": "string"
          }
          ...
        ]
      }
      ...
    ]
  }
}

KeyName1=string,KeyName2=string

{"string": "string"
  ...}

S3LogDestination={BucketName=string,BucketOwner=string,OutputFormat=string,Prefix=string},FirehoseLogDestination={DeliveryStreamArn=string},CloudwatchLogsLogDestination={LogGroupArn=string},Level=string,IncludeExecutionData=string,string

{
  "S3LogDestination": {
    "BucketName": "string",
    "BucketOwner": "string",
    "OutputFormat": "json"|"plain"|"w3c",
    "Prefix": "string"
  },
  "FirehoseLogDestination": {
    "DeliveryStreamArn": "string"
  },
  "CloudwatchLogsLogDestination": {
    "LogGroupArn": "string"
  },
  "Level": "OFF"|"ERROR"|"INFO"|"TRACE",
  "IncludeExecutionData": ["ALL", ...]
}

aws pipes create-pipe \
    --name Demo_Pipe \
    --desired-state RUNNING \
    --role-arn arn:aws:iam::123456789012:role/service-role/Amazon_EventBridge_Pipe_Demo_Pipe_28b3aa4f \
    --source arn:aws:sqs:us-east-1:123456789012:Demo_Queue \
    --target arn:aws:logs:us-east-1:123456789012:log-group:/aws/pipes/Demo_LogGroup

{
    "Arn": "arn:aws:pipes:us-east-1:123456789012:pipe/Demo_Pipe",
    "Name": "Demo_Pipe",
    "DesiredState": "RUNNING",
    "CurrentState": "CREATING",
    "CreationTime": "2024-10-08T12:33:59-05:00",
    "LastModifiedTime": "2024-10-08T12:33:59.684839-05:00"
}