Pipeline
data class PipelineDefinitionArgs(val parameterObjects: Output<List<PipelineDefinitionParameterObjectArgs>>? = null, val parameterValues: Output<List<PipelineDefinitionParameterValueArgs>>? = null, val pipelineId: Output<String>? = null, val pipelineObjects: Output<List<PipelineDefinitionPipelineObjectArgs>>? = null) : ConvertibleToJava<PipelineDefinitionArgs>
Provides a DataPipeline Pipeline Definition resource.
Example Usage
import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";
const _default = new aws.datapipeline.Pipeline("default", {name: "tf-pipeline-default"});
const example = new aws.datapipeline.PipelineDefinition("example", {
pipelineId: _default.id,
pipelineObjects: [
{
id: "Default",
name: "Default",
fields: [{
key: "workerGroup",
stringValue: "workerGroup",
}],
},
{
id: "Schedule",
name: "Schedule",
fields: [
{
key: "startDateTime",
stringValue: "2012-12-12T00:00:00",
},
{
key: "type",
stringValue: "Schedule",
},
{
key: "period",
stringValue: "1 hour",
},
{
key: "endDateTime",
stringValue: "2012-12-21T18:00:00",
},
],
},
{
id: "SayHello",
name: "SayHello",
fields: [
{
key: "type",
stringValue: "ShellCommandActivity",
},
{
key: "command",
stringValue: "echo hello",
},
{
key: "parent",
stringValue: "Default",
},
{
key: "schedule",
stringValue: "Schedule",
},
],
},
],
});Content copied to clipboard
import pulumi
import pulumi_aws as aws
default = aws.datapipeline.Pipeline("default", name="tf-pipeline-default")
example = aws.datapipeline.PipelineDefinition("example",
pipeline_id=default.id,
pipeline_objects=[
{
"id": "Default",
"name": "Default",
"fields": [{
"key": "workerGroup",
"string_value": "workerGroup",
}],
},
{
"id": "Schedule",
"name": "Schedule",
"fields": [
{
"key": "startDateTime",
"string_value": "2012-12-12T00:00:00",
},
{
"key": "type",
"string_value": "Schedule",
},
{
"key": "period",
"string_value": "1 hour",
},
{
"key": "endDateTime",
"string_value": "2012-12-21T18:00:00",
},
],
},
{
"id": "SayHello",
"name": "SayHello",
"fields": [
{
"key": "type",
"string_value": "ShellCommandActivity",
},
{
"key": "command",
"string_value": "echo hello",
},
{
"key": "parent",
"string_value": "Default",
},
{
"key": "schedule",
"string_value": "Schedule",
},
],
},
])Content copied to clipboard
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;
return await Deployment.RunAsync(() =>
{
var @default = new Aws.DataPipeline.Pipeline("default", new()
{
Name = "tf-pipeline-default",
});
var example = new Aws.DataPipeline.PipelineDefinition("example", new()
{
PipelineId = @default.Id,
PipelineObjects = new[]
{
new Aws.DataPipeline.Inputs.PipelineDefinitionPipelineObjectArgs
{
Id = "Default",
Name = "Default",
Fields = new[]
{
new Aws.DataPipeline.Inputs.PipelineDefinitionPipelineObjectFieldArgs
{
Key = "workerGroup",
StringValue = "workerGroup",
},
},
},
new Aws.DataPipeline.Inputs.PipelineDefinitionPipelineObjectArgs
{
Id = "Schedule",
Name = "Schedule",
Fields = new[]
{
new Aws.DataPipeline.Inputs.PipelineDefinitionPipelineObjectFieldArgs
{
Key = "startDateTime",
StringValue = "2012-12-12T00:00:00",
},
new Aws.DataPipeline.Inputs.PipelineDefinitionPipelineObjectFieldArgs
{
Key = "type",
StringValue = "Schedule",
},
new Aws.DataPipeline.Inputs.PipelineDefinitionPipelineObjectFieldArgs
{
Key = "period",
StringValue = "1 hour",
},
new Aws.DataPipeline.Inputs.PipelineDefinitionPipelineObjectFieldArgs
{
Key = "endDateTime",
StringValue = "2012-12-21T18:00:00",
},
},
},
new Aws.DataPipeline.Inputs.PipelineDefinitionPipelineObjectArgs
{
Id = "SayHello",
Name = "SayHello",
Fields = new[]
{
new Aws.DataPipeline.Inputs.PipelineDefinitionPipelineObjectFieldArgs
{
Key = "type",
StringValue = "ShellCommandActivity",
},
new Aws.DataPipeline.Inputs.PipelineDefinitionPipelineObjectFieldArgs
{
Key = "command",
StringValue = "echo hello",
},
new Aws.DataPipeline.Inputs.PipelineDefinitionPipelineObjectFieldArgs
{
Key = "parent",
StringValue = "Default",
},
new Aws.DataPipeline.Inputs.PipelineDefinitionPipelineObjectFieldArgs
{
Key = "schedule",
StringValue = "Schedule",
},
},
},
},
});
});Content copied to clipboard
package main
import (
"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/datapipeline"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_default, err := datapipeline.NewPipeline(ctx, "default", &datapipeline.PipelineArgs{
Name: pulumi.String("tf-pipeline-default"),
})
if err != nil {
return err
}
_, err = datapipeline.NewPipelineDefinition(ctx, "example", &datapipeline.PipelineDefinitionArgs{
PipelineId: _default.ID(),
PipelineObjects: datapipeline.PipelineDefinitionPipelineObjectArray{
&datapipeline.PipelineDefinitionPipelineObjectArgs{
Id: pulumi.String("Default"),
Name: pulumi.String("Default"),
Fields: datapipeline.PipelineDefinitionPipelineObjectFieldArray{
&datapipeline.PipelineDefinitionPipelineObjectFieldArgs{
Key: pulumi.String("workerGroup"),
StringValue: pulumi.String("workerGroup"),
},
},
},
&datapipeline.PipelineDefinitionPipelineObjectArgs{
Id: pulumi.String("Schedule"),
Name: pulumi.String("Schedule"),
Fields: datapipeline.PipelineDefinitionPipelineObjectFieldArray{
&datapipeline.PipelineDefinitionPipelineObjectFieldArgs{
Key: pulumi.String("startDateTime"),
StringValue: pulumi.String("2012-12-12T00:00:00"),
},
&datapipeline.PipelineDefinitionPipelineObjectFieldArgs{
Key: pulumi.String("type"),
StringValue: pulumi.String("Schedule"),
},
&datapipeline.PipelineDefinitionPipelineObjectFieldArgs{
Key: pulumi.String("period"),
StringValue: pulumi.String("1 hour"),
},
&datapipeline.PipelineDefinitionPipelineObjectFieldArgs{
Key: pulumi.String("endDateTime"),
StringValue: pulumi.String("2012-12-21T18:00:00"),
},
},
},
&datapipeline.PipelineDefinitionPipelineObjectArgs{
Id: pulumi.String("SayHello"),
Name: pulumi.String("SayHello"),
Fields: datapipeline.PipelineDefinitionPipelineObjectFieldArray{
&datapipeline.PipelineDefinitionPipelineObjectFieldArgs{
Key: pulumi.String("type"),
StringValue: pulumi.String("ShellCommandActivity"),
},
&datapipeline.PipelineDefinitionPipelineObjectFieldArgs{
Key: pulumi.String("command"),
StringValue: pulumi.String("echo hello"),
},
&datapipeline.PipelineDefinitionPipelineObjectFieldArgs{
Key: pulumi.String("parent"),
StringValue: pulumi.String("Default"),
},
&datapipeline.PipelineDefinitionPipelineObjectFieldArgs{
Key: pulumi.String("schedule"),
StringValue: pulumi.String("Schedule"),
},
},
},
},
})
if err != nil {
return err
}
return nil
})
}Content copied to clipboard
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.datapipeline.Pipeline;
import com.pulumi.aws.datapipeline.PipelineArgs;
import com.pulumi.aws.datapipeline.PipelineDefinition;
import com.pulumi.aws.datapipeline.PipelineDefinitionArgs;
import com.pulumi.aws.datapipeline.inputs.PipelineDefinitionPipelineObjectArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var default_ = new Pipeline("default", PipelineArgs.builder()
.name("tf-pipeline-default")
.build());
var example = new PipelineDefinition("example", PipelineDefinitionArgs.builder()
.pipelineId(default_.id())
.pipelineObjects(
PipelineDefinitionPipelineObjectArgs.builder()
.id("Default")
.name("Default")
.fields(PipelineDefinitionPipelineObjectFieldArgs.builder()
.key("workerGroup")
.stringValue("workerGroup")
.build())
.build(),
PipelineDefinitionPipelineObjectArgs.builder()
.id("Schedule")
.name("Schedule")
.fields(
PipelineDefinitionPipelineObjectFieldArgs.builder()
.key("startDateTime")
.stringValue("2012-12-12T00:00:00")
.build(),
PipelineDefinitionPipelineObjectFieldArgs.builder()
.key("type")
.stringValue("Schedule")
.build(),
PipelineDefinitionPipelineObjectFieldArgs.builder()
.key("period")
.stringValue("1 hour")
.build(),
PipelineDefinitionPipelineObjectFieldArgs.builder()
.key("endDateTime")
.stringValue("2012-12-21T18:00:00")
.build())
.build(),
PipelineDefinitionPipelineObjectArgs.builder()
.id("SayHello")
.name("SayHello")
.fields(
PipelineDefinitionPipelineObjectFieldArgs.builder()
.key("type")
.stringValue("ShellCommandActivity")
.build(),
PipelineDefinitionPipelineObjectFieldArgs.builder()
.key("command")
.stringValue("echo hello")
.build(),
PipelineDefinitionPipelineObjectFieldArgs.builder()
.key("parent")
.stringValue("Default")
.build(),
PipelineDefinitionPipelineObjectFieldArgs.builder()
.key("schedule")
.stringValue("Schedule")
.build())
.build())
.build());
}
}Content copied to clipboard
resources:
default:
type: aws:datapipeline:Pipeline
properties:
name: tf-pipeline-default
example:
type: aws:datapipeline:PipelineDefinition
properties:
pipelineId: ${default.id}
pipelineObjects:
- id: Default
name: Default
fields:
- key: workerGroup
stringValue: workerGroup
- id: Schedule
name: Schedule
fields:
- key: startDateTime
stringValue: 2012-12-12T00:00:00
- key: type
stringValue: Schedule
- key: period
stringValue: 1 hour
- key: endDateTime
stringValue: 2012-12-21T18:00:00
- id: SayHello
name: SayHello
fields:
- key: type
stringValue: ShellCommandActivity
- key: command
stringValue: echo hello
- key: parent
stringValue: Default
- key: schedule
stringValue: ScheduleContent copied to clipboard
Import
Using pulumi import, import aws_datapipeline_pipeline_definition using the id. For example:
$ pulumi import aws:datapipeline/pipelineDefinition:PipelineDefinition example df-1234567890Content copied to clipboard
Constructors
Link copied to clipboard
constructor(parameterObjects: Output<List<PipelineDefinitionParameterObjectArgs>>? = null, parameterValues: Output<List<PipelineDefinitionParameterValueArgs>>? = null, pipelineId: Output<String>? = null, pipelineObjects: Output<List<PipelineDefinitionPipelineObjectArgs>>? = null)
Properties
Link copied to clipboard
Configuration block for the parameter objects used in the pipeline definition. See below
Link copied to clipboard
Configuration block for the parameter values used in the pipeline definition. See below
Link copied to clipboard
ID of the pipeline.
Link copied to clipboard
Configuration block for the objects that define the pipeline. See below The following arguments are optional: