Docs Home Pulumi IaC Pulumi ESC Pulumi Insights Pulumi Cloud Packages Tutorials
  1. Packages
  2. AWS
  3. API Docs
  4. glue
  5. getScript
AWS v6.76.0 published on Tuesday, Apr 8, 2025 by Pulumi
pulumi/pulumi-aws

aws.glue.getScript

Explore with Pulumi AI

AWS v6.76.0 published on Tuesday, Apr 8, 2025 by Pulumi
pulumi/pulumi-aws

Use this data source to generate a Glue script from a Directed Acyclic Graph (DAG).

Example Usage

Generate Python Script

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";

const example = aws.glue.getScript({
    language: "PYTHON",
    dagEdges: [
        {
            source: "datasource0",
            target: "applymapping1",
        },
        {
            source: "applymapping1",
            target: "selectfields2",
        },
        {
            source: "selectfields2",
            target: "resolvechoice3",
        },
        {
            source: "resolvechoice3",
            target: "datasink4",
        },
    ],
    dagNodes: [
        {
            id: "datasource0",
            nodeType: "DataSource",
            args: [
                {
                    name: "database",
                    value: `"${source.name}"`,
                },
                {
                    name: "table_name",
                    value: `"${sourceAwsGlueCatalogTable.name}"`,
                },
            ],
        },
        {
            id: "applymapping1",
            nodeType: "ApplyMapping",
            args: [{
                name: "mapping",
                value: "[(\"column1\", \"string\", \"column1\", \"string\")]",
            }],
        },
        {
            id: "selectfields2",
            nodeType: "SelectFields",
            args: [{
                name: "paths",
                value: "[\"column1\"]",
            }],
        },
        {
            id: "resolvechoice3",
            nodeType: "ResolveChoice",
            args: [
                {
                    name: "choice",
                    value: "\"MATCH_CATALOG\"",
                },
                {
                    name: "database",
                    value: `"${destination.name}"`,
                },
                {
                    name: "table_name",
                    value: `"${destinationAwsGlueCatalogTable.name}"`,
                },
            ],
        },
        {
            id: "datasink4",
            nodeType: "DataSink",
            args: [
                {
                    name: "database",
                    value: `"${destination.name}"`,
                },
                {
                    name: "table_name",
                    value: `"${destinationAwsGlueCatalogTable.name}"`,
                },
            ],
        },
    ],
});
export const pythonScript = example.then(example => example.pythonScript);
Copy
import pulumi
import pulumi_aws as aws

example = aws.glue.get_script(language="PYTHON",
    dag_edges=[
        {
            "source": "datasource0",
            "target": "applymapping1",
        },
        {
            "source": "applymapping1",
            "target": "selectfields2",
        },
        {
            "source": "selectfields2",
            "target": "resolvechoice3",
        },
        {
            "source": "resolvechoice3",
            "target": "datasink4",
        },
    ],
    dag_nodes=[
        {
            "id": "datasource0",
            "node_type": "DataSource",
            "args": [
                {
                    "name": "database",
                    "value": f"\"{source['name']}\"",
                },
                {
                    "name": "table_name",
                    "value": f"\"{source_aws_glue_catalog_table['name']}\"",
                },
            ],
        },
        {
            "id": "applymapping1",
            "node_type": "ApplyMapping",
            "args": [{
                "name": "mapping",
                "value": "[(\"column1\", \"string\", \"column1\", \"string\")]",
            }],
        },
        {
            "id": "selectfields2",
            "node_type": "SelectFields",
            "args": [{
                "name": "paths",
                "value": "[\"column1\"]",
            }],
        },
        {
            "id": "resolvechoice3",
            "node_type": "ResolveChoice",
            "args": [
                {
                    "name": "choice",
                    "value": "\"MATCH_CATALOG\"",
                },
                {
                    "name": "database",
                    "value": f"\"{destination['name']}\"",
                },
                {
                    "name": "table_name",
                    "value": f"\"{destination_aws_glue_catalog_table['name']}\"",
                },
            ],
        },
        {
            "id": "datasink4",
            "node_type": "DataSink",
            "args": [
                {
                    "name": "database",
                    "value": f"\"{destination['name']}\"",
                },
                {
                    "name": "table_name",
                    "value": f"\"{destination_aws_glue_catalog_table['name']}\"",
                },
            ],
        },
    ])
pulumi.export("pythonScript", example.python_script)
Copy
package main

