Namespace Pulumi.Azure.StreamAnalytics

Classes

FunctionJavaScriptUDF

Manages a JavaScript UDF Function within Stream Analytics Streaming Job.

FunctionJavaScriptUDFArgs

FunctionJavaScriptUDFState

GetJob

GetJobArgs

GetJobResult

Job

Manages a Stream Analytics Job.

Example Usage

using Pulumi;
using Azure = Pulumi.Azure;

class MyStack : Stack
{
public MyStack()
{
    var exampleResourceGroup = new Azure.Core.ResourceGroup("exampleResourceGroup", new Azure.Core.ResourceGroupArgs
    {
        Location = "West Europe",
    });
    var exampleJob = new Azure.StreamAnalytics.Job("exampleJob", new Azure.StreamAnalytics.JobArgs
    {
        ResourceGroupName = exampleResourceGroup.Name,
        Location = exampleResourceGroup.Location,
        CompatibilityLevel = "1.1",
        DataLocale = "en-GB",
        EventsLateArrivalMaxDelayInSeconds = 60,
        EventsOutOfOrderMaxDelayInSeconds = 50,
        EventsOutOfOrderPolicy = "Adjust",
        OutputErrorPolicy = "Drop",
        StreamingUnits = 3,
        Tags = 
        {
            { "environment", "Example" },
        },
        TransformationQuery = @"    SELECT *
INTO [YourOutputAlias]
FROM [YourInputAlias]
",
    });
}

}

JobArgs

JobState

OutputBlob

Manages a Stream Analytics Output to Blob Storage.

OutputBlobArgs

OutputBlobState

OutputEventHub

Manages a Stream Analytics Output to an EventHub.

Example Usage

using Pulumi;
using Azure = Pulumi.Azure;

class MyStack : Stack
{
public MyStack()
{
    var exampleResourceGroup = Output.Create(Azure.Core.GetResourceGroup.InvokeAsync(new Azure.Core.GetResourceGroupArgs
    {
        Name = "example-resources",
    }));
    var exampleJob = Output.Create(Azure.StreamAnalytics.GetJob.InvokeAsync(new Azure.StreamAnalytics.GetJobArgs
    {
        Name = "example-job",
        ResourceGroupName = azurerm_resource_group.Example.Name,
    }));
    var exampleEventHubNamespace = new Azure.EventHub.EventHubNamespace("exampleEventHubNamespace", new Azure.EventHub.EventHubNamespaceArgs
    {
        Location = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Location),
        ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
        Sku = "Standard",
        Capacity = 1,
    });
    var exampleEventHub = new Azure.EventHub.EventHub("exampleEventHub", new Azure.EventHub.EventHubArgs
    {
        NamespaceName = exampleEventHubNamespace.Name,
        ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
        PartitionCount = 2,
        MessageRetention = 1,
    });
    var exampleOutputEventHub = new Azure.StreamAnalytics.OutputEventHub("exampleOutputEventHub", new Azure.StreamAnalytics.OutputEventHubArgs
    {
        StreamAnalyticsJobName = exampleJob.Apply(exampleJob => exampleJob.Name),
        ResourceGroupName = exampleJob.Apply(exampleJob => exampleJob.ResourceGroupName),
        EventhubName = exampleEventHub.Name,
        ServicebusNamespace = exampleEventHubNamespace.Name,
        SharedAccessPolicyKey = exampleEventHubNamespace.DefaultPrimaryKey,
        SharedAccessPolicyName = "RootManageSharedAccessKey",
        Serialization = new Azure.StreamAnalytics.Inputs.OutputEventHubSerializationArgs
        {
            Type = "Avro",
        },
    });
}

}

OutputEventHubArgs

OutputEventHubState

OutputMssql

Manages a Stream Analytics Output to Microsoft SQL Server Database.

Example Usage

using Pulumi;
using Azure = Pulumi.Azure;

class MyStack : Stack
{
public MyStack()
{
    var exampleResourceGroup = Output.Create(Azure.Core.GetResourceGroup.InvokeAsync(new Azure.Core.GetResourceGroupArgs
    {
        Name = "example-resources",
    }));
    var exampleJob = Output.Create(Azure.StreamAnalytics.GetJob.InvokeAsync(new Azure.StreamAnalytics.GetJobArgs
    {
        Name = "example-job",
        ResourceGroupName = azurerm_resource_group.Example.Name,
    }));
    var exampleSqlServer = new Azure.Sql.SqlServer("exampleSqlServer", new Azure.Sql.SqlServerArgs
    {
        ResourceGroupName = azurerm_resource_group.Example.Name,
        Location = azurerm_resource_group.Example.Location,
        Version = "12.0",
        AdministratorLogin = "dbadmin",
        AdministratorLoginPassword = "example-password",
    });
    var exampleDatabase = new Azure.Sql.Database("exampleDatabase", new Azure.Sql.DatabaseArgs
    {
        ResourceGroupName = azurerm_resource_group.Example.Name,
        Location = azurerm_resource_group.Example.Location,
        ServerName = exampleSqlServer.Name,
        RequestedServiceObjectiveName = "S0",
        Collation = "SQL_LATIN1_GENERAL_CP1_CI_AS",
        MaxSizeBytes = "268435456000",
        CreateMode = "Default",
    });
    var exampleOutputMssql = new Azure.StreamAnalytics.OutputMssql("exampleOutputMssql", new Azure.StreamAnalytics.OutputMssqlArgs
    {
        StreamAnalyticsJobName = azurerm_stream_analytics_job.Example.Name,
        ResourceGroupName = azurerm_stream_analytics_job.Example.Resource_group_name,
        Server = exampleSqlServer.FullyQualifiedDomainName,
        User = exampleSqlServer.AdministratorLogin,
        Password = exampleSqlServer.AdministratorLoginPassword,
        Database = exampleDatabase.Name,
        Table = "ExampleTable",
    });
}

}

