get
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);Content copied to clipboard
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)Content copied to clipboard
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),
};
});Content copied to clipboard
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
})
}Content copied to clipboard
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()));
}
}Content copied to clipboard
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}Content copied to clipboard
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);Content copied to clipboard
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)Content copied to clipboard
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),
};
});Content copied to clipboard
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
})
}Content copied to clipboard
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()));
}
}Content copied to clipboard
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}Content copied to clipboard
Return
A collection of values returned by getScript.
Parameters
argument
A collection of arguments for invoking getScript.
suspend fun getScript(dagEdges: List<GetScriptDagEdge>, dagNodes: List<GetScriptDagNode>, language: String? = null): GetScriptResult
Return
A collection of values returned by getScript.
Parameters
dag
List of the edges in the DAG. Defined below.
dag
List of the nodes in the DAG. Defined below.
language
Programming language of the resulting code from the DAG. Defaults to PYTHON. Valid values are PYTHON and SCALA.
See also
Return
A collection of values returned by getScript.
Parameters
argument
Builder for com.pulumi.aws.glue.kotlin.inputs.GetScriptPlainArgs.