import (
	"fmt"

	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/glue"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		example, err := glue.GetScript(ctx, &glue.GetScriptArgs{
			Language: pulumi.StringRef("PYTHON"),
			DagEdges: []glue.GetScriptDagEdge{
				{
					Source: "datasource0",
					Target: "applymapping1",
				},
				{
					Source: "applymapping1",
					Target: "selectfields2",
				},
				{
					Source: "selectfields2",
					Target: "resolvechoice3",
				},
				{
					Source: "resolvechoice3",
					Target: "datasink4",
				},
			},
			DagNodes: []glue.GetScriptDagNode{
				{
					Id:       "datasource0",
					NodeType: "DataSource",
					Args: []glue.GetScriptDagNodeArg{
						{
							Name:  "database",
							Value: fmt.Sprintf("\"%v\"", source.Name),
						},
						{
							Name:  "table_name",
							Value: fmt.Sprintf("\"%v\"", sourceAwsGlueCatalogTable.Name),
						},
					},
				},
				{
					Id:       "applymapping1",
					NodeType: "ApplyMapping",
					Args: []glue.GetScriptDagNodeArg{
						{
							Name:  "mapping",
							Value: "[(\"column1\", \"string\", \"column1\", \"string\")]",
						},
					},
				},
				{
					Id:       "selectfields2",
					NodeType: "SelectFields",
					Args: []glue.GetScriptDagNodeArg{
						{
							Name:  "paths",
							Value: "[\"column1\"]",
						},
					},
				},
				{
					Id:       "resolvechoice3",
					NodeType: "ResolveChoice",
					Args: []glue.GetScriptDagNodeArg{
						{
							Name:  "choice",
							Value: "\"MATCH_CATALOG\"",
						},
						{
							Name:  "database",
							Value: fmt.Sprintf("\"%v\"", destination.Name),
						},
						{
							Name:  "table_name",
							Value: fmt.Sprintf("\"%v\"", destinationAwsGlueCatalogTable.Name),
						},
					},
				},
				{
					Id:       "datasink4",
					NodeType: "DataSink",
					Args: []glue.GetScriptDagNodeArg{
						{
							Name:  "database",
							Value: fmt.Sprintf("\"%v\"", destination.Name),
						},
						{
							Name:  "table_name",
							Value: fmt.Sprintf("\"%v\"", destinationAwsGlueCatalogTable.Name),
						},
					},
				},
			},
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("pythonScript", example.PythonScript)
		return nil
	})
}
Copy
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;

