Docs
PackagesAWS Native is in preview. AWS Classic is fully supported.
AWS Native v0.102.0 published on Tuesday, Apr 16, 2024 by Pulumi
aws-native.pipes.Pipe
Explore with Pulumi AI
AWS Native is in preview. AWS Classic is fully supported.
AWS Native v0.102.0 published on Tuesday, Apr 16, 2024 by Pulumi
Definition of AWS::Pipes::Pipe Resource Type
Example Usage
Example
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AwsNative = Pulumi.AwsNative;
return await Deployment.RunAsync(() =>
{
var testPipe = new AwsNative.Pipes.Pipe("testPipe", new()
{
Name = "PipeCfnExample",
RoleArn = "arn:aws:iam::123456789123:role/Pipe-Dev-All-Targets-Dummy-Execution-Role",
Source = "arn:aws:sqs:us-east-1:123456789123:pipeDemoSource",
Enrichment = "arn:aws:execute-api:us-east-1:123456789123:53eo2i89p9/*/POST/pets",
Target = "arn:aws:states:us-east-1:123456789123:stateMachine:PipeTargetStateMachine",
});
});
package main
import (
"github.com/pulumi/pulumi-aws-native/sdk/go/aws/pipes"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := pipes.NewPipe(ctx, "testPipe", &pipes.PipeArgs{
Name: pulumi.String("PipeCfnExample"),
RoleArn: pulumi.String("arn:aws:iam::123456789123:role/Pipe-Dev-All-Targets-Dummy-Execution-Role"),
Source: pulumi.String("arn:aws:sqs:us-east-1:123456789123:pipeDemoSource"),
Enrichment: pulumi.String("arn:aws:execute-api:us-east-1:123456789123:53eo2i89p9/*/POST/pets"),
Target: pulumi.String("arn:aws:states:us-east-1:123456789123:stateMachine:PipeTargetStateMachine"),
})
if err != nil {
return err
}
return nil
})
}
Coming soon!
import pulumi
import pulumi_aws_native as aws_native
test_pipe = aws_native.pipes.Pipe("testPipe",
name="PipeCfnExample",
role_arn="arn:aws:iam::123456789123:role/Pipe-Dev-All-Targets-Dummy-Execution-Role",
source="arn:aws:sqs:us-east-1:123456789123:pipeDemoSource",
enrichment="arn:aws:execute-api:us-east-1:123456789123:53eo2i89p9/*/POST/pets",
target="arn:aws:states:us-east-1:123456789123:stateMachine:PipeTargetStateMachine")
import * as pulumi from "@pulumi/pulumi";
import * as aws_native from "@pulumi/aws-native";
const testPipe = new aws_native.pipes.Pipe("testPipe", {
name: "PipeCfnExample",
roleArn: "arn:aws:iam::123456789123:role/Pipe-Dev-All-Targets-Dummy-Execution-Role",
source: "arn:aws:sqs:us-east-1:123456789123:pipeDemoSource",
enrichment: "arn:aws:execute-api:us-east-1:123456789123:53eo2i89p9/*/POST/pets",
target: "arn:aws:states:us-east-1:123456789123:stateMachine:PipeTargetStateMachine",
});
Coming soon!
Example
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AwsNative = Pulumi.AwsNative;
return await Deployment.RunAsync(() =>
{
var testPipe = new AwsNative.Pipes.Pipe("testPipe", new()
{
Name = "PipeCfnExample",
RoleArn = "arn:aws:iam::123456789123:role/Pipe-Dev-All-Targets-Dummy-Execution-Role",
Source = "arn:aws:sqs:us-east-1:123456789123:pipeDemoSource",
Enrichment = "arn:aws:execute-api:us-east-1:123456789123:53eo2i89p9/*/POST/pets",
Target = "arn:aws:states:us-east-1:123456789123:stateMachine:PipeTargetStateMachine",
});
});
package main
import (
"github.com/pulumi/pulumi-aws-native/sdk/go/aws/pipes"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := pipes.NewPipe(ctx, "testPipe", &pipes.PipeArgs{
Name: pulumi.String("PipeCfnExample"),
RoleArn: pulumi.String("arn:aws:iam::123456789123:role/Pipe-Dev-All-Targets-Dummy-Execution-Role"),
Source: pulumi.String("arn:aws:sqs:us-east-1:123456789123:pipeDemoSource"),
Enrichment: pulumi.String("arn:aws:execute-api:us-east-1:123456789123:53eo2i89p9/*/POST/pets"),
Target: pulumi.String("arn:aws:states:us-east-1:123456789123:stateMachine:PipeTargetStateMachine"),
})
if err != nil {
return err
}
return nil
})
}
Coming soon!
import pulumi
import pulumi_aws_native as aws_native
test_pipe = aws_native.pipes.Pipe("testPipe",
name="PipeCfnExample",
role_arn="arn:aws:iam::123456789123:role/Pipe-Dev-All-Targets-Dummy-Execution-Role",
source="arn:aws:sqs:us-east-1:123456789123:pipeDemoSource",
enrichment="arn:aws:execute-api:us-east-1:123456789123:53eo2i89p9/*/POST/pets",
target="arn:aws:states:us-east-1:123456789123:stateMachine:PipeTargetStateMachine")
import * as pulumi from "@pulumi/pulumi";
import * as aws_native from "@pulumi/aws-native";
const testPipe = new aws_native.pipes.Pipe("testPipe", {
name: "PipeCfnExample",
roleArn: "arn:aws:iam::123456789123:role/Pipe-Dev-All-Targets-Dummy-Execution-Role",
source: "arn:aws:sqs:us-east-1:123456789123:pipeDemoSource",
enrichment: "arn:aws:execute-api:us-east-1:123456789123:53eo2i89p9/*/POST/pets",
target: "arn:aws:states:us-east-1:123456789123:stateMachine:PipeTargetStateMachine",
});
Coming soon!
Create Pipe Resource
Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.
Constructor syntax
new Pipe(name: string, args: PipeArgs, opts?: CustomResourceOptions);@overload
def Pipe(resource_name: str,
args: PipeArgs,
opts: Optional[ResourceOptions] = None)
@overload
def Pipe(resource_name: str,
opts: Optional[ResourceOptions] = None,
role_arn: Optional[str] = None,
source: Optional[str] = None,
target: Optional[str] = None,
description: Optional[str] = None,
desired_state: Optional[PipeRequestedPipeState] = None,
enrichment: Optional[str] = None,
enrichment_parameters: Optional[PipeEnrichmentParametersArgs] = None,
log_configuration: Optional[PipeLogConfigurationArgs] = None,
name: Optional[str] = None,
source_parameters: Optional[PipeSourceParametersArgs] = None,
tags: Optional[Mapping[str, str]] = None,
target_parameters: Optional[PipeTargetParametersArgs] = None)func NewPipe(ctx *Context, name string, args PipeArgs, opts ...ResourceOption) (*Pipe, error)public Pipe(string name, PipeArgs args, CustomResourceOptions? opts = null)type: aws-native:pipes:Pipe
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.
Parameters
- name string
- The unique name of the resource.
- args PipeArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- resource_name str
- The unique name of the resource.
- args PipeArgs
- The arguments to resource properties.
- opts ResourceOptions
- Bag of options to control resource's behavior.
- ctx Context
- Context object for the current deployment.
- name string
- The unique name of the resource.
- args PipeArgs
- The arguments to resource properties.
- opts ResourceOption
- Bag of options to control resource's behavior.
- name string
- The unique name of the resource.
- args PipeArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- name String
- The unique name of the resource.
- args PipeArgs
- The arguments to resource properties.
- options CustomResourceOptions
- Bag of options to control resource's behavior.
Example
The following reference example uses placeholder values for all input properties.
Coming soon!
Coming soon!
Coming soon!
Coming soon!
const pipeResource = new aws_native.pipes.Pipe("pipeResource", {
roleArn: "string",
source: "string",
target: "string",
description: "string",
desiredState: aws_native.pipes.PipeRequestedPipeState.Running,
enrichment: "string",
enrichmentParameters: {
httpParameters: {
headerParameters: {
string: "string",
},
pathParameterValues: ["string"],
queryStringParameters: {
string: "string",
},
},
inputTemplate: "string",
},
logConfiguration: {
cloudwatchLogsLogDestination: {
logGroupArn: "string",
},
firehoseLogDestination: {
deliveryStreamArn: "string",
},
includeExecutionData: [aws_native.pipes.PipeIncludeExecutionDataOption.All],
level: aws_native.pipes.PipeLogLevel.Off,
s3LogDestination: {
bucketName: "string",
bucketOwner: "string",
outputFormat: aws_native.pipes.PipeS3OutputFormat.Json,
prefix: "string",
},
},
name: "string",
sourceParameters: {
activeMqBrokerParameters: {
credentials: {
basicAuth: "string",
},
queueName: "string",
batchSize: 0,
maximumBatchingWindowInSeconds: 0,
},
dynamoDbStreamParameters: {
startingPosition: aws_native.pipes.PipeDynamoDbStreamStartPosition.TrimHorizon,
batchSize: 0,
deadLetterConfig: {
arn: "string",
},
maximumBatchingWindowInSeconds: 0,
maximumRecordAgeInSeconds: 0,
maximumRetryAttempts: 0,
onPartialBatchItemFailure: aws_native.pipes.PipeOnPartialBatchItemFailureStreams.AutomaticBisect,
parallelizationFactor: 0,
},
filterCriteria: {
filters: [{
pattern: "string",
}],
},
kinesisStreamParameters: {
startingPosition: aws_native.pipes.PipeKinesisStreamStartPosition.TrimHorizon,
batchSize: 0,
deadLetterConfig: {
arn: "string",
},
maximumBatchingWindowInSeconds: 0,
maximumRecordAgeInSeconds: 0,
maximumRetryAttempts: 0,
onPartialBatchItemFailure: aws_native.pipes.PipeOnPartialBatchItemFailureStreams.AutomaticBisect,
parallelizationFactor: 0,
startingPositionTimestamp: "string",
},
managedStreamingKafkaParameters: {
topicName: "string",
batchSize: 0,
consumerGroupId: "string",
credentials: {
saslScram512Auth: "string",
},
maximumBatchingWindowInSeconds: 0,
startingPosition: aws_native.pipes.PipeMskStartPosition.TrimHorizon,
},
rabbitMqBrokerParameters: {
credentials: {
basicAuth: "string",
},
queueName: "string",
batchSize: 0,
maximumBatchingWindowInSeconds: 0,
virtualHost: "string",
},
selfManagedKafkaParameters: {
topicName: "string",
additionalBootstrapServers: ["string"],
batchSize: 0,
consumerGroupId: "string",
credentials: {
basicAuth: "string",
},
maximumBatchingWindowInSeconds: 0,
serverRootCaCertificate: "string",
startingPosition: aws_native.pipes.PipeSelfManagedKafkaStartPosition.TrimHorizon,
vpc: {
securityGroup: ["string"],
subnets: ["string"],
},
},
sqsQueueParameters: {
batchSize: 0,
maximumBatchingWindowInSeconds: 0,
},
},
tags: {
string: "string",
},
targetParameters: {
batchJobParameters: {
jobDefinition: "string",
jobName: "string",
arrayProperties: {
size: 0,
},
containerOverrides: {
command: ["string"],
environment: [{
name: "string",
value: "string",
}],
instanceType: "string",
resourceRequirements: [{
type: aws_native.pipes.PipeBatchResourceRequirementType.Gpu,
value: "string",
}],
},
dependsOn: [{
jobId: "string",
type: aws_native.pipes.PipeBatchJobDependencyType.NToN,
}],
parameters: {
string: "string",
},
retryStrategy: {
attempts: 0,
},
},
cloudWatchLogsParameters: {
logStreamName: "string",
timestamp: "string",
},
ecsTaskParameters: {
taskDefinitionArn: "string",
overrides: {
containerOverrides: [{
command: ["string"],
cpu: 0,
environment: [{
name: "string",
value: "string",
}],
environmentFiles: [{
type: aws_native.pipes.PipeEcsEnvironmentFileType.S3,
value: "string",
}],
memory: 0,
memoryReservation: 0,
name: "string",
resourceRequirements: [{
type: aws_native.pipes.PipeEcsResourceRequirementType.Gpu,
value: "string",
}],
}],
cpu: "string",
ephemeralStorage: {
sizeInGiB: 0,
},
executionRoleArn: "string",
inferenceAcceleratorOverrides: [{
deviceName: "string",
deviceType: "string",
}],
memory: "string",
taskRoleArn: "string",
},
placementStrategy: [{
field: "string",
type: aws_native.pipes.PipePlacementStrategyType.Random,
}],
group: "string",
launchType: aws_native.pipes.PipeLaunchType.Ec2,
networkConfiguration: {
awsvpcConfiguration: {
subnets: ["string"],
assignPublicIp: aws_native.pipes.PipeAssignPublicIp.Enabled,
securityGroups: ["string"],
},
},
capacityProviderStrategy: [{
capacityProvider: "string",
base: 0,
weight: 0,
}],
placementConstraints: [{
expression: "string",
type: aws_native.pipes.PipePlacementConstraintType.DistinctInstance,
}],
enableExecuteCommand: false,
platformVersion: "string",
propagateTags: aws_native.pipes.PipePropagateTags.TaskDefinition,
referenceId: "string",
tags: [{
key: "string",
value: "string",
}],
taskCount: 0,
enableEcsManagedTags: false,
},
eventBridgeEventBusParameters: {
detailType: "string",
endpointId: "string",
resources: ["string"],
source: "string",
time: "string",
},
httpParameters: {
headerParameters: {
string: "string",
},
pathParameterValues: ["string"],
queryStringParameters: {
string: "string",
},
},
inputTemplate: "string",
kinesisStreamParameters: {
partitionKey: "string",
},
lambdaFunctionParameters: {
invocationType: aws_native.pipes.PipeTargetInvocationType.RequestResponse,
},
redshiftDataParameters: {
database: "string",
sqls: ["string"],
dbUser: "string",
secretManagerArn: "string",
statementName: "string",
withEvent: false,
},
sageMakerPipelineParameters: {
pipelineParameterList: [{
name: "string",
value: "string",
}],
},
sqsQueueParameters: {
messageDeduplicationId: "string",
messageGroupId: "string",
},
stepFunctionStateMachineParameters: {
invocationType: aws_native.pipes.PipeTargetInvocationType.RequestResponse,
},
},
});
Coming soon!
Pipe Resource Properties
To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.
Inputs
The Pipe resource accepts the following input properties:
- Role
Arn string - Source string
- Target string
- Description string
- Desired
State Pulumi.Aws Native. Pipes. Pipe Requested Pipe State - Enrichment string
- Enrichment
Parameters Pulumi.Aws Native. Pipes. Inputs. Pipe Enrichment Parameters - Log
Configuration Pulumi.Aws Native. Pipes. Inputs. Pipe Log Configuration - Name string
- Source
Parameters Pulumi.Aws Native. Pipes. Inputs. Pipe Source Parameters - Dictionary<string, string>
- Target
Parameters Pulumi.Aws Native. Pipes. Inputs. Pipe Target Parameters
- Role
Arn string - Source string
- Target string
- Description string
- Desired
State PipeRequested Pipe State - Enrichment string
- Enrichment
Parameters PipeEnrichment Parameters Args - Log
Configuration PipeLog Configuration Args - Name string
- Source
Parameters PipeSource Parameters Args - map[string]string
- Target
Parameters PipeTarget Parameters Args
- role
Arn String - source String
- target String
- description String
- desired
State PipeRequested Pipe State - enrichment String
- enrichment
Parameters PipeEnrichment Parameters - log
Configuration PipeLog Configuration - name String
- source
Parameters PipeSource Parameters - Map<String,String>
- target
Parameters PipeTarget Parameters
- role
Arn string - source string
- target string
- description string
- desired
State PipeRequested Pipe State - enrichment string
- enrichment
Parameters PipeEnrichment Parameters - log
Configuration PipeLog Configuration - name string
- source
Parameters PipeSource Parameters - {[key: string]: string}
- target
Parameters PipeTarget Parameters
- role
Arn String - source String
- target String
- description String
- desired
State "RUNNING" | "STOPPED" - enrichment String
- enrichment
Parameters Property Map - log
Configuration Property Map - name String
- source
Parameters Property Map - Map<String>
- target
Parameters Property Map
Outputs
All input properties are implicitly available as output properties. Additionally, the Pipe resource produces the following output properties:
- Arn string
- Creation
Time string - Current
State Pulumi.Aws Native. Pipes. Pipe State - Id string
- The provider-assigned unique ID for this managed resource.
- Last
Modified stringTime - State
Reason string
- Arn string
- Creation
Time string - Current
State PipeState Enum - Id string
- The provider-assigned unique ID for this managed resource.
- Last
Modified stringTime - State
Reason string
- arn String
- creation
Time String - current
State PipeState - id String
- The provider-assigned unique ID for this managed resource.
- last
Modified StringTime - state
Reason String
- arn string
- creation
Time string - current
State PipeState - id string
- The provider-assigned unique ID for this managed resource.
- last
Modified stringTime - state
Reason string
- arn str
- creation_
time str - current_
state PipeState - id str
- The provider-assigned unique ID for this managed resource.
- last_
modified_ strtime - state_
reason str
- arn String
- creation
Time String - current
State "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" - id String
- The provider-assigned unique ID for this managed resource.
- last
Modified StringTime - state
Reason String
Supporting Types
PipeAssignPublicIp, PipeAssignPublicIpArgs
- Enabled
- ENABLED
- Disabled
- DISABLED
- Pipe
Assign Public Ip Enabled - ENABLED
- Pipe
Assign Public Ip Disabled - DISABLED
- Enabled
- ENABLED
- Disabled
- DISABLED
- Enabled
- ENABLED
- Disabled
- DISABLED
- ENABLED
- ENABLED
- DISABLED
- DISABLED
- "ENABLED"
- ENABLED
- "DISABLED"
- DISABLED
PipeAwsVpcConfiguration, PipeAwsVpcConfigurationArgs
- Subnets List<string>
- Assign
Public Pulumi.Ip Aws Native. Pipes. Pipe Assign Public Ip - Security
Groups List<string>
- Subnets []string
- Assign
Public PipeIp Assign Public Ip - Security
Groups []string
- subnets List<String>
- assign
Public PipeIp Assign Public Ip - security
Groups List<String>
- subnets string[]
- assign
Public PipeIp Assign Public Ip - security
Groups string[]
- subnets Sequence[str]
- assign_
public_ Pipeip Assign Public Ip - security_
groups Sequence[str]
- subnets List<String>
- assign
Public "ENABLED" | "DISABLED"Ip - security
Groups List<String>
PipeBatchArrayProperties, PipeBatchArrayPropertiesArgs
- Size int
- Size int
- size Integer
- size number
- size int
- size Number
PipeBatchContainerOverrides, PipeBatchContainerOverridesArgs
- command List<String>
- environment List<Property Map>
- instance
Type String - resource
Requirements List<Property Map>
PipeBatchEnvironmentVariable, PipeBatchEnvironmentVariableArgs
PipeBatchJobDependency, PipeBatchJobDependencyArgs
- job
Id String - type "N_TO_N" | "SEQUENTIAL"
PipeBatchJobDependencyType, PipeBatchJobDependencyTypeArgs
- NTo
N - N_TO_N
- Sequential
- SEQUENTIAL
- Pipe
Batch Job Dependency Type NTo N - N_TO_N
- Pipe
Batch Job Dependency Type Sequential - SEQUENTIAL
- NTo
N - N_TO_N
- Sequential
- SEQUENTIAL
- NTo
N - N_TO_N
- Sequential
- SEQUENTIAL
- N_TO_N
- N_TO_N
- SEQUENTIAL
- SEQUENTIAL
- "N_TO_N"
- N_TO_N
- "SEQUENTIAL"
- SEQUENTIAL
PipeBatchResourceRequirement, PipeBatchResourceRequirementArgs
PipeBatchResourceRequirementType, PipeBatchResourceRequirementTypeArgs
- Gpu
- GPU
- Memory
- MEMORY
- Vcpu
- VCPU
- Pipe
Batch Resource Requirement Type Gpu - GPU
- Pipe
Batch Resource Requirement Type Memory - MEMORY
- Pipe
Batch Resource Requirement Type Vcpu - VCPU
- Gpu
- GPU
- Memory
- MEMORY
- Vcpu
- VCPU
- Gpu
- GPU
- Memory
- MEMORY
- Vcpu
- VCPU
- GPU
- GPU
- MEMORY
- MEMORY
- VCPU
- VCPU
- "GPU"
- GPU
- "MEMORY"
- MEMORY
- "VCPU"
- VCPU
PipeBatchRetryStrategy, PipeBatchRetryStrategyArgs
- Attempts int
- Attempts int
- attempts Integer
- attempts number
- attempts int
- attempts Number
PipeCapacityProviderStrategyItem, PipeCapacityProviderStrategyItemArgs
- Capacity
Provider string - Base int
- Weight int
- Capacity
Provider string - Base int
- Weight int
- capacity
Provider String - base Integer
- weight Integer
- capacity
Provider string - base number
- weight number
- capacity_
provider str - base int
- weight int
- capacity
Provider String - base Number
- weight Number
PipeCloudwatchLogsLogDestination, PipeCloudwatchLogsLogDestinationArgs
- Log
Group stringArn
- Log
Group stringArn
- log
Group StringArn
- log
Group stringArn
- log_
group_ strarn
- log
Group StringArn
PipeDeadLetterConfig, PipeDeadLetterConfigArgs
- Arn string
- Arn string
- arn String
- arn string
- arn str
- arn String
PipeDynamoDbStreamStartPosition, PipeDynamoDbStreamStartPositionArgs
- Trim
Horizon - TRIM_HORIZON
- Latest
- LATEST
- Pipe
Dynamo Db Stream Start Position Trim Horizon - TRIM_HORIZON
- Pipe
Dynamo Db Stream Start Position Latest - LATEST
- Trim
Horizon - TRIM_HORIZON
- Latest
- LATEST
- Trim
Horizon - TRIM_HORIZON
- Latest
- LATEST
- TRIM_HORIZON
- TRIM_HORIZON
- LATEST
- LATEST
- "TRIM_HORIZON"
- TRIM_HORIZON
- "LATEST"
- LATEST
PipeEcsContainerOverride, PipeEcsContainerOverrideArgs
- Command List<string>
- Cpu int
- Environment
List<Pulumi.
Aws Native. Pipes. Inputs. Pipe Ecs Environment Variable> - Environment
Files List<Pulumi.Aws Native. Pipes. Inputs. Pipe Ecs Environment File> - Memory int
- Memory
Reservation int - Name string
- Resource
Requirements List<Pulumi.Aws Native. Pipes. Inputs. Pipe Ecs Resource Requirement>
- command List<String>
- cpu Integer
- environment
List<Pipe
Ecs Environment Variable> - environment
Files List<PipeEcs Environment File> - memory Integer
- memory
Reservation Integer - name String
- resource
Requirements List<PipeEcs Resource Requirement>
- command List<String>
- cpu Number
- environment List<Property Map>
- environment
Files List<Property Map> - memory Number
- memory
Reservation Number - name String
- resource
Requirements List<Property Map>
PipeEcsEnvironmentFile, PipeEcsEnvironmentFileArgs
PipeEcsEnvironmentFileType, PipeEcsEnvironmentFileTypeArgs
- S3
- s3
- Pipe
Ecs Environment File Type S3 - s3
- S3
- s3
- S3
- s3
- S3
- s3
- "s3"
- s3
PipeEcsEnvironmentVariable, PipeEcsEnvironmentVariableArgs
PipeEcsEphemeralStorage, PipeEcsEphemeralStorageArgs
- Size
In intGi B
- Size
In intGi B
- size
In IntegerGi B
- size
In numberGi B
- size_
in_ intgi_ b
- size
In NumberGi B
PipeEcsInferenceAcceleratorOverride, PipeEcsInferenceAcceleratorOverrideArgs
- Device
Name string - Device
Type string
- Device
Name string - Device
Type string
- device
Name String - device
Type String
- device
Name string - device
Type string
- device_
name str - device_
type str
- device
Name String - device
Type String
PipeEcsResourceRequirement, PipeEcsResourceRequirementArgs
PipeEcsResourceRequirementType, PipeEcsResourceRequirementTypeArgs
- Gpu
- GPU
- Inference
Accelerator - InferenceAccelerator
- Pipe
Ecs Resource Requirement Type Gpu - GPU
- Pipe
Ecs Resource Requirement Type Inference Accelerator - InferenceAccelerator
- Gpu
- GPU
- Inference
Accelerator - InferenceAccelerator
- Gpu
- GPU
- Inference
Accelerator - InferenceAccelerator
- GPU
- GPU
- INFERENCE_ACCELERATOR
- InferenceAccelerator
- "GPU"
- GPU
- "Inference
Accelerator" - InferenceAccelerator
PipeEcsTaskOverride, PipeEcsTaskOverrideArgs
- Container
Overrides List<Pulumi.Aws Native. Pipes. Inputs. Pipe Ecs Container Override> - Cpu string
- Ephemeral
Storage Pulumi.Aws Native. Pipes. Inputs. Pipe Ecs Ephemeral Storage - Execution
Role stringArn - Inference
Accelerator List<Pulumi.Overrides Aws Native. Pipes. Inputs. Pipe Ecs Inference Accelerator Override> - Memory string
- Task
Role stringArn
PipeEnrichmentHttpParameters, PipeEnrichmentHttpParametersArgs
- Header
Parameters Dictionary<string, string> - Path
Parameter List<string>Values - Query
String Dictionary<string, string>Parameters
- Header
Parameters map[string]string - Path
Parameter []stringValues - Query
String map[string]stringParameters
- header
Parameters Map<String,String> - path
Parameter List<String>Values - query
String Map<String,String>Parameters
- header
Parameters {[key: string]: string} - path
Parameter string[]Values - query
String {[key: string]: string}Parameters
- header_
parameters Mapping[str, str] - path_
parameter_ Sequence[str]values - query_
string_ Mapping[str, str]parameters
- header
Parameters Map<String> - path
Parameter List<String>Values - query
String Map<String>Parameters
PipeEnrichmentParameters, PipeEnrichmentParametersArgs
PipeFilter, PipeFilterArgs
- Pattern string
- Pattern string
- pattern String
- pattern string
- pattern str
- pattern String
PipeFilterCriteria, PipeFilterCriteriaArgs
PipeFirehoseLogDestination, PipeFirehoseLogDestinationArgs
- Delivery
Stream stringArn
- Delivery
Stream stringArn
- delivery
Stream StringArn
- delivery
Stream stringArn
- delivery
Stream StringArn
PipeIncludeExecutionDataOption, PipeIncludeExecutionDataOptionArgs
- All
- ALL
- Pipe
Include Execution Data Option All - ALL
- All
- ALL
- All
- ALL
- ALL
- ALL
- "ALL"
- ALL
PipeKinesisStreamStartPosition, PipeKinesisStreamStartPositionArgs
- Trim
Horizon - TRIM_HORIZON
- Latest
- LATEST
- At
Timestamp - AT_TIMESTAMP
- Pipe
Kinesis Stream Start Position Trim Horizon - TRIM_HORIZON
- Pipe
Kinesis Stream Start Position Latest - LATEST
- Pipe
Kinesis Stream Start Position At Timestamp - AT_TIMESTAMP
- Trim
Horizon - TRIM_HORIZON
- Latest
- LATEST
- At
Timestamp - AT_TIMESTAMP
- Trim
Horizon - TRIM_HORIZON
- Latest
- LATEST
- At
Timestamp - AT_TIMESTAMP
- TRIM_HORIZON
- TRIM_HORIZON
- LATEST
- LATEST
- AT_TIMESTAMP
- AT_TIMESTAMP
- "TRIM_HORIZON"
- TRIM_HORIZON
- "LATEST"
- LATEST
- "AT_TIMESTAMP"
- AT_TIMESTAMP
PipeLaunchType, PipeLaunchTypeArgs
- Ec2
- EC2
- Fargate
- FARGATE
- External
- EXTERNAL
- Pipe
Launch Type Ec2 - EC2
- Pipe
Launch Type Fargate - FARGATE
- Pipe
Launch Type External - EXTERNAL
- Ec2
- EC2
- Fargate
- FARGATE
- External
- EXTERNAL
- Ec2
- EC2
- Fargate
- FARGATE
- External
- EXTERNAL
- EC2
- EC2
- FARGATE
- FARGATE
- EXTERNAL
- EXTERNAL
- "EC2"
- EC2
- "FARGATE"
- FARGATE
- "EXTERNAL"
- EXTERNAL
PipeLogConfiguration, PipeLogConfigurationArgs
- Cloudwatch
Logs Pulumi.Log Destination Aws Native. Pipes. Inputs. Pipe Cloudwatch Logs Log Destination - Firehose
Log Pulumi.Destination Aws Native. Pipes. Inputs. Pipe Firehose Log Destination - Include
Execution List<Pulumi.Data Aws Native. Pipes. Pipe Include Execution Data Option> - Level
Pulumi.
Aws Native. Pipes. Pipe Log Level - S3Log
Destination Pulumi.Aws Native. Pipes. Inputs. Pipe S3Log Destination
PipeLogLevel, PipeLogLevelArgs
- Off
- OFF
- Error
- ERROR
- Info
- INFO
- Trace
- TRACE
- Pipe
Log Level Off - OFF
- Pipe
Log Level Error - ERROR
- Pipe
Log Level Info - INFO
- Pipe
Log Level Trace - TRACE
- Off
- OFF
- Error
- ERROR
- Info
- INFO
- Trace
- TRACE
- Off
- OFF
- Error
- ERROR
- Info
- INFO
- Trace
- TRACE
- OFF
- OFF
- ERROR
- ERROR
- INFO
- INFO
- TRACE
- TRACE
- "OFF"
- OFF
- "ERROR"
- ERROR
- "INFO"
- INFO
- "TRACE"
- TRACE
PipeMqBrokerAccessCredentialsProperties, PipeMqBrokerAccessCredentialsPropertiesArgs
- Basic
Auth string - Optional SecretManager ARN which stores the database credentials
- Basic
Auth string - Optional SecretManager ARN which stores the database credentials
- basic
Auth String - Optional SecretManager ARN which stores the database credentials
- basic
Auth string - Optional SecretManager ARN which stores the database credentials
- basic_
auth str - Optional SecretManager ARN which stores the database credentials
- basic
Auth String - Optional SecretManager ARN which stores the database credentials
PipeMskAccessCredentials0Properties, PipeMskAccessCredentials0PropertiesArgs
- Sasl
Scram512Auth string - Optional SecretManager ARN which stores the database credentials
- Sasl
Scram512Auth string - Optional SecretManager ARN which stores the database credentials
- sasl
Scram512Auth String - Optional SecretManager ARN which stores the database credentials
- sasl
Scram512Auth string - Optional SecretManager ARN which stores the database credentials
- sasl_
scram512_ strauth - Optional SecretManager ARN which stores the database credentials
- sasl
Scram512Auth String - Optional SecretManager ARN which stores the database credentials
PipeMskAccessCredentials1Properties, PipeMskAccessCredentials1PropertiesArgs
- Client
Certificate stringTls Auth - Optional SecretManager ARN which stores the database credentials
- Client
Certificate stringTls Auth - Optional SecretManager ARN which stores the database credentials
- client
Certificate StringTls Auth - Optional SecretManager ARN which stores the database credentials
- client
Certificate stringTls Auth - Optional SecretManager ARN which stores the database credentials
- client_
certificate_ strtls_ auth - Optional SecretManager ARN which stores the database credentials
- client
Certificate StringTls Auth - Optional SecretManager ARN which stores the database credentials
PipeMskStartPosition, PipeMskStartPositionArgs
- Trim
Horizon - TRIM_HORIZON
- Latest
- LATEST
- Pipe
Msk Start Position Trim Horizon - TRIM_HORIZON
- Pipe
Msk Start Position Latest - LATEST
- Trim
Horizon - TRIM_HORIZON
- Latest
- LATEST
- Trim
Horizon - TRIM_HORIZON
- Latest
- LATEST
- TRIM_HORIZON
- TRIM_HORIZON
- LATEST
- LATEST
- "TRIM_HORIZON"
- TRIM_HORIZON
- "LATEST"
- LATEST
PipeNetworkConfiguration, PipeNetworkConfigurationArgs
PipeOnPartialBatchItemFailureStreams, PipeOnPartialBatchItemFailureStreamsArgs
- Automatic
Bisect - AUTOMATIC_BISECT
- Pipe
On Partial Batch Item Failure Streams Automatic Bisect - AUTOMATIC_BISECT
- Automatic
Bisect - AUTOMATIC_BISECT
- Automatic
Bisect - AUTOMATIC_BISECT
- AUTOMATIC_BISECT
- AUTOMATIC_BISECT
- "AUTOMATIC_BISECT"
- AUTOMATIC_BISECT
PipePlacementConstraint, PipePlacementConstraintArgs
PipePlacementConstraintType, PipePlacementConstraintTypeArgs
- Distinct
Instance - distinctInstance
- Member
Of - memberOf
- Pipe
Placement Constraint Type Distinct Instance - distinctInstance
- Pipe
Placement Constraint Type Member Of - memberOf
- Distinct
Instance - distinctInstance
- Member
Of - memberOf
- Distinct
Instance - distinctInstance
- Member
Of - memberOf
- DISTINCT_INSTANCE
- distinctInstance
- MEMBER_OF
- memberOf
- "distinct
Instance" - distinctInstance
- "member
Of" - memberOf
PipePlacementStrategy, PipePlacementStrategyArgs
PipePlacementStrategyType, PipePlacementStrategyTypeArgs
- Random
- random
- Spread
- spread
- Binpack
- binpack
- Pipe
Placement Strategy Type Random - random
- Pipe
Placement Strategy Type Spread - spread
- Pipe
Placement Strategy Type Binpack - binpack
- Random
- random
- Spread
- spread
- Binpack
- binpack
- Random
- random
- Spread
- spread
- Binpack
- binpack
- RANDOM
- random
- SPREAD
- spread
- BINPACK
- binpack
- "random"
- random
- "spread"
- spread
- "binpack"
- binpack
PipePropagateTags, PipePropagateTagsArgs
- Task
Definition - TASK_DEFINITION
- Pipe
Propagate Tags Task Definition - TASK_DEFINITION
- Task
Definition - TASK_DEFINITION
- Task
Definition - TASK_DEFINITION
- TASK_DEFINITION
- TASK_DEFINITION
- "TASK_DEFINITION"
- TASK_DEFINITION
PipeRequestedPipeState, PipeRequestedPipeStateArgs
- Running
- RUNNING
- Stopped
- STOPPED
- Pipe
Requested Pipe State Running - RUNNING
- Pipe
Requested Pipe State Stopped - STOPPED
- Running
- RUNNING
- Stopped
- STOPPED
- Running
- RUNNING
- Stopped
- STOPPED
- RUNNING
- RUNNING
- STOPPED
- STOPPED
- "RUNNING"
- RUNNING
- "STOPPED"
- STOPPED
PipeS3LogDestination, PipeS3LogDestinationArgs
- Bucket
Name string - Bucket
Owner string - Output
Format Pulumi.Aws Native. Pipes. Pipe S3Output Format - Prefix string
- Bucket
Name string - Bucket
Owner string - Output
Format PipeS3Output Format - Prefix string
- bucket
Name String - bucket
Owner String - output
Format PipeS3Output Format - prefix String
- bucket
Name string - bucket
Owner string - output
Format PipeS3Output Format - prefix string
- bucket
Name String - bucket
Owner String - output
Format "json" | "plain" | "w3c" - prefix String
PipeS3OutputFormat, PipeS3OutputFormatArgs
- Json
- json
- Plain
- plain
- W3c
- w3c
- Pipe
S3Output Format Json - json
- Pipe
S3Output Format Plain - plain
- Pipe
S3Output Format W3c - w3c
- Json
- json
- Plain
- plain
- W3c
- w3c
- Json
- json
- Plain
- plain
- W3c
- w3c
- JSON
- json
- PLAIN
- plain
- W3C
- w3c
- "json"
- json
- "plain"
- plain
- "w3c"
- w3c
PipeSageMakerPipelineParameter, PipeSageMakerPipelineParameterArgs
PipeSelfManagedKafkaAccessConfigurationCredentials0Properties, PipeSelfManagedKafkaAccessConfigurationCredentials0PropertiesArgs
- Basic
Auth string - Optional SecretManager ARN which stores the database credentials
- Basic
Auth string - Optional SecretManager ARN which stores the database credentials
- basic
Auth String - Optional SecretManager ARN which stores the database credentials
- basic
Auth string - Optional SecretManager ARN which stores the database credentials
- basic_
auth str - Optional SecretManager ARN which stores the database credentials
- basic
Auth String - Optional SecretManager ARN which stores the database credentials
PipeSelfManagedKafkaAccessConfigurationCredentials1Properties, PipeSelfManagedKafkaAccessConfigurationCredentials1PropertiesArgs
- Sasl
Scram512Auth string - Optional SecretManager ARN which stores the database credentials
- Sasl
Scram512Auth string - Optional SecretManager ARN which stores the database credentials
- sasl
Scram512Auth String - Optional SecretManager ARN which stores the database credentials
- sasl
Scram512Auth string - Optional SecretManager ARN which stores the database credentials
- sasl_
scram512_ strauth - Optional SecretManager ARN which stores the database credentials
- sasl
Scram512Auth String - Optional SecretManager ARN which stores the database credentials
PipeSelfManagedKafkaAccessConfigurationCredentials2Properties, PipeSelfManagedKafkaAccessConfigurationCredentials2PropertiesArgs
- Sasl
Scram256Auth string - Optional SecretManager ARN which stores the database credentials
- Sasl
Scram256Auth string - Optional SecretManager ARN which stores the database credentials
- sasl
Scram256Auth String - Optional SecretManager ARN which stores the database credentials
- sasl
Scram256Auth string - Optional SecretManager ARN which stores the database credentials
- sasl_
scram256_ strauth - Optional SecretManager ARN which stores the database credentials
- sasl
Scram256Auth String - Optional SecretManager ARN which stores the database credentials
PipeSelfManagedKafkaAccessConfigurationCredentials3Properties, PipeSelfManagedKafkaAccessConfigurationCredentials3PropertiesArgs
- Client
Certificate stringTls Auth - Optional SecretManager ARN which stores the database credentials
- Client
Certificate stringTls Auth - Optional SecretManager ARN which stores the database credentials
- client
Certificate StringTls Auth - Optional SecretManager ARN which stores the database credentials
- client
Certificate stringTls Auth - Optional SecretManager ARN which stores the database credentials
- client_
certificate_ strtls_ auth - Optional SecretManager ARN which stores the database credentials
- client
Certificate StringTls Auth - Optional SecretManager ARN which stores the database credentials
PipeSelfManagedKafkaAccessConfigurationVpc, PipeSelfManagedKafkaAccessConfigurationVpcArgs
- Security
Group List<string> - List of SecurityGroupId.
- Subnets List<string>
- List of SubnetId.
- Security
Group []string - List of SecurityGroupId.
- Subnets []string
- List of SubnetId.
- security
Group List<String> - List of SecurityGroupId.
- subnets List<String>
- List of SubnetId.
- security
Group string[] - List of SecurityGroupId.
- subnets string[]
- List of SubnetId.
- security_
group Sequence[str] - List of SecurityGroupId.
- subnets Sequence[str]
- List of SubnetId.
- security
Group List<String> - List of SecurityGroupId.
- subnets List<String>
- List of SubnetId.
PipeSelfManagedKafkaStartPosition, PipeSelfManagedKafkaStartPositionArgs
- Trim
Horizon - TRIM_HORIZON
- Latest
- LATEST
- Pipe
Self Managed Kafka Start Position Trim Horizon - TRIM_HORIZON
- Pipe
Self Managed Kafka Start Position Latest - LATEST
- Trim
Horizon - TRIM_HORIZON
- Latest
- LATEST
- Trim
Horizon - TRIM_HORIZON
- Latest
- LATEST
- TRIM_HORIZON
- TRIM_HORIZON
- LATEST
- LATEST
- "TRIM_HORIZON"
- TRIM_HORIZON
- "LATEST"
- LATEST
PipeSourceActiveMqBrokerParameters, PipeSourceActiveMqBrokerParametersArgs
- credentials Property Map
- queue
Name String - batch
Size Number - maximum
Batching NumberWindow In Seconds
PipeSourceDynamoDbStreamParameters, PipeSourceDynamoDbStreamParametersArgs
- Starting
Position Pulumi.Aws Native. Pipes. Pipe Dynamo Db Stream Start Position - Batch
Size int - Dead
Letter Pulumi.Config Aws Native. Pipes. Inputs. Pipe Dead Letter Config - Maximum
Batching intWindow In Seconds - Maximum
Record intAge In Seconds - Maximum
Retry intAttempts - On
Partial Pulumi.Batch Item Failure Aws Native. Pipes. Pipe On Partial Batch Item Failure Streams - Parallelization
Factor int
PipeSourceKinesisStreamParameters, PipeSourceKinesisStreamParametersArgs
- Starting
Position Pulumi.Aws Native. Pipes. Pipe Kinesis Stream Start Position - Batch
Size int - Dead
Letter Pulumi.Config Aws Native. Pipes. Inputs. Pipe Dead Letter Config - Maximum
Batching intWindow In Seconds - Maximum
Record intAge In Seconds - Maximum
Retry intAttempts - On
Partial Pulumi.Batch Item Failure Aws Native. Pipes. Pipe On Partial Batch Item Failure Streams - Parallelization
Factor int - Starting
Position stringTimestamp
- Starting
Position PipeKinesis Stream Start Position - Batch
Size int - Dead
Letter PipeConfig Dead Letter Config - Maximum
Batching intWindow In Seconds - Maximum
Record intAge In Seconds - Maximum
Retry intAttempts - On
Partial PipeBatch Item Failure On Partial Batch Item Failure Streams - Parallelization
Factor int - Starting
Position stringTimestamp
- starting
Position PipeKinesis Stream Start Position - batch
Size Integer - dead
Letter PipeConfig Dead Letter Config - maximum
Batching IntegerWindow In Seconds - maximum
Record IntegerAge In Seconds - maximum
Retry IntegerAttempts - on
Partial PipeBatch Item Failure On Partial Batch Item Failure Streams - parallelization
Factor Integer - starting
Position StringTimestamp
- starting
Position PipeKinesis Stream Start Position - batch
Size number - dead
Letter PipeConfig Dead Letter Config - maximum
Batching numberWindow In Seconds - maximum
Record numberAge In Seconds - maximum
Retry numberAttempts - on
Partial PipeBatch Item Failure On Partial Batch Item Failure Streams - parallelization
Factor number - starting
Position stringTimestamp
- starting_
position PipeKinesis Stream Start Position - batch_
size int - dead_
letter_ Pipeconfig Dead Letter Config - maximum_
batching_ intwindow_ in_ seconds - maximum_
record_ intage_ in_ seconds - maximum_
retry_ intattempts - on_
partial_ Pipebatch_ item_ failure On Partial Batch Item Failure Streams - parallelization_
factor int - starting_
position_ strtimestamp
- starting
Position "TRIM_HORIZON" | "LATEST" | "AT_TIMESTAMP" - batch
Size Number - dead
Letter Property MapConfig - maximum
Batching NumberWindow In Seconds - maximum
Record NumberAge In Seconds - maximum
Retry NumberAttempts - on
Partial "AUTOMATIC_BISECT"Batch Item Failure - parallelization
Factor Number - starting
Position StringTimestamp
PipeSourceManagedStreamingKafkaParameters, PipeSourceManagedStreamingKafkaParametersArgs
PipeSourceParameters, PipeSourceParametersArgs
- Active
Mq Pulumi.Broker Parameters Aws Native. Pipes. Inputs. Pipe Source Active Mq Broker Parameters - Dynamo
Db Pulumi.Stream Parameters Aws Native. Pipes. Inputs. Pipe Source Dynamo Db Stream Parameters - Filter
Criteria Pulumi.Aws Native. Pipes. Inputs. Pipe Filter Criteria - Kinesis
Stream Pulumi.Parameters Aws Native. Pipes. Inputs. Pipe Source Kinesis Stream Parameters - Managed
Streaming Pulumi.Kafka Parameters Aws Native. Pipes. Inputs. Pipe Source Managed Streaming Kafka Parameters - Rabbit
Mq Pulumi.Broker Parameters Aws Native. Pipes. Inputs. Pipe Source Rabbit Mq Broker Parameters - Self
Managed Pulumi.Kafka Parameters Aws Native. Pipes. Inputs. Pipe Source Self Managed Kafka Parameters - Sqs
Queue Pulumi.Parameters Aws Native. Pipes. Inputs. Pipe Source Sqs Queue Parameters
- Active
Mq PipeBroker Parameters Source Active Mq Broker Parameters - Dynamo
Db PipeStream Parameters Source Dynamo Db Stream Parameters - Filter
Criteria PipeFilter Criteria - Kinesis
Stream PipeParameters Source Kinesis Stream Parameters - Managed
Streaming PipeKafka Parameters Source Managed Streaming Kafka Parameters - Rabbit
Mq PipeBroker Parameters Source Rabbit Mq Broker Parameters - Self
Managed PipeKafka Parameters Source Self Managed Kafka Parameters - Sqs
Queue PipeParameters Source Sqs Queue Parameters
- active
Mq PipeBroker Parameters Source Active Mq Broker Parameters - dynamo
Db PipeStream Parameters Source Dynamo Db Stream Parameters - filter
Criteria PipeFilter Criteria - kinesis
Stream PipeParameters Source Kinesis Stream Parameters - managed
Streaming PipeKafka Parameters Source Managed Streaming Kafka Parameters - rabbit
Mq PipeBroker Parameters Source Rabbit Mq Broker Parameters - self
Managed PipeKafka Parameters Source Self Managed Kafka Parameters - sqs
Queue PipeParameters Source Sqs Queue Parameters
- active
Mq PipeBroker Parameters Source Active Mq Broker Parameters - dynamo
Db PipeStream Parameters Source Dynamo Db Stream Parameters - filter
Criteria PipeFilter Criteria - kinesis
Stream PipeParameters Source Kinesis Stream Parameters - managed
Streaming PipeKafka Parameters Source Managed Streaming Kafka Parameters - rabbit
Mq PipeBroker Parameters Source Rabbit Mq Broker Parameters - self
Managed PipeKafka Parameters Source Self Managed Kafka Parameters - sqs
Queue PipeParameters Source Sqs Queue Parameters
- active_
mq_ Pipebroker_ parameters Source Active Mq Broker Parameters - dynamo_
db_ Pipestream_ parameters Source Dynamo Db Stream Parameters - filter_
criteria PipeFilter Criteria - kinesis_
stream_ Pipeparameters Source Kinesis Stream Parameters - managed_
streaming_ Pipekafka_ parameters Source Managed Streaming Kafka Parameters - rabbit_
mq_ Pipebroker_ parameters Source Rabbit Mq Broker Parameters - self_
managed_ Pipekafka_ parameters Source Self Managed Kafka Parameters - sqs_
queue_ Pipeparameters Source Sqs Queue Parameters
PipeSourceRabbitMqBrokerParameters, PipeSourceRabbitMqBrokerParametersArgs
- credentials
Pipe
Mq Broker Access Credentials Properties - queue
Name String - batch
Size Integer - maximum
Batching IntegerWindow In Seconds - virtual
Host String
- credentials
Pipe
Mq Broker Access Credentials Properties - queue
Name string - batch
Size number - maximum
Batching numberWindow In Seconds - virtual
Host string
- credentials Property Map
- queue
Name String - batch
Size Number - maximum
Batching NumberWindow In Seconds - virtual
Host String
PipeSourceSelfManagedKafkaParameters, PipeSourceSelfManagedKafkaParametersArgs
- Topic
Name string - Additional
Bootstrap List<string>Servers - Batch
Size int - Consumer
Group stringId - Credentials
Pulumi.
Aws | Pulumi.Native. Pipes. Inputs. Pipe Self Managed Kafka Access Configuration Credentials0Properties Aws | Pulumi.Native. Pipes. Inputs. Pipe Self Managed Kafka Access Configuration Credentials1Properties Aws | Pulumi.Native. Pipes. Inputs. Pipe Self Managed Kafka Access Configuration Credentials2Properties Aws Native. Pipes. Inputs. Pipe Self Managed Kafka Access Configuration Credentials3Properties - Maximum
Batching intWindow In Seconds - Server
Root stringCa Certificate - Optional SecretManager ARN which stores the database credentials
- Starting
Position Pulumi.Aws Native. Pipes. Pipe Self Managed Kafka Start Position - Vpc
Pulumi.
Aws Native. Pipes. Inputs. Pipe Self Managed Kafka Access Configuration Vpc
- Topic
Name string - Additional
Bootstrap []stringServers - Batch
Size int - Consumer
Group stringId - Credentials
Pipe
Self | PipeManaged Kafka Access Configuration Credentials0Properties Self | PipeManaged Kafka Access Configuration Credentials1Properties Self | PipeManaged Kafka Access Configuration Credentials2Properties Self Managed Kafka Access Configuration Credentials3Properties - Maximum
Batching intWindow In Seconds - Server
Root stringCa Certificate - Optional SecretManager ARN which stores the database credentials
- Starting
Position PipeSelf Managed Kafka Start Position - Vpc
Pipe
Self Managed Kafka Access Configuration Vpc
- topic
Name String - additional
Bootstrap List<String>Servers - batch
Size Integer - consumer
Group StringId - credentials
Pipe
Self | PipeManaged Kafka Access Configuration Credentials0Properties Self | PipeManaged Kafka Access Configuration Credentials1Properties Self | PipeManaged Kafka Access Configuration Credentials2Properties Self Managed Kafka Access Configuration Credentials3Properties - maximum
Batching IntegerWindow In Seconds - server
Root StringCa Certificate - Optional SecretManager ARN which stores the database credentials
- starting
Position PipeSelf Managed Kafka Start Position - vpc
Pipe
Self Managed Kafka Access Configuration Vpc
- topic
Name string - additional
Bootstrap string[]Servers - batch
Size number - consumer
Group stringId - credentials
Pipe
Self | PipeManaged Kafka Access Configuration Credentials0Properties Self | PipeManaged Kafka Access Configuration Credentials1Properties Self | PipeManaged Kafka Access Configuration Credentials2Properties Self Managed Kafka Access Configuration Credentials3Properties - maximum
Batching numberWindow In Seconds - server
Root stringCa Certificate - Optional SecretManager ARN which stores the database credentials
- starting
Position PipeSelf Managed Kafka Start Position - vpc
Pipe
Self Managed Kafka Access Configuration Vpc
- topic_
name str - additional_
bootstrap_ Sequence[str]servers - batch_
size int - consumer_
group_ strid - credentials
Pipe
Self | PipeManaged Kafka Access Configuration Credentials0Properties Self | PipeManaged Kafka Access Configuration Credentials1Properties Self | PipeManaged Kafka Access Configuration Credentials2Properties Self Managed Kafka Access Configuration Credentials3Properties - maximum_
batching_ intwindow_ in_ seconds - server_
root_ strca_ certificate - Optional SecretManager ARN which stores the database credentials
- starting_
position PipeSelf Managed Kafka Start Position - vpc
Pipe
Self Managed Kafka Access Configuration Vpc
- topic
Name String - additional
Bootstrap List<String>Servers - batch
Size Number - consumer
Group StringId - credentials Property Map | Property Map | Property Map | Property Map
- maximum
Batching NumberWindow In Seconds - server
Root StringCa Certificate - Optional SecretManager ARN which stores the database credentials
- starting
Position "TRIM_HORIZON" | "LATEST" - vpc Property Map
PipeSourceSqsQueueParameters, PipeSourceSqsQueueParametersArgs
- batch
Size Integer - maximum
Batching IntegerWindow In Seconds
- batch
Size number - maximum
Batching numberWindow In Seconds
- batch
Size Number - maximum
Batching NumberWindow In Seconds
PipeState, PipeStateArgs
- Running
- RUNNING
- Stopped
- STOPPED
- Creating
- CREATING
- Updating
- UPDATING
- Deleting
- DELETING
- Starting
- STARTING
- Stopping
- STOPPING
- Create
Failed - CREATE_FAILED
- Update
Failed - UPDATE_FAILED
- Start
Failed - START_FAILED
- Stop
Failed - STOP_FAILED
- Delete
Failed - DELETE_FAILED
- Create
Rollback Failed - CREATE_ROLLBACK_FAILED
- Delete
Rollback Failed - DELETE_ROLLBACK_FAILED
- Update
Rollback Failed - UPDATE_ROLLBACK_FAILED
- Pipe
State Running - RUNNING
- Pipe
State Stopped - STOPPED
- Pipe
State Creating - CREATING
- Pipe
State Updating - UPDATING
- Pipe
State Deleting - DELETING
- Pipe
State Starting - STARTING
- Pipe
State Stopping - STOPPING
- Pipe
State Create Failed - CREATE_FAILED
- Pipe
State Update Failed - UPDATE_FAILED
- Pipe
State Start Failed - START_FAILED
- Pipe
State Stop Failed - STOP_FAILED
- Pipe
State Delete Failed - DELETE_FAILED
- Pipe
State Create Rollback Failed - CREATE_ROLLBACK_FAILED
- Pipe
State Delete Rollback Failed - DELETE_ROLLBACK_FAILED
- Pipe
State Update Rollback Failed - UPDATE_ROLLBACK_FAILED
- Running
- RUNNING
- Stopped
- STOPPED
- Creating
- CREATING
- Updating
- UPDATING
- Deleting
- DELETING
- Starting
- STARTING
- Stopping
- STOPPING
- Create
Failed - CREATE_FAILED
- Update
Failed - UPDATE_FAILED
- Start
Failed - START_FAILED
- Stop
Failed - STOP_FAILED
- Delete
Failed - DELETE_FAILED
- Create
Rollback Failed - CREATE_ROLLBACK_FAILED
- Delete
Rollback Failed - DELETE_ROLLBACK_FAILED
- Update
Rollback Failed - UPDATE_ROLLBACK_FAILED
- Running
- RUNNING
- Stopped
- STOPPED
- Creating
- CREATING
- Updating
- UPDATING
- Deleting
- DELETING
- Starting
- STARTING
- Stopping
- STOPPING
- Create
Failed - CREATE_FAILED
- Update
Failed - UPDATE_FAILED
- Start
Failed - START_FAILED
- Stop
Failed - STOP_FAILED
- Delete
Failed - DELETE_FAILED
- Create
Rollback Failed - CREATE_ROLLBACK_FAILED
- Delete
Rollback Failed - DELETE_ROLLBACK_FAILED
- Update
Rollback Failed - UPDATE_ROLLBACK_FAILED
- RUNNING
- RUNNING
- STOPPED
- STOPPED
- CREATING
- CREATING
- UPDATING
- UPDATING
- DELETING
- DELETING
- STARTING
- STARTING
- STOPPING
- STOPPING
- CREATE_FAILED
- CREATE_FAILED
- UPDATE_FAILED
- UPDATE_FAILED
- START_FAILED
- START_FAILED
- STOP_FAILED
- STOP_FAILED
- DELETE_FAILED
- DELETE_FAILED
- CREATE_ROLLBACK_FAILED
- CREATE_ROLLBACK_FAILED
- DELETE_ROLLBACK_FAILED
- DELETE_ROLLBACK_FAILED
- UPDATE_ROLLBACK_FAILED
- UPDATE_ROLLBACK_FAILED
- "RUNNING"
- RUNNING
- "STOPPED"
- STOPPED
- "CREATING"
- CREATING
- "UPDATING"
- UPDATING
- "DELETING"
- DELETING
- "STARTING"
- STARTING
- "STOPPING"
- STOPPING
- "CREATE_FAILED"
- CREATE_FAILED
- "UPDATE_FAILED"
- UPDATE_FAILED
- "START_FAILED"
- START_FAILED
- "STOP_FAILED"
- STOP_FAILED
- "DELETE_FAILED"
- DELETE_FAILED
- "CREATE_ROLLBACK_FAILED"
- CREATE_ROLLBACK_FAILED
- "DELETE_ROLLBACK_FAILED"
- DELETE_ROLLBACK_FAILED
- "UPDATE_ROLLBACK_FAILED"
- UPDATE_ROLLBACK_FAILED
PipeTag, PipeTagArgs
PipeTargetBatchJobParameters, PipeTargetBatchJobParametersArgs
- Job
Definition string - Job
Name string - Array
Properties Pulumi.Aws Native. Pipes. Inputs. Pipe Batch Array Properties - Container
Overrides Pulumi.Aws Native. Pipes. Inputs. Pipe Batch Container Overrides - Depends
On List<Pulumi.Aws Native. Pipes. Inputs. Pipe Batch Job Dependency> - Parameters Dictionary<string, string>
- Retry
Strategy Pulumi.Aws Native. Pipes. Inputs. Pipe Batch Retry Strategy
PipeTargetCloudWatchLogsParameters, PipeTargetCloudWatchLogsParametersArgs
- Log
Stream stringName - Timestamp string
- Log
Stream stringName - Timestamp string
- log
Stream StringName - timestamp String
- log
Stream stringName - timestamp string
- log_
stream_ strname - timestamp str
- log
Stream StringName - timestamp String
PipeTargetEcsTaskParameters, PipeTargetEcsTaskParametersArgs
- Task
Definition stringArn - Capacity
Provider List<Pulumi.Strategy Aws Native. Pipes. Inputs. Pipe Capacity Provider Strategy Item> - bool
- Enable
Execute boolCommand - Group string
- Launch
Type Pulumi.Aws Native. Pipes. Pipe Launch Type - Network
Configuration Pulumi.Aws Native. Pipes. Inputs. Pipe Network Configuration - Overrides
Pulumi.
Aws Native. Pipes. Inputs. Pipe Ecs Task Override - Placement
Constraints List<Pulumi.Aws Native. Pipes. Inputs. Pipe Placement Constraint> - Placement
Strategy List<Pulumi.Aws Native. Pipes. Inputs. Pipe Placement Strategy> - Platform
Version string -
Pulumi.
Aws Native. Pipes. Pipe Propagate Tags - Reference
Id string -
List<Pulumi.
Aws Native. Pipes. Inputs. Pipe Tag> - Task
Count int
- Task
Definition stringArn - Capacity
Provider []PipeStrategy Capacity Provider Strategy Item - bool
- Enable
Execute boolCommand - Group string
- Launch
Type PipeLaunch Type - Network
Configuration PipeNetwork Configuration - Overrides
Pipe
Ecs Task Override - Placement
Constraints []PipePlacement Constraint - Placement
Strategy []PipePlacement Strategy - Platform
Version string -
Pipe
Propagate Tags - Reference
Id string -
[]Pipe
Tag - Task
Count int
- task
Definition StringArn - capacity
Provider List<PipeStrategy Capacity Provider Strategy Item> - Boolean
- enable
Execute BooleanCommand - group String
- launch
Type PipeLaunch Type - network
Configuration PipeNetwork Configuration - overrides
Pipe
Ecs Task Override - placement
Constraints List<PipePlacement Constraint> - placement
Strategy List<PipePlacement Strategy> - platform
Version String -
Pipe
Propagate Tags - reference
Id String -
List<Pipe
Tag> - task
Count Integer
- task
Definition stringArn - capacity
Provider PipeStrategy Capacity Provider Strategy Item[] - boolean
- enable
Execute booleanCommand - group string
- launch
Type PipeLaunch Type - network
Configuration PipeNetwork Configuration - overrides
Pipe
Ecs Task Override - placement
Constraints PipePlacement Constraint[] - placement
Strategy PipePlacement Strategy[] - platform
Version string -
Pipe
Propagate Tags - reference
Id string -
Pipe
Tag[] - task
Count number
- task_
definition_ strarn - capacity_
provider_ Sequence[Pipestrategy Capacity Provider Strategy Item] - bool
- enable_
execute_ boolcommand - group str
- launch_
type PipeLaunch Type - network_
configuration PipeNetwork Configuration - overrides
Pipe
Ecs Task Override - placement_
constraints Sequence[PipePlacement Constraint] - placement_
strategy Sequence[PipePlacement Strategy] - platform_
version str -
Pipe
Propagate Tags - reference_
id str -
Sequence[Pipe
Tag] - task_
count int
- task
Definition StringArn - capacity
Provider List<Property Map>Strategy - Boolean
- enable
Execute BooleanCommand - group String
- launch
Type "EC2" | "FARGATE" | "EXTERNAL" - network
Configuration Property Map - overrides Property Map
- placement
Constraints List<Property Map> - placement
Strategy List<Property Map> - platform
Version String - "TASK_DEFINITION"
- reference
Id String - List<Property Map>
- task
Count Number
PipeTargetEventBridgeEventBusParameters, PipeTargetEventBridgeEventBusParametersArgs
- Detail
Type string - Endpoint
Id string - Resources List<string>
- Source string
- Time string
- Detail
Type string - Endpoint
Id string - Resources []string
- Source string
- Time string
- detail
Type String - endpoint
Id String - resources List<String>
- source String
- time String
- detail
Type string - endpoint
Id string - resources string[]
- source string
- time string
- detail_
type str - endpoint_
id str - resources Sequence[str]
- source str
- time str
- detail
Type String - endpoint
Id String - resources List<String>
- source String
- time String
PipeTargetHttpParameters, PipeTargetHttpParametersArgs
- Header
Parameters Dictionary<string, string> - Path
Parameter List<string>Values - Query
String Dictionary<string, string>Parameters
- Header
Parameters map[string]string - Path
Parameter []stringValues - Query
String map[string]stringParameters
- header
Parameters Map<String,String> - path
Parameter List<String>Values - query
String Map<String,String>Parameters
- header
Parameters {[key: string]: string} - path
Parameter string[]Values - query
String {[key: string]: string}Parameters
- header_
parameters Mapping[str, str] - path_
parameter_ Sequence[str]values - query_
string_ Mapping[str, str]parameters
- header
Parameters Map<String> - path
Parameter List<String>Values - query
String Map<String>Parameters
PipeTargetInvocationType, PipeTargetInvocationTypeArgs
- Request
Response - REQUEST_RESPONSE
- Fire
And Forget - FIRE_AND_FORGET
- Pipe
Target Invocation Type Request Response - REQUEST_RESPONSE
- Pipe
Target Invocation Type Fire And Forget - FIRE_AND_FORGET
- Request
Response - REQUEST_RESPONSE
- Fire
And Forget - FIRE_AND_FORGET
- Request
Response - REQUEST_RESPONSE
- Fire
And Forget - FIRE_AND_FORGET
- REQUEST_RESPONSE
- REQUEST_RESPONSE
- FIRE_AND_FORGET
- FIRE_AND_FORGET
- "REQUEST_RESPONSE"
- REQUEST_RESPONSE
- "FIRE_AND_FORGET"
- FIRE_AND_FORGET
PipeTargetKinesisStreamParameters, PipeTargetKinesisStreamParametersArgs
- Partition
Key string
- Partition
Key string
- partition
Key String
- partition
Key string
- partition_
key str
- partition
Key String
PipeTargetLambdaFunctionParameters, PipeTargetLambdaFunctionParametersArgs
PipeTargetParameters, PipeTargetParametersArgs
- Batch
Job Pulumi.Parameters Aws Native. Pipes. Inputs. Pipe Target Batch Job Parameters - Cloud
Watch Pulumi.Logs Parameters Aws Native. Pipes. Inputs. Pipe Target Cloud Watch Logs Parameters - Ecs
Task Pulumi.Parameters Aws Native. Pipes. Inputs. Pipe Target Ecs Task Parameters - Event
Bridge Pulumi.Event Bus Parameters Aws Native. Pipes. Inputs. Pipe Target Event Bridge Event Bus Parameters - Http
Parameters Pulumi.Aws Native. Pipes. Inputs. Pipe Target Http Parameters - Input
Template string - Kinesis
Stream Pulumi.Parameters Aws Native. Pipes. Inputs. Pipe Target Kinesis Stream Parameters - Lambda
Function Pulumi.Parameters Aws Native. Pipes. Inputs. Pipe Target Lambda Function Parameters - Redshift
Data Pulumi.Parameters Aws Native. Pipes. Inputs. Pipe Target Redshift Data Parameters - Sage
Maker Pulumi.Pipeline Parameters Aws Native. Pipes. Inputs. Pipe Target Sage Maker Pipeline Parameters - Sqs
Queue Pulumi.Parameters Aws Native. Pipes. Inputs. Pipe Target Sqs Queue Parameters - Step
Function Pulumi.State Machine Parameters Aws Native. Pipes. Inputs. Pipe Target State Machine Parameters
- Batch
Job PipeParameters Target Batch Job Parameters - Cloud
Watch PipeLogs Parameters Target Cloud Watch Logs Parameters - Ecs
Task PipeParameters Target Ecs Task Parameters - Event
Bridge PipeEvent Bus Parameters Target Event Bridge Event Bus Parameters - Http
Parameters PipeTarget Http Parameters - Input
Template string - Kinesis
Stream PipeParameters Target Kinesis Stream Parameters - Lambda
Function PipeParameters Target Lambda Function Parameters - Redshift
Data PipeParameters Target Redshift Data Parameters - Sage
Maker PipePipeline Parameters Target Sage Maker Pipeline Parameters - Sqs
Queue PipeParameters Target Sqs Queue Parameters - Step
Function PipeState Machine Parameters Target State Machine Parameters
- batch
Job PipeParameters Target Batch Job Parameters - cloud
Watch PipeLogs Parameters Target Cloud Watch Logs Parameters - ecs
Task PipeParameters Target Ecs Task Parameters - event
Bridge PipeEvent Bus Parameters Target Event Bridge Event Bus Parameters - http
Parameters PipeTarget Http Parameters - input
Template String - kinesis
Stream PipeParameters Target Kinesis Stream Parameters - lambda
Function PipeParameters Target Lambda Function Parameters - redshift
Data PipeParameters Target Redshift Data Parameters - sage
Maker PipePipeline Parameters Target Sage Maker Pipeline Parameters - sqs
Queue PipeParameters Target Sqs Queue Parameters - step
Function PipeState Machine Parameters Target State Machine Parameters
- batch
Job PipeParameters Target Batch Job Parameters - cloud
Watch PipeLogs Parameters Target Cloud Watch Logs Parameters - ecs
Task PipeParameters Target Ecs Task Parameters - event
Bridge PipeEvent Bus Parameters Target Event Bridge Event Bus Parameters - http
Parameters PipeTarget Http Parameters - input
Template string - kinesis
Stream PipeParameters Target Kinesis Stream Parameters - lambda
Function PipeParameters Target Lambda Function Parameters - redshift
Data PipeParameters Target Redshift Data Parameters - sage
Maker PipePipeline Parameters Target Sage Maker Pipeline Parameters - sqs
Queue PipeParameters Target Sqs Queue Parameters - step
Function PipeState Machine Parameters Target State Machine Parameters
- batch_
job_ Pipeparameters Target Batch Job Parameters - cloud_
watch_ Pipelogs_ parameters Target Cloud Watch Logs Parameters - ecs_
task_ Pipeparameters Target Ecs Task Parameters - event_
bridge_ Pipeevent_ bus_ parameters Target Event Bridge Event Bus Parameters - http_
parameters PipeTarget Http Parameters - input_
template str - kinesis_
stream_ Pipeparameters Target Kinesis Stream Parameters - lambda_
function_ Pipeparameters Target Lambda Function Parameters - redshift_
data_ Pipeparameters Target Redshift Data Parameters - sage_
maker_ Pipepipeline_ parameters Target Sage Maker Pipeline Parameters - sqs_
queue_ Pipeparameters Target Sqs Queue Parameters - step_
function_ Pipestate_ machine_ parameters Target State Machine Parameters
- batch
Job Property MapParameters - cloud
Watch Property MapLogs Parameters - ecs
Task Property MapParameters - event
Bridge Property MapEvent Bus Parameters - http
Parameters Property Map - input
Template String - kinesis
Stream Property MapParameters - lambda
Function Property MapParameters - redshift
Data Property MapParameters - sage
Maker Property MapPipeline Parameters - sqs
Queue Property MapParameters - step
Function Property MapState Machine Parameters
PipeTargetRedshiftDataParameters, PipeTargetRedshiftDataParametersArgs
- Database string
- Redshift Database
- Sqls List<string>
- A list of SQLs.
- Db
User string - Database user name
- Secret
Manager stringArn - Optional SecretManager ARN which stores the database credentials
- Statement
Name string - A name for Redshift DataAPI statement which can be used as filter of ListStatement.
- With
Event bool
- Database string
- Redshift Database
- Sqls []string
- A list of SQLs.
- Db
User string - Database user name
- Secret
Manager stringArn - Optional SecretManager ARN which stores the database credentials
- Statement
Name string - A name for Redshift DataAPI statement which can be used as filter of ListStatement.
- With
Event bool
- database String
- Redshift Database
- sqls List<String>
- A list of SQLs.
- db
User String - Database user name
- secret
Manager StringArn - Optional SecretManager ARN which stores the database credentials
- statement
Name String - A name for Redshift DataAPI statement which can be used as filter of ListStatement.
- with
Event Boolean
- database string
- Redshift Database
- sqls string[]
- A list of SQLs.
- db
User string - Database user name
- secret
Manager stringArn - Optional SecretManager ARN which stores the database credentials
- statement
Name string - A name for Redshift DataAPI statement which can be used as filter of ListStatement.
- with
Event boolean
- database str
- Redshift Database
- sqls Sequence[str]
- A list of SQLs.
- db_
user str - Database user name
- secret_
manager_ strarn - Optional SecretManager ARN which stores the database credentials
- statement_
name str - A name for Redshift DataAPI statement which can be used as filter of ListStatement.
- with_
event bool
- database String
- Redshift Database
- sqls List<String>
- A list of SQLs.
- db
User String - Database user name
- secret
Manager StringArn - Optional SecretManager ARN which stores the database credentials
- statement
Name String - A name for Redshift DataAPI statement which can be used as filter of ListStatement.
- with
Event Boolean
PipeTargetSageMakerPipelineParameters, PipeTargetSageMakerPipelineParametersArgs
PipeTargetSqsQueueParameters, PipeTargetSqsQueueParametersArgs
- Message
Deduplication stringId - Message
Group stringId
- Message
Deduplication stringId - Message
Group stringId
- message
Deduplication StringId - message
Group StringId
- message
Deduplication stringId - message
Group stringId
- message
Deduplication StringId - message
Group StringId
PipeTargetStateMachineParameters, PipeTargetStateMachineParametersArgs
Package Details
- Repository
- AWS Native pulumi/pulumi-aws-native
- License
- Apache-2.0
AWS Native is in preview. AWS Classic is fully supported.
AWS Native v0.102.0 published on Tuesday, Apr 16, 2024 by Pulumi