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=[
aws.datapipeline.PipelineDefinitionPipelineObjectArgs(
id="Default",
name="Default",
fields=[aws.datapipeline.PipelineDefinitionPipelineObjectFieldArgs(
key="workerGroup",
string_value="workerGroup",
)],
),
aws.datapipeline.PipelineDefinitionPipelineObjectArgs(
id="Schedule",
name="Schedule",
fields=[
aws.datapipeline.PipelineDefinitionPipelineObjectFieldArgs(
key="startDateTime",
string_value="2012-12-12T00:00:00",
),
aws.datapipeline.PipelineDefinitionPipelineObjectFieldArgs(
key="type",
string_value="Schedule",
),
aws.datapipeline.PipelineDefinitionPipelineObjectFieldArgs(
key="period",
string_value="1 hour",
),
aws.datapipeline.PipelineDefinitionPipelineObjectFieldArgs(
key="endDateTime",
string_value="2012-12-21T18:00:00",
),
],
),
aws.datapipeline.PipelineDefinitionPipelineObjectArgs(
id="SayHello",
name="SayHello",
fields=[
aws.datapipeline.PipelineDefinitionPipelineObjectFieldArgs(
key="type",
string_value="ShellCommandActivity",
),
aws.datapipeline.PipelineDefinitionPipelineObjectFieldArgs(
key="command",
string_value="echo hello",
),
aws.datapipeline.PipelineDefinitionPipelineObjectFieldArgs(
key="parent",
string_value="Default",
),
aws.datapipeline.PipelineDefinitionPipelineObjectFieldArgs(
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 {
_, 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
fun PipelineDefinitionArgs(parameterObjects: Output<List<PipelineDefinitionParameterObjectArgs>>? = null, parameterValues: Output<List<PipelineDefinitionParameterValueArgs>>? = null, pipelineId: Output<String>? = null, pipelineObjects: Output<List<PipelineDefinitionPipelineObjectArgs>>? = null)