return await Deployment.RunAsync(() => 
{
    var example = Aws.Glue.GetScript.Invoke(new()
    {
        Language = "PYTHON",
        DagEdges = new[]
        {
            new Aws.Glue.Inputs.GetScriptDagEdgeInputArgs
            {
                Source = "datasource0",
                Target = "applymapping1",
            },
            new Aws.Glue.Inputs.GetScriptDagEdgeInputArgs
            {
                Source = "applymapping1",
                Target = "selectfields2",
            },
            new Aws.Glue.Inputs.GetScriptDagEdgeInputArgs
            {
                Source = "selectfields2",
                Target = "resolvechoice3",
            },
            new Aws.Glue.Inputs.GetScriptDagEdgeInputArgs
            {
                Source = "resolvechoice3",
                Target = "datasink4",
            },
        },
        DagNodes = new[]
        {
            new Aws.Glue.Inputs.GetScriptDagNodeInputArgs
            {
                Id = "datasource0",
                NodeType = "DataSource",
                Args = new[]
                {
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "database",
                        Value = $"\"{source.Name}\"",
                    },
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "table_name",
                        Value = $"\"{sourceAwsGlueCatalogTable.Name}\"",
                    },
                },
            },
            new Aws.Glue.Inputs.GetScriptDagNodeInputArgs
            {
                Id = "applymapping1",
                NodeType = "ApplyMapping",
                Args = new[]
                {
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "mapping",
                        Value = "[(\"column1\", \"string\", \"column1\", \"string\")]",
                    },
                },
            },
            new Aws.Glue.Inputs.GetScriptDagNodeInputArgs
            {
                Id = "selectfields2",
                NodeType = "SelectFields",
                Args = new[]
                {
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "paths",
                        Value = "[\"column1\"]",
                    },
                },
            },
            new Aws.Glue.Inputs.GetScriptDagNodeInputArgs
            {
                Id = "resolvechoice3",
                NodeType = "ResolveChoice",
                Args = new[]
                {
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "choice",
                        Value = "\"MATCH_CATALOG\"",
                    },
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "database",
                        Value = $"\"{destination.Name}\"",
                    },
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "table_name",
                        Value = $"\"{destinationAwsGlueCatalogTable.Name}\"",
                    },
                },
            },
            new Aws.Glue.Inputs.GetScriptDagNodeInputArgs
            {
                Id = "datasink4",
                NodeType = "DataSink",
                Args = new[]
                {
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "database",
                        Value = $"\"{destination.Name}\"",
                    },
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "table_name",
                        Value = $"\"{destinationAwsGlueCatalogTable.Name}\"",
                    },
                },
            },
        },
    });

    return new Dictionary<string, object?>
    {
        ["pythonScript"] = example.Apply(getScriptResult => getScriptResult.PythonScript),
    };
});
Copy
package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.glue.GlueFunctions;
import com.pulumi.aws.glue.inputs.GetScriptArgs;
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) {
        final var example = GlueFunctions.getScript(GetScriptArgs.builder()
            .language("PYTHON")
            .dagEdges(            
                GetScriptDagEdgeArgs.builder()
                    .source("datasource0")
                    .target("applymapping1")
                    .build(),
                GetScriptDagEdgeArgs.builder()
                    .source("applymapping1")
                    .target("selectfields2")
                    .build(),
                GetScriptDagEdgeArgs.builder()
                    .source("selectfields2")
                    .target("resolvechoice3")
                    .build(),
                GetScriptDagEdgeArgs.builder()
                    .source("resolvechoice3")
                    .target("datasink4")
                    .build())
            .dagNodes(            
                GetScriptDagNodeArgs.builder()
                    .id("datasource0")
                    .nodeType("DataSource")
                    .args(                    
                        GetScriptDagNodeArgArgs.builder()
                            .name("database")
                            .value(String.format("\"%s\"", source.name()))
                            .build(),
                        GetScriptDagNodeArgArgs.builder()
                            .name("table_name")
                            .value(String.format("\"%s\"", sourceAwsGlueCatalogTable.name()))
                            .build())
                    .build(),
                GetScriptDagNodeArgs.builder()
                    .id("applymapping1")
                    .nodeType("ApplyMapping")
                    .args(GetScriptDagNodeArgArgs.builder()
                        .name("mapping")
                        .value("[(\"column1\", \"string\", \"column1\", \"string\")]")
                        .build())
                    .build(),
                GetScriptDagNodeArgs.builder()
                    .id("selectfields2")
                    .nodeType("SelectFields")
                    .args(GetScriptDagNodeArgArgs.builder()
                        .name("paths")
                        .value("[\"column1\"]")
                        .build())
                    .build(),
                GetScriptDagNodeArgs.builder()
                    .id("resolvechoice3")
                    .nodeType("ResolveChoice")
                    .args(                    
                        GetScriptDagNodeArgArgs.builder()
                            .name("choice")
                            .value("\"MATCH_CATALOG\"")
                            .build(),
                        GetScriptDagNodeArgArgs.builder()
                            .name("database")
                            .value(String.format("\"%s\"", destination.name()))
                            .build(),
                        GetScriptDagNodeArgArgs.builder()
                            .name("table_name")
                            .value(String.format("\"%s\"", destinationAwsGlueCatalogTable.name()))
                            .build())
                    .build(),
                GetScriptDagNodeArgs.builder()
                    .id("datasink4")
                    .nodeType("DataSink")
                    .args(                    
                        GetScriptDagNodeArgArgs.builder()
                            .name("database")
                            .value(String.format("\"%s\"", destination.name()))
                            .build(),
                        GetScriptDagNodeArgArgs.builder()
                            .name("table_name")
                            .value(String.format("\"%s\"", destinationAwsGlueCatalogTable.name()))
                            .build())
                    .build())
            .build());

        ctx.export("pythonScript", example.applyValue(getScriptResult -> getScriptResult.pythonScript()));
    }
}
Copy
variables:
  example:
    fn::invoke:
      function: aws:glue:getScript
      arguments:
        language: PYTHON
        dagEdges:
          - source: datasource0
            target: applymapping1
          - source: applymapping1
            target: selectfields2
          - source: selectfields2
            target: resolvechoice3
          - source: resolvechoice3
            target: datasink4
        dagNodes:
          - id: datasource0
            nodeType: DataSource
            args:
              - name: database
                value: '"${source.name}"'
              - name: table_name
                value: '"${sourceAwsGlueCatalogTable.name}"'
          - id: applymapping1
            nodeType: ApplyMapping
            args:
              - name: mapping
                value: '[("column1", "string", "column1", "string")]'
          - id: selectfields2
            nodeType: SelectFields
            args:
              - name: paths
                value: '["column1"]'
          - id: resolvechoice3
            nodeType: ResolveChoice
            args:
              - name: choice
                value: '"MATCH_CATALOG"'
              - name: database
                value: '"${destination.name}"'
              - name: table_name
                value: '"${destinationAwsGlueCatalogTable.name}"'
          - id: datasink4
            nodeType: DataSink
            args:
              - name: database
                value: '"${destination.name}"'
              - name: table_name
                value: '"${destinationAwsGlueCatalogTable.name}"'
