Function Java Script UDFArgs
data class FunctionJavaScriptUDFArgs(val inputs: Output<List<FunctionJavaScriptUDFInputArgs>>? = null, val name: Output<String>? = null, val output: Output<FunctionJavaScriptUDFOutputArgs>? = null, val resourceGroupName: Output<String>? = null, val script: Output<String>? = null, val streamAnalyticsJobName: Output<String>? = null) : ConvertibleToJava<FunctionJavaScriptUDFArgs>
Manages a JavaScript UDF Function within Stream Analytics Streaming Job.
Example Usage
import * as pulumi from "@pulumi/pulumi";
import * as azure from "@pulumi/azure";
const example = azure.core.getResourceGroup({
name: "example-resources",
});
const exampleGetJob = example.then(example => azure.streamanalytics.getJob({
name: "example-job",
resourceGroupName: example.name,
}));
const exampleFunctionJavaScriptUDF = new azure.streamanalytics.FunctionJavaScriptUDF("example", {
name: "example-javascript-function",
streamAnalyticsJobName: exampleGetJob.then(exampleGetJob => exampleGetJob.name),
resourceGroupName: exampleGetJob.then(exampleGetJob => exampleGetJob.resourceGroupName),
script: `function getRandomNumber(in) {
return in;
}
`,
inputs: [{
type: "bigint",
}],
output: {
type: "bigint",
},
});
Content copied to clipboard
import pulumi
import pulumi_azure as azure
example = azure.core.get_resource_group(name="example-resources")
example_get_job = azure.streamanalytics.get_job(name="example-job",
resource_group_name=example.name)
example_function_java_script_udf = azure.streamanalytics.FunctionJavaScriptUDF("example",
name="example-javascript-function",
stream_analytics_job_name=example_get_job.name,
resource_group_name=example_get_job.resource_group_name,
script="""function getRandomNumber(in) {
return in;
}
""",
inputs=[{
"type": "bigint",
}],
output={
"type": "bigint",
})
Content copied to clipboard
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Azure = Pulumi.Azure;
return await Deployment.RunAsync(() =>
{
var example = Azure.Core.GetResourceGroup.Invoke(new()
{
Name = "example-resources",
});
var exampleGetJob = Azure.StreamAnalytics.GetJob.Invoke(new()
{
Name = "example-job",
ResourceGroupName = example.Apply(getResourceGroupResult => getResourceGroupResult.Name),
});
var exampleFunctionJavaScriptUDF = new Azure.StreamAnalytics.FunctionJavaScriptUDF("example", new()
{
Name = "example-javascript-function",
StreamAnalyticsJobName = exampleGetJob.Apply(getJobResult => getJobResult.Name),
ResourceGroupName = exampleGetJob.Apply(getJobResult => getJobResult.ResourceGroupName),
Script = @"function getRandomNumber(in) {
return in;
}
",
Inputs = new[]
{
new Azure.StreamAnalytics.Inputs.FunctionJavaScriptUDFInputArgs
{
Type = "bigint",
},
},
Output = new Azure.StreamAnalytics.Inputs.FunctionJavaScriptUDFOutputArgs
{
Type = "bigint",
},
});
});
Content copied to clipboard
package main
import (
"github.com/pulumi/pulumi-azure/sdk/v6/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v6/go/azure/streamanalytics"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
example, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
Name: "example-resources",
}, nil)
if err != nil {
return err
}
exampleGetJob, err := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
Name: "example-job",
ResourceGroupName: example.Name,
}, nil)
if err != nil {
return err
}
_, err = streamanalytics.NewFunctionJavaScriptUDF(ctx, "example", &streamanalytics.FunctionJavaScriptUDFArgs{
Name: pulumi.String("example-javascript-function"),
StreamAnalyticsJobName: pulumi.String(exampleGetJob.Name),
ResourceGroupName: pulumi.String(exampleGetJob.ResourceGroupName),
Script: pulumi.String("function getRandomNumber(in) {\n return in;\n}\n"),
Inputs: streamanalytics.FunctionJavaScriptUDFInputTypeArray{
&streamanalytics.FunctionJavaScriptUDFInputTypeArgs{
Type: pulumi.String("bigint"),
},
},
Output: &streamanalytics.FunctionJavaScriptUDFOutputTypeArgs{
Type: pulumi.String("bigint"),
},
})
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.azure.core.CoreFunctions;
import com.pulumi.azure.core.inputs.GetResourceGroupArgs;
import com.pulumi.azure.streamanalytics.StreamanalyticsFunctions;
import com.pulumi.azure.streamanalytics.inputs.GetJobArgs;
import com.pulumi.azure.streamanalytics.FunctionJavaScriptUDF;
import com.pulumi.azure.streamanalytics.FunctionJavaScriptUDFArgs;
import com.pulumi.azure.streamanalytics.inputs.FunctionJavaScriptUDFInputArgs;
import com.pulumi.azure.streamanalytics.inputs.FunctionJavaScriptUDFOutputArgs;
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 = CoreFunctions.getResourceGroup(GetResourceGroupArgs.builder()
.name("example-resources")
.build());
final var exampleGetJob = StreamanalyticsFunctions.getJob(GetJobArgs.builder()
.name("example-job")
.resourceGroupName(example.name())
.build());
var exampleFunctionJavaScriptUDF = new FunctionJavaScriptUDF("exampleFunctionJavaScriptUDF", FunctionJavaScriptUDFArgs.builder()
.name("example-javascript-function")
.streamAnalyticsJobName(exampleGetJob.name())
.resourceGroupName(exampleGetJob.resourceGroupName())
.script("""
function getRandomNumber(in) {
return in;
}
""")
.inputs(FunctionJavaScriptUDFInputArgs.builder()
.type("bigint")
.build())
.output(FunctionJavaScriptUDFOutputArgs.builder()
.type("bigint")
.build())
.build());
}
}
Content copied to clipboard
resources:
exampleFunctionJavaScriptUDF:
type: azure:streamanalytics:FunctionJavaScriptUDF
name: example
properties:
name: example-javascript-function
streamAnalyticsJobName: ${exampleGetJob.name}
resourceGroupName: ${exampleGetJob.resourceGroupName}
script: |
function getRandomNumber(in) {
return in;
}
inputs:
- type: bigint
output:
type: bigint
variables:
example:
fn::invoke:
function: azure:core:getResourceGroup
arguments:
name: example-resources
exampleGetJob:
fn::invoke:
function: azure:streamanalytics:getJob
arguments:
name: example-job
resourceGroupName: ${example.name}
Content copied to clipboard
API Providers
This resource uses the following Azure API Providers:
Microsoft.StreamAnalytics
: 2020-03-01
Import
Stream Analytics JavaScript UDF Functions can be imported using the resource id
, e.g.
$ pulumi import azure:streamanalytics/functionJavaScriptUDF:FunctionJavaScriptUDF example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.StreamAnalytics/streamingJobs/job1/functions/func1
Content copied to clipboard
Constructors
Link copied to clipboard
constructor(inputs: Output<List<FunctionJavaScriptUDFInputArgs>>? = null, name: Output<String>? = null, output: Output<FunctionJavaScriptUDFOutputArgs>? = null, resourceGroupName: Output<String>? = null, script: Output<String>? = null, streamAnalyticsJobName: Output<String>? = null)
Properties
Link copied to clipboard
One or more input
blocks as defined below.
Link copied to clipboard
An output
blocks as defined below.
Link copied to clipboard
The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
Link copied to clipboard
The name of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.