OutputMssqlArgs

OutputMssqlState

OutputServiceBusQueue

Manages a Stream Analytics Output to a ServiceBus Queue.

Example Usage

using Pulumi;
using Azure = Pulumi.Azure;

class MyStack : Stack
{
public MyStack()
{
    var exampleResourceGroup = Output.Create(Azure.Core.GetResourceGroup.InvokeAsync(new Azure.Core.GetResourceGroupArgs
    {
        Name = "example-resources",
    }));
    var exampleJob = Output.Create(Azure.StreamAnalytics.GetJob.InvokeAsync(new Azure.StreamAnalytics.GetJobArgs
    {
        Name = "example-job",
        ResourceGroupName = azurerm_resource_group.Example.Name,
    }));
    var exampleNamespace = new Azure.ServiceBus.Namespace("exampleNamespace", new Azure.ServiceBus.NamespaceArgs
    {
        Location = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Location),
        ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
        Sku = "Standard",
    });
    var exampleQueue = new Azure.ServiceBus.Queue("exampleQueue", new Azure.ServiceBus.QueueArgs
    {
        ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
        NamespaceName = exampleNamespace.Name,
        EnablePartitioning = true,
    });
    var exampleOutputServiceBusQueue = new Azure.StreamAnalytics.OutputServiceBusQueue("exampleOutputServiceBusQueue", new Azure.StreamAnalytics.OutputServiceBusQueueArgs
    {
        StreamAnalyticsJobName = exampleJob.Apply(exampleJob => exampleJob.Name),
        ResourceGroupName = exampleJob.Apply(exampleJob => exampleJob.ResourceGroupName),
        QueueName = exampleQueue.Name,
        ServicebusNamespace = exampleNamespace.Name,
        SharedAccessPolicyKey = exampleNamespace.DefaultPrimaryKey,
        SharedAccessPolicyName = "RootManageSharedAccessKey",
        Serialization = new Azure.StreamAnalytics.Inputs.OutputServiceBusQueueSerializationArgs
        {
            Format = "Avro",
        },
    });
}

}

OutputServiceBusQueueArgs

OutputServiceBusQueueState

OutputServicebusTopic

Manages a Stream Analytics Output to a ServiceBus Topic.

Example Usage

using Pulumi;
using Azure = Pulumi.Azure;

class MyStack : Stack
{
public MyStack()
{
    var exampleResourceGroup = Output.Create(Azure.Core.GetResourceGroup.InvokeAsync(new Azure.Core.GetResourceGroupArgs
    {
        Name = "example-resources",
    }));
    var exampleJob = Output.Create(Azure.StreamAnalytics.GetJob.InvokeAsync(new Azure.StreamAnalytics.GetJobArgs
    {
        Name = "example-job",
        ResourceGroupName = azurerm_resource_group.Example.Name,
    }));
    var exampleNamespace = new Azure.ServiceBus.Namespace("exampleNamespace", new Azure.ServiceBus.NamespaceArgs
    {
        Location = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Location),
        ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
        Sku = "Standard",
    });
    var exampleTopic = new Azure.ServiceBus.Topic("exampleTopic", new Azure.ServiceBus.TopicArgs
    {
        ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
        NamespaceName = exampleNamespace.Name,
        EnablePartitioning = true,
    });
    var exampleOutputServicebusTopic = new Azure.StreamAnalytics.OutputServicebusTopic("exampleOutputServicebusTopic", new Azure.StreamAnalytics.OutputServicebusTopicArgs
    {
        StreamAnalyticsJobName = exampleJob.Apply(exampleJob => exampleJob.Name),
        ResourceGroupName = exampleJob.Apply(exampleJob => exampleJob.ResourceGroupName),
        TopicName = exampleTopic.Name,
        ServicebusNamespace = exampleNamespace.Name,
        SharedAccessPolicyKey = exampleNamespace.DefaultPrimaryKey,
        SharedAccessPolicyName = "RootManageSharedAccessKey",
        Serialization = new Azure.StreamAnalytics.Inputs.OutputServicebusTopicSerializationArgs
        {
            Format = "Avro",
        },
    });
}

}

OutputServicebusTopicArgs

OutputServicebusTopicState

ReferenceInputBlob

Manages a Stream Analytics Reference Input Blob. Reference data (also known as a lookup table) is a finite data set that is static or slowly changing in nature, used to perform a lookup or to correlate with your data stream. Learn more here.

ReferenceInputBlobArgs

ReferenceInputBlobState

StreamInputBlob

Manages a Stream Analytics Stream Input Blob.

StreamInputBlobArgs

StreamInputBlobState

StreamInputEventHub

Manages a Stream Analytics Stream Input EventHub.

Example Usage

using Pulumi;
using Azure = Pulumi.Azure;

class MyStack : Stack
{
public MyStack()
{
    var exampleResourceGroup = Output.Create(Azure.Core.GetResourceGroup.InvokeAsync(new Azure.Core.GetResourceGroupArgs
    {
        Name = "example-resources",
    }));
    var exampleJob = Output.Create(Azure.StreamAnalytics.GetJob.InvokeAsync(new Azure.StreamAnalytics.GetJobArgs
    {
        Name = "example-job",
        ResourceGroupName = azurerm_resource_group.Example.Name,
    }));
    var exampleEventHubNamespace = new Azure.EventHub.EventHubNamespace("exampleEventHubNamespace", new Azure.EventHub.EventHubNamespaceArgs
    {
        Location = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Location),
        ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
        Sku = "Standard",
        Capacity = 1,
    });
    var exampleEventHub = new Azure.EventHub.EventHub("exampleEventHub", new Azure.EventHub.EventHubArgs
    {
        NamespaceName = exampleEventHubNamespace.Name,
        ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
        PartitionCount = 2,
        MessageRetention = 1,
    });
    var exampleConsumerGroup = new Azure.EventHub.ConsumerGroup("exampleConsumerGroup", new Azure.EventHub.ConsumerGroupArgs
    {
        NamespaceName = exampleEventHubNamespace.Name,
        EventhubName = exampleEventHub.Name,
        ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
    });
    var exampleStreamInputEventHub = new Azure.StreamAnalytics.StreamInputEventHub("exampleStreamInputEventHub", new Azure.StreamAnalytics.StreamInputEventHubArgs
    {
        StreamAnalyticsJobName = exampleJob.Apply(exampleJob => exampleJob.Name),
        ResourceGroupName = exampleJob.Apply(exampleJob => exampleJob.ResourceGroupName),
        EventhubConsumerGroupName = exampleConsumerGroup.Name,
        EventhubName = exampleEventHub.Name,
        ServicebusNamespace = exampleEventHubNamespace.Name,
        SharedAccessPolicyKey = exampleEventHubNamespace.DefaultPrimaryKey,
        SharedAccessPolicyName = "RootManageSharedAccessKey",
        Serialization = new Azure.StreamAnalytics.Inputs.StreamInputEventHubSerializationArgs
        {
            Type = "Json",
            Encoding = "UTF8",
        },
    });
}

}

StreamInputEventHubArgs

StreamInputEventHubState

StreamInputIotHub

Manages a Stream Analytics Stream Input IoTHub.

Example Usage

using Pulumi;
using Azure = Pulumi.Azure;

class MyStack : Stack
{
public MyStack()
{
    var exampleResourceGroup = Output.Create(Azure.Core.GetResourceGroup.InvokeAsync(new Azure.Core.GetResourceGroupArgs
    {
        Name = "example-resources",
    }));
    var exampleJob = Output.Create(Azure.StreamAnalytics.GetJob.InvokeAsync(new Azure.StreamAnalytics.GetJobArgs
    {
        Name = "example-job",
        ResourceGroupName = azurerm_resource_group.Example.Name,
    }));
    var exampleIoTHub = new Azure.Iot.IoTHub("exampleIoTHub", new Azure.Iot.IoTHubArgs
    {
        ResourceGroupName = azurerm_resource_group.Example.Name,
        Location = azurerm_resource_group.Example.Location,
        Sku = new Azure.Iot.Inputs.IoTHubSkuArgs
        {
            Name = "S1",
            Capacity = "1",
        },
    });
    var exampleStreamInputIotHub = new Azure.StreamAnalytics.StreamInputIotHub("exampleStreamInputIotHub", new Azure.StreamAnalytics.StreamInputIotHubArgs
    {
        StreamAnalyticsJobName = exampleJob.Apply(exampleJob => exampleJob.Name),
        ResourceGroupName = exampleJob.Apply(exampleJob => exampleJob.ResourceGroupName),
        Endpoint = "messages/events",
        EventhubConsumerGroupName = "$Default",
        IothubNamespace = exampleIoTHub.Name,
        SharedAccessPolicyKey = exampleIoTHub.SharedAccessPolicies.Apply(sharedAccessPolicies => sharedAccessPolicies[0].PrimaryKey),
        SharedAccessPolicyName = "iothubowner",
        Serialization = new Azure.StreamAnalytics.Inputs.StreamInputIotHubSerializationArgs
        {
            Type = "Json",
            Encoding = "UTF8",
        },
    });
}

}

StreamInputIotHubArgs

StreamInputIotHubState