outputs:
  pythonScript: ${example.pythonScript}
Copy

Generate Scala Code

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";

const example = aws.glue.getScript({
    language: "SCALA",
    dagEdges: [
        {
            source: "datasource0",
            target: "applymapping1",
        },
        {
            source: "applymapping1",
            target: "selectfields2",
        },
        {
            source: "selectfields2",
            target: "resolvechoice3",
        },
        {
            source: "resolvechoice3",
            target: "datasink4",
        },
    ],
    dagNodes: [
        {
            id: "datasource0",
            nodeType: "DataSource",
            args: [
                {
                    name: "database",
                    value: `"${source.name}"`,
                },
                {
                    name: "table_name",
                    value: `"${sourceAwsGlueCatalogTable.name}"`,
                },
            ],
        },
        {
            id: "applymapping1",
            nodeType: "ApplyMapping",
            args: [{
                name: "mappings",
                value: "[(\"column1\", \"string\", \"column1\", \"string\")]",
            }],
        },
        {
            id: "selectfields2",
            nodeType: "SelectFields",
            args: [{
                name: "paths",
                value: "[\"column1\"]",
            }],
        },
        {
            id: "resolvechoice3",
            nodeType: "ResolveChoice",
            args: [
                {
                    name: "choice",
                    value: "\"MATCH_CATALOG\"",
                },
                {
                    name: "database",
                    value: `"${destination.name}"`,
                },
                {
                    name: "table_name",
                    value: `"${destinationAwsGlueCatalogTable.name}"`,
                },
            ],
        },
        {
            id: "datasink4",
            nodeType: "DataSink",
            args: [
                {
                    name: "database",
                    value: `"${destination.name}"`,
                },
                {
                    name: "table_name",
                    value: `"${destinationAwsGlueCatalogTable.name}"`,
                },
            ],
        },
    ],
});
export const scalaCode = example.then(example => example.scalaCode);
Copy
import pulumi
import pulumi_aws as aws

example = aws.glue.get_script(language="SCALA",
    dag_edges=[
        {
            "source": "datasource0",
            "target": "applymapping1",
        },
        {
            "source": "applymapping1",
            "target": "selectfields2",
        },
        {
            "source": "selectfields2",
            "target": "resolvechoice3",
        },
        {
            "source": "resolvechoice3",
            "target": "datasink4",
        },
    ],
    dag_nodes=[
        {
            "id": "datasource0",
            "node_type": "DataSource",
            "args": [
                {
                    "name": "database",
                    "value": f"\"{source['name']}\"",
                },
                {
                    "name": "table_name",
                    "value": f"\"{source_aws_glue_catalog_table['name']}\"",
                },
            ],
        },
        {
            "id": "applymapping1",
            "node_type": "ApplyMapping",
            "args": [{
                "name": "mappings",
                "value": "[(\"column1\", \"string\", \"column1\", \"string\")]",
            }],
        },
        {
            "id": "selectfields2",
            "node_type": "SelectFields",
            "args": [{
                "name": "paths",
                "value": "[\"column1\"]",
            }],
        },
        {
            "id": "resolvechoice3",
            "node_type": "ResolveChoice",
            "args": [
                {
                    "name": "choice",
                    "value": "\"MATCH_CATALOG\"",
                },
                {
                    "name": "database",
                    "value": f"\"{destination['name']}\"",
                },
                {
                    "name": "table_name",
                    "value": f"\"{destination_aws_glue_catalog_table['name']}\"",
                },
            ],
        },
        {
            "id": "datasink4",
            "node_type": "DataSink",
            "args": [
                {
                    "name": "database",
                    "value": f"\"{destination['name']}\"",
                },
                {
                    "name": "table_name",
                    "value": f"\"{destination_aws_glue_catalog_table['name']}\"",
                },
            ],
        },
    ])
pulumi.export("scalaCode", example.scala_code)
Copy
package main

import (
	"fmt"

	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/glue"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		example, err := glue.GetScript(ctx, &glue.GetScriptArgs{
			Language: pulumi.StringRef("SCALA"),
			DagEdges: []glue.GetScriptDagEdge{
				{
					Source: "datasource0",
					Target: "applymapping1",
				},
				{
					Source: "applymapping1",
					Target: "selectfields2",
				},
				{
					Source: "selectfields2",
					Target: "resolvechoice3",
				},
				{
					Source: "resolvechoice3",
					Target: "datasink4",
				},
			},
			DagNodes: []glue.GetScriptDagNode{
				{
					Id:       "datasource0",
					NodeType: "DataSource",
					Args: []glue.GetScriptDagNodeArg{
						{
							Name:  "database",
							Value: fmt.Sprintf("\"%v\"", source.Name),
						},
						{
							Name:  "table_name",
							Value: fmt.Sprintf("\"%v\"", sourceAwsGlueCatalogTable.Name),
						},
					},
				},
				{
					Id:       "applymapping1",
					NodeType: "ApplyMapping",
					Args: []glue.GetScriptDagNodeArg{
						{
							Name:  "mappings",
							Value: "[(\"column1\", \"string\", \"column1\", \"string\")]",
						},
					},
				},
				{
					Id:       "selectfields2",
					NodeType: "SelectFields",
					Args: []glue.GetScriptDagNodeArg{
						{
							Name:  "paths",
							Value: "[\"column1\"]",
						},
					},
				},
				{
					Id:       "resolvechoice3",
					NodeType: "ResolveChoice",
					Args: []glue.GetScriptDagNodeArg{
						{
							Name:  "choice",
							Value: "\"MATCH_CATALOG\"",
						},
						{
							Name:  "database",
							Value: fmt.Sprintf("\"%v\"", destination.Name),
						},
						{
							Name:  "table_name",
							Value: fmt.Sprintf("\"%v\"", destinationAwsGlueCatalogTable.Name),
						},
					},
				},
				{
					Id:       "datasink4",
					NodeType: "DataSink",
					Args: []glue.GetScriptDagNodeArg{
						{
							Name:  "database",
							Value: fmt.Sprintf("\"%v\"", destination.Name),
						},
						{
							Name:  "table_name",
							Value: fmt.Sprintf("\"%v\"", destinationAwsGlueCatalogTable.Name),
						},
					},
				},
			},
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("scalaCode", example.ScalaCode)
		return nil
	})
}
Copy
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;

return await Deployment.RunAsync(() => 
{
    var example = Aws.Glue.GetScript.Invoke(new()
    {
        Language = "SCALA",
        DagEdges = new[]
        {
            new Aws.Glue.Inputs.GetScriptDagEdgeInputArgs
            {
                Source = "datasource0",
                Target = "applymapping1",
            },
            new Aws.Glue.Inputs.GetScriptDagEdgeInputArgs
            {
                Source = "applymapping1",
                Target = "selectfields2",
            },
            new Aws.Glue.Inputs.GetScriptDagEdgeInputArgs
            {
                Source = "selectfields2",
                Target = "resolvechoice3",
            },
            new Aws.Glue.Inputs.GetScriptDagEdgeInputArgs
            {
                Source = "resolvechoice3",
                Target = "datasink4",
            },
        },
        DagNodes = new[]
        {
            new Aws.Glue.Inputs.GetScriptDagNodeInputArgs
            {
                Id = "datasource0",
                NodeType = "DataSource",
                Args = new[]
                {
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "database",
                        Value = $"\"{source.Name}\"",
                    },
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "table_name",
                        Value = $"\"{sourceAwsGlueCatalogTable.Name}\"",
                    },
                },
            },
            new Aws.Glue.Inputs.GetScriptDagNodeInputArgs
            {
                Id = "applymapping1",
                NodeType = "ApplyMapping",
                Args = new[]
                {
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "mappings",
                        Value = "[(\"column1\", \"string\", \"column1\", \"string\")]",
                    },
                },
            },
            new Aws.Glue.Inputs.GetScriptDagNodeInputArgs
            {
                Id = "selectfields2",
                NodeType = "SelectFields",
                Args = new[]
                {
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "paths",
                        Value = "[\"column1\"]",
                    },
                },
            },
            new Aws.Glue.Inputs.GetScriptDagNodeInputArgs
            {
                Id = "resolvechoice3",
                NodeType = "ResolveChoice",
                Args = new[]
                {
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "choice",
                        Value = "\"MATCH_CATALOG\"",
                    },
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "database",
                        Value = $"\"{destination.Name}\"",
                    },
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "table_name",
                        Value = $"\"{destinationAwsGlueCatalogTable.Name}\"",
                    },
                },
            },
            new Aws.Glue.Inputs.GetScriptDagNodeInputArgs
            {
                Id = "datasink4",
                NodeType = "DataSink",
                Args = new[]
                {
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "database",
                        Value = $"\"{destination.Name}\"",
                    },
                    new Aws.Glue.Inputs.GetScriptDagNodeArgInputArgs
                    {
                        Name = "table_name",
                        Value = $"\"{destinationAwsGlueCatalogTable.Name}\"",
                    },
                },
            },
        },
    });

    return new Dictionary<string, object?>
    {
        ["scalaCode"] = example.Apply(getScriptResult => getScriptResult.ScalaCode),
    };
});
Copy
package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.glue.GlueFunctions;
import com.pulumi.aws.glue.inputs.GetScriptArgs;
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) {
        final var example = GlueFunctions.getScript(GetScriptArgs.builder()
            .language("SCALA")
            .dagEdges(            
                GetScriptDagEdgeArgs.builder()
                    .source("datasource0")
                    .target("applymapping1")
                    .build(),
                GetScriptDagEdgeArgs.builder()
                    .source("applymapping1")
                    .target("selectfields2")
                    .build(),
                GetScriptDagEdgeArgs.builder()
                    .source("selectfields2")
                    .target("resolvechoice3")
                    .build(),
                GetScriptDagEdgeArgs.builder()
                    .source("resolvechoice3")
                    .target("datasink4")
                    .build())
            .dagNodes(            
                GetScriptDagNodeArgs.builder()
                    .id("datasource0")
                    .nodeType("DataSource")
                    .args(                    
                        GetScriptDagNodeArgArgs.builder()
                            .name("database")
                            .value(String.format("\"%s\"", source.name()))
                            .build(),
                        GetScriptDagNodeArgArgs.builder()
                            .name("table_name")
                            .value(String.format("\"%s\"", sourceAwsGlueCatalogTable.name()))
                            .build())
                    .build(),
                GetScriptDagNodeArgs.builder()
                    .id("applymapping1")
                    .nodeType("ApplyMapping")
                    .args(GetScriptDagNodeArgArgs.builder()
                        .name("mappings")
                        .value("[(\"column1\", \"string\", \"column1\", \"string\")]")
                        .build())
                    .build(),
                GetScriptDagNodeArgs.builder()
                    .id("selectfields2")
                    .nodeType("SelectFields")
                    .args(GetScriptDagNodeArgArgs.builder()
                        .name("paths")
                        .value("[\"column1\"]")
                        .build())
                    .build(),
                GetScriptDagNodeArgs.builder()
                    .id("resolvechoice3")
                    .nodeType("ResolveChoice")
                    .args(                    
                        GetScriptDagNodeArgArgs.builder()
                            .name("choice")
                            .value("\"MATCH_CATALOG\"")
                            .build(),
                        GetScriptDagNodeArgArgs.builder()
                            .name("database")
                            .value(String.format("\"%s\"", destination.name()))
                            .build(),
                        GetScriptDagNodeArgArgs.builder()
                            .name("table_name")
                            .value(String.format("\"%s\"", destinationAwsGlueCatalogTable.name()))
                            .build())
                    .build(),
                GetScriptDagNodeArgs.builder()
                    .id("datasink4")
                    .nodeType("DataSink")
                    .args(                    
                        GetScriptDagNodeArgArgs.builder()
                            .name("database")
                            .value(String.format("\"%s\"", destination.name()))
                            .build(),
                        GetScriptDagNodeArgArgs.builder()
                            .name("table_name")
                            .value(String.format("\"%s\"", destinationAwsGlueCatalogTable.name()))
                            .build())
                    .build())
            .build());

        ctx.export("scalaCode", example.applyValue(getScriptResult -> getScriptResult.scalaCode()));
    }
}
Copy
variables:
  example:
    fn::invoke:
      function: aws:glue:getScript
      arguments:
        language: SCALA
        dagEdges:
          - source: datasource0
            target: applymapping1
          - source: applymapping1
            target: selectfields2
          - source: selectfields2
            target: resolvechoice3
          - source: resolvechoice3
            target: datasink4
        dagNodes:
          - id: datasource0
            nodeType: DataSource
            args:
              - name: database
                value: '"${source.name}"'
              - name: table_name
                value: '"${sourceAwsGlueCatalogTable.name}"'
          - id: applymapping1
            nodeType: ApplyMapping
            args:
              - name: mappings
                value: '[("column1", "string", "column1", "string")]'
          - id: selectfields2
            nodeType: SelectFields
            args:
              - name: paths
                value: '["column1"]'
          - id: resolvechoice3
            nodeType: ResolveChoice
            args:
              - name: choice
                value: '"MATCH_CATALOG"'
              - name: database
                value: '"${destination.name}"'
              - name: table_name
                value: '"${destinationAwsGlueCatalogTable.name}"'
          - id: datasink4
            nodeType: DataSink
            args:
              - name: database
                value: '"${destination.name}"'
              - name: table_name
                value: '"${destinationAwsGlueCatalogTable.name}"'
outputs:
  scalaCode: ${example.scalaCode}
Copy

Using getScript

Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

function getScript(args: GetScriptArgs, opts?: InvokeOptions): Promise<GetScriptResult>
function getScriptOutput(args: GetScriptOutputArgs, opts?: InvokeOptions): Output<GetScriptResult>
Copy
def get_script(dag_edges: Optional[Sequence[GetScriptDagEdge]] = None,
               dag_nodes: Optional[Sequence[GetScriptDagNode]] = None,
               language: Optional[str] = None,
               opts: Optional[InvokeOptions] = None) -> GetScriptResult
def get_script_output(dag_edges: Optional[pulumi.Input[Sequence[pulumi.Input[GetScriptDagEdgeArgs]]]] = None,
               dag_nodes: Optional[pulumi.Input[Sequence[pulumi.Input[GetScriptDagNodeArgs]]]] = None,
               language: Optional[pulumi.Input[str]] = None,
               opts: Optional[InvokeOptions] = None) -> Output[GetScriptResult]
Copy
func GetScript(ctx *Context, args *GetScriptArgs, opts ...InvokeOption) (*GetScriptResult, error)
func GetScriptOutput(ctx *Context, args *GetScriptOutputArgs, opts ...InvokeOption) GetScriptResultOutput
Copy

> Note: This function is named GetScript in the Go SDK.

public static class GetScript 
{
    public static Task<GetScriptResult> InvokeAsync(GetScriptArgs args, InvokeOptions? opts = null)
    public static Output<GetScriptResult> Invoke(GetScriptInvokeArgs args, InvokeOptions? opts = null)
}
Copy
public static CompletableFuture<GetScriptResult> getScript(GetScriptArgs args, InvokeOptions options)
public static Output<GetScriptResult> getScript(GetScriptArgs args, InvokeOptions options)
Copy
fn::invoke:
  function: aws:glue/getScript:getScript
  arguments:
    # arguments dictionary
Copy

The following arguments are supported:

DagEdges This property is required. List<GetScriptDagEdge>
List of the edges in the DAG. Defined below.
DagNodes This property is required. List<GetScriptDagNode>
List of the nodes in the DAG. Defined below.
Language string
Programming language of the resulting code from the DAG. Defaults to PYTHON. Valid values are PYTHON and SCALA.
DagEdges This property is required. []GetScriptDagEdge
List of the edges in the DAG. Defined below.
DagNodes This property is required. []GetScriptDagNode
List of the nodes in the DAG. Defined below.
Language string
Programming language of the resulting code from the DAG. Defaults to PYTHON. Valid values are PYTHON and SCALA.
dagEdges This property is required. List<GetScriptDagEdge>
List of the edges in the DAG. Defined below.
dagNodes This property is required. List<GetScriptDagNode>
List of the nodes in the DAG. Defined below.
language String
Programming language of the resulting code from the DAG. Defaults to PYTHON. Valid values are PYTHON and SCALA.
dagEdges This property is required. GetScriptDagEdge[]
List of the edges in the DAG. Defined below.
dagNodes This property is required. GetScriptDagNode[]
List of the nodes in the DAG. Defined below.
language string
Programming language of the resulting code from the DAG. Defaults to PYTHON. Valid values are PYTHON and SCALA.
dag_edges This property is required. Sequence[GetScriptDagEdge]
List of the edges in the DAG. Defined below.
dag_nodes This property is required. Sequence[GetScriptDagNode]
List of the nodes in the DAG. Defined below.
language str
Programming language of the resulting code from the DAG. Defaults to PYTHON. Valid values are PYTHON and SCALA.
dagEdges This property is required. List<Property Map>
List of the edges in the DAG. Defined below.
dagNodes This property is required. List<Property Map>
List of the nodes in the DAG. Defined below.
language String
Programming language of the resulting code from the DAG. Defaults to PYTHON. Valid values are PYTHON and SCALA.

getScript Result

The following output properties are available:

DagEdges List<GetScriptDagEdge>
DagNodes List<GetScriptDagNode>
Id string
The provider-assigned unique ID for this managed resource.
PythonScript string
Python script generated from the DAG when the language argument is set to PYTHON.
ScalaCode string
Scala code generated from the DAG when the language argument is set to SCALA.
Language string
DagEdges []GetScriptDagEdge
DagNodes []GetScriptDagNode
Id string
The provider-assigned unique ID for this managed resource.
PythonScript string
Python script generated from the DAG when the language argument is set to PYTHON.
ScalaCode string
Scala code generated from the DAG when the language argument is set to SCALA.
Language string
dagEdges List<GetScriptDagEdge>
dagNodes List<GetScriptDagNode>
id String
The provider-assigned unique ID for this managed resource.
pythonScript String
Python script generated from the DAG when the language argument is set to PYTHON.
scalaCode String
Scala code generated from the DAG when the language argument is set to SCALA.
language String
dagEdges GetScriptDagEdge[]
dagNodes GetScriptDagNode[]
id string
The provider-assigned unique ID for this managed resource.
pythonScript string
Python script generated from the DAG when the language argument is set to PYTHON.
scalaCode string
Scala code generated from the DAG when the language argument is set to SCALA.
language string
dag_edges Sequence[GetScriptDagEdge]
dag_nodes Sequence[GetScriptDagNode]
id str
The provider-assigned unique ID for this managed resource.
python_script str
Python script generated from the DAG when the language argument is set to PYTHON.
scala_code str
Scala code generated from the DAG when the language argument is set to SCALA.
language str
dagEdges List<Property Map>
dagNodes List<Property Map>
id String
The provider-assigned unique ID for this managed resource.
pythonScript String
Python script generated from the DAG when the language argument is set to PYTHON.
scalaCode String
Scala code generated from the DAG when the language argument is set to SCALA.
language String

Supporting Types

GetScriptDagEdge

Source This property is required. string
ID of the node at which the edge starts.
Target This property is required. string
ID of the node at which the edge ends.
TargetParameter string
Target of the edge.
Source This property is required. string
ID of the node at which the edge starts.
Target This property is required. string
ID of the node at which the edge ends.
TargetParameter string
Target of the edge.
source This property is required. String
ID of the node at which the edge starts.
target This property is required. String
ID of the node at which the edge ends.
targetParameter String
Target of the edge.
source This property is required. string
ID of the node at which the edge starts.
target This property is required. string
ID of the node at which the edge ends.
targetParameter string
Target of the edge.
source This property is required. str
ID of the node at which the edge starts.
target This property is required. str
ID of the node at which the edge ends.
target_parameter str
Target of the edge.
source This property is required. String
ID of the node at which the edge starts.
target This property is required. String
ID of the node at which the edge ends.
targetParameter String
Target of the edge.

GetScriptDagNode

Args This property is required. List<GetScriptDagNodeArg>
Nested configuration an argument or property of a node. Defined below.
Id This property is required. string
Node identifier that is unique within the node's graph.
NodeType This property is required. string
Type of node this is.
LineNumber int
Line number of the node.
Args This property is required. []GetScriptDagNodeArg
Nested configuration an argument or property of a node. Defined below.
Id This property is required. string
Node identifier that is unique within the node's graph.
NodeType This property is required. string
Type of node this is.
LineNumber int
Line number of the node.
args This property is required. List<GetScriptDagNodeArg>
Nested configuration an argument or property of a node. Defined below.
id This property is required. String
Node identifier that is unique within the node's graph.
nodeType This property is required. String
Type of node this is.
lineNumber Integer
Line number of the node.
args This property is required. GetScriptDagNodeArg[]
Nested configuration an argument or property of a node. Defined below.
id This property is required. string
Node identifier that is unique within the node's graph.
nodeType This property is required. string
Type of node this is.
lineNumber number
Line number of the node.
args This property is required. Sequence[GetScriptDagNodeArg]
Nested configuration an argument or property of a node. Defined below.
id This property is required. str
Node identifier that is unique within the node's graph.
node_type This property is required. str
Type of node this is.
line_number int
Line number of the node.
args This property is required. List<Property Map>
Nested configuration an argument or property of a node. Defined below.
id This property is required. String
Node identifier that is unique within the node's graph.
nodeType This property is required. String
Type of node this is.
lineNumber Number
Line number of the node.

GetScriptDagNodeArg

Name This property is required. string
Name of the argument or property.
Value This property is required. string
Value of the argument or property.
Param bool
Boolean if the value is used as a parameter. Defaults to false.
Name This property is required. string
Name of the argument or property.
Value This property is required. string
Value of the argument or property.
Param bool
Boolean if the value is used as a parameter. Defaults to false.
name This property is required. String
Name of the argument or property.
value This property is required. String
Value of the argument or property.
param Boolean
Boolean if the value is used as a parameter. Defaults to false.
name This property is required. string
Name of the argument or property.
value This property is required. string
Value of the argument or property.
param boolean
Boolean if the value is used as a parameter. Defaults to false.
name This property is required. str
Name of the argument or property.
value This property is required. str
Value of the argument or property.
param bool
Boolean if the value is used as a parameter. Defaults to false.
name This property is required. String
Name of the argument or property.
value This property is required. String
Value of the argument or property.
param Boolean
Boolean if the value is used as a parameter. Defaults to false.

Package Details

Repository
AWS Classic pulumi/pulumi-aws
License
Apache-2.0
Notes
This Pulumi package is based on the aws Terraform Provider.
AWS v6.76.0 published on Tuesday, Apr 8, 2025 by Pulumi
pulumi/pulumi-aws