1. Docs
  2. Reference
  3. API
  4. @pulumi/azure
  5. streamanalytics

Module streamanalytics

This page documents the language specification for the azure package. If you're looking for help working with the inputs, outputs, or functions of azure resources in a Pulumi program, please see the resource documentation for examples and API reference.

Resources

Functions

Others

Resources

Resource FunctionJavaScriptUDF

class FunctionJavaScriptUDF extends CustomResource

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 exampleResourceGroup = azure.core.getResourceGroup({
    name: "example-resources",
});
const exampleJob = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: azurerm_resource_group.example.name,
});
const exampleFunctionJavaScriptUDF = new azure.streamanalytics.FunctionJavaScriptUDF("exampleFunctionJavaScriptUDF", {
    streamAnalyticsJobName: exampleJob.then(exampleJob => exampleJob.name),
    resourceGroupName: exampleJob.then(exampleJob => exampleJob.resourceGroupName),
    script: `function getRandomNumber(in) {
  return in;
}
`,
    input: [{
        type: "bigint",
    }],
    output: {
        type: "bigint",
    },
});

constructor

new FunctionJavaScriptUDF(name: string, args: FunctionJavaScriptUDFArgs, opts?: pulumi.CustomResourceOptions)

Create a FunctionJavaScriptUDF resource with the given unique name, arguments, and options.

  • name The unique name of the resource.
  • args The arguments to use to populate this resource's properties.
  • opts A bag of options that control this resource's behavior.

method get

public static get(name: string, id: pulumi.Input<pulumi.ID>, state?: FunctionJavaScriptUDFState, opts?: pulumi.CustomResourceOptions): FunctionJavaScriptUDF

Get an existing FunctionJavaScriptUDF resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

method getProvider

getProvider(moduleMember: string): ProviderResource | undefined

method isInstance

public static isInstance(obj: any): obj is FunctionJavaScriptUDF

Returns true if the given object is an instance of FunctionJavaScriptUDF. This is designed to work even when multiple copies of the Pulumi SDK have been loaded into the same process.

property id

id: Output<ID>;

id is the provider-assigned unique ID for this managed resource. It is set during deployments and may be missing (undefined) during planning phases.

property inputs

public inputs: pulumi.Output<FunctionJavaScriptUDFInput[]>;

One or more input blocks as defined below.

property name

public name: pulumi.Output<string>;

The name of the JavaScript UDF Function. Changing this forces a new resource to be created.

property output

public output: pulumi.Output<FunctionJavaScriptUDFOutput>;

An output blocks as defined below.

property resourceGroupName

public resourceGroupName: pulumi.Output<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property script

public script: pulumi.Output<string>;

The JavaScript of this UDF Function.

property streamAnalyticsJobName

public streamAnalyticsJobName: pulumi.Output<string>;

The name of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.

property urn

urn: Output<URN>;

urn is the stable logical URN used to distinctly address a resource, both before and after deployments.

Resource Job

class Job extends CustomResource

Manages a Stream Analytics Job.

Example Usage

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

const exampleResourceGroup = new azure.core.ResourceGroup("exampleResourceGroup", {location: "West Europe"});
const exampleJob = new azure.streamanalytics.Job("exampleJob", {
    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]
`,
});

constructor

new Job(name: string, args: JobArgs, opts?: pulumi.CustomResourceOptions)

Create a Job resource with the given unique name, arguments, and options.

  • name The unique name of the resource.
  • args The arguments to use to populate this resource's properties.
  • opts A bag of options that control this resource's behavior.

method get

public static get(name: string, id: pulumi.Input<pulumi.ID>, state?: JobState, opts?: pulumi.CustomResourceOptions): Job

Get an existing Job resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

method getProvider

getProvider(moduleMember: string): ProviderResource | undefined

method isInstance

public static isInstance(obj: any): obj is Job

Returns true if the given object is an instance of Job. This is designed to work even when multiple copies of the Pulumi SDK have been loaded into the same process.

property compatibilityLevel

public compatibilityLevel: pulumi.Output<string>;

Specifies the compatibility level for this job - which controls certain runtime behaviours of the streaming job. Possible values are 1.0 and 1.1.

property dataLocale

public dataLocale: pulumi.Output<string>;

Specifies the Data Locale of the Job, which should be a supported .NET Culture.

property eventsLateArrivalMaxDelayInSeconds

public eventsLateArrivalMaxDelayInSeconds: pulumi.Output<number | undefined>;

Specifies the maximum tolerable delay in seconds where events arriving late could be included. Supported range is -1 (indefinite) to 1814399 (20d 23h 59m 59s). Default is 0.

property eventsOutOfOrderMaxDelayInSeconds

public eventsOutOfOrderMaxDelayInSeconds: pulumi.Output<number | undefined>;

Specifies the maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order. Supported range is 0 to 599 (9m 59s). Default is 5.

property eventsOutOfOrderPolicy

public eventsOutOfOrderPolicy: pulumi.Output<string | undefined>;

Specifies the policy which should be applied to events which arrive out of order in the input event stream. Possible values are Adjust and Drop. Default is Adjust.

property id

id: Output<ID>;

id is the provider-assigned unique ID for this managed resource. It is set during deployments and may be missing (undefined) during planning phases.

property jobId

public jobId: pulumi.Output<string>;

The Job ID assigned by the Stream Analytics Job.

property location

public location: pulumi.Output<string>;

The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.

property name

public name: pulumi.Output<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property outputErrorPolicy

public outputErrorPolicy: pulumi.Output<string | undefined>;

Specifies the policy which should be applied to events which arrive at the output and cannot be written to the external storage due to being malformed (such as missing column values, column values of wrong type or size). Possible values are Drop and Stop. Default is Drop.

property resourceGroupName

public resourceGroupName: pulumi.Output<string>;

The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.

property streamingUnits

public streamingUnits: pulumi.Output<number>;

Specifies the number of streaming units that the streaming job uses. Supported values are 1, 3, 6 and multiples of 6 up to 120.

property tags

public tags: pulumi.Output<{[key: string]: string} | undefined>;

A mapping of tags assigned to the resource.

property transformationQuery

public transformationQuery: pulumi.Output<string>;

Specifies the query that will be run in the streaming job, written in Stream Analytics Query Language (SAQL).

property urn

urn: Output<URN>;

urn is the stable logical URN used to distinctly address a resource, both before and after deployments.

Resource OutputBlob

class OutputBlob extends CustomResource

Manages a Stream Analytics Output to Blob Storage.

Example Usage

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

const exampleResourceGroup = azure.core.getResourceGroup({
    name: "example-resources",
});
const exampleJob = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: azurerm_resource_group.example.name,
});
const exampleAccount = new azure.storage.Account("exampleAccount", {
    resourceGroupName: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.name),
    location: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.location),
    accountTier: "Standard",
    accountReplicationType: "LRS",
});
const exampleContainer = new azure.storage.Container("exampleContainer", {
    storageAccountName: exampleAccount.name,
    containerAccessType: "private",
});
const exampleOutputBlob = new azure.streamanalytics.OutputBlob("exampleOutputBlob", {
    streamAnalyticsJobName: exampleJob.then(exampleJob => exampleJob.name),
    resourceGroupName: exampleJob.then(exampleJob => exampleJob.resourceGroupName),
    storageAccountName: exampleAccount.name,
    storageAccountKey: exampleAccount.primaryAccessKey,
    storageContainerName: exampleContainer.name,
    pathPattern: "some-pattern",
    dateFormat: "yyyy-MM-dd",
    timeFormat: "HH",
    serialization: {
        type: "Csv",
        encoding: "UTF8",
        fieldDelimiter: ",",
    },
});

constructor

new OutputBlob(name: string, args: OutputBlobArgs, opts?: pulumi.CustomResourceOptions)

Create a OutputBlob resource with the given unique name, arguments, and options.

  • name The unique name of the resource.
  • args The arguments to use to populate this resource's properties.
  • opts A bag of options that control this resource's behavior.

method get

public static get(name: string, id: pulumi.Input<pulumi.ID>, state?: OutputBlobState, opts?: pulumi.CustomResourceOptions): OutputBlob

Get an existing OutputBlob resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

method getProvider

getProvider(moduleMember: string): ProviderResource | undefined

method isInstance

public static isInstance(obj: any): obj is OutputBlob

Returns true if the given object is an instance of OutputBlob. This is designed to work even when multiple copies of the Pulumi SDK have been loaded into the same process.

property dateFormat

public dateFormat: pulumi.Output<string>;

The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.

property id

id: Output<ID>;

id is the provider-assigned unique ID for this managed resource. It is set during deployments and may be missing (undefined) during planning phases.

property name

public name: pulumi.Output<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property pathPattern

public pathPattern: pulumi.Output<string>;

The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.

property resourceGroupName

public resourceGroupName: pulumi.Output<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

public serialization: pulumi.Output<OutputBlobSerialization>;

A serialization block as defined below.

property storageAccountKey

public storageAccountKey: pulumi.Output<string>;

The Access Key which should be used to connect to this Storage Account.

property storageAccountName

public storageAccountName: pulumi.Output<string>;

The name of the Storage Account.

property storageContainerName

public storageContainerName: pulumi.Output<string>;

The name of the Container within the Storage Account.

property streamAnalyticsJobName

public streamAnalyticsJobName: pulumi.Output<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property timeFormat

public timeFormat: pulumi.Output<string>;

The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.

property urn

urn: Output<URN>;

urn is the stable logical URN used to distinctly address a resource, both before and after deployments.

Resource OutputEventHub

class OutputEventHub extends CustomResource

Manages a Stream Analytics Output to an EventHub.

Example Usage

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

const exampleResourceGroup = azure.core.getResourceGroup({
    name: "example-resources",
});
const exampleJob = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: azurerm_resource_group.example.name,
});
const exampleEventHubNamespace = new azure.eventhub.EventHubNamespace("exampleEventHubNamespace", {
    location: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.location),
    resourceGroupName: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.name),
    sku: "Standard",
    capacity: 1,
});
const exampleEventHub = new azure.eventhub.EventHub("exampleEventHub", {
    namespaceName: exampleEventHubNamespace.name,
    resourceGroupName: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.name),
    partitionCount: 2,
    messageRetention: 1,
});
const exampleOutputEventHub = new azure.streamanalytics.OutputEventHub("exampleOutputEventHub", {
    streamAnalyticsJobName: exampleJob.then(exampleJob => exampleJob.name),
    resourceGroupName: exampleJob.then(exampleJob => exampleJob.resourceGroupName),
    eventhubName: exampleEventHub.name,
    servicebusNamespace: exampleEventHubNamespace.name,
    sharedAccessPolicyKey: exampleEventHubNamespace.defaultPrimaryKey,
    sharedAccessPolicyName: "RootManageSharedAccessKey",
    serialization: {
        type: "Avro",
    },
});

constructor

new OutputEventHub(name: string, args: OutputEventHubArgs, opts?: pulumi.CustomResourceOptions)

Create a OutputEventHub resource with the given unique name, arguments, and options.

  • name The unique name of the resource.
  • args The arguments to use to populate this resource's properties.
  • opts A bag of options that control this resource's behavior.

method get

public static get(name: string, id: pulumi.Input<pulumi.ID>, state?: OutputEventHubState, opts?: pulumi.CustomResourceOptions): OutputEventHub

Get an existing OutputEventHub resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

method getProvider

getProvider(moduleMember: string): ProviderResource | undefined

method isInstance

public static isInstance(obj: any): obj is OutputEventHub

Returns true if the given object is an instance of OutputEventHub. This is designed to work even when multiple copies of the Pulumi SDK have been loaded into the same process.

property eventhubName

public eventhubName: pulumi.Output<string>;

The name of the Event Hub.

property id

id: Output<ID>;

id is the provider-assigned unique ID for this managed resource. It is set during deployments and may be missing (undefined) during planning phases.

property name

public name: pulumi.Output<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property resourceGroupName

public resourceGroupName: pulumi.Output<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

public serialization: pulumi.Output<OutputEventHubSerialization>;

A serialization block as defined below.

property servicebusNamespace

public servicebusNamespace: pulumi.Output<string>;

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

property sharedAccessPolicyKey

public sharedAccessPolicyKey: pulumi.Output<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

public sharedAccessPolicyName: pulumi.Output<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

public streamAnalyticsJobName: pulumi.Output<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property urn

urn: Output<URN>;

urn is the stable logical URN used to distinctly address a resource, both before and after deployments.

Resource OutputMssql

class OutputMssql extends CustomResource

Manages a Stream Analytics Output to Microsoft SQL Server Database.

Example Usage

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

const exampleResourceGroup = azure.core.getResourceGroup({
    name: "example-resources",
});
const exampleJob = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: azurerm_resource_group.example.name,
});
const exampleSqlServer = new azure.sql.SqlServer("exampleSqlServer", {
    resourceGroupName: azurerm_resource_group.example.name,
    location: azurerm_resource_group.example.location,
    version: "12.0",
    administratorLogin: "dbadmin",
    administratorLoginPassword: "example-password",
});
const exampleDatabase = new azure.sql.Database("exampleDatabase", {
    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",
});
const exampleOutputMssql = new azure.streamanalytics.OutputMssql("exampleOutputMssql", {
    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",
});

constructor

new OutputMssql(name: string, args: OutputMssqlArgs, opts?: pulumi.CustomResourceOptions)

Create a OutputMssql resource with the given unique name, arguments, and options.

  • name The unique name of the resource.
  • args The arguments to use to populate this resource's properties.
  • opts A bag of options that control this resource's behavior.

method get

public static get(name: string, id: pulumi.Input<pulumi.ID>, state?: OutputMssqlState, opts?: pulumi.CustomResourceOptions): OutputMssql

Get an existing OutputMssql resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

method getProvider

getProvider(moduleMember: string): ProviderResource | undefined

method isInstance

public static isInstance(obj: any): obj is OutputMssql

Returns true if the given object is an instance of OutputMssql. This is designed to work even when multiple copies of the Pulumi SDK have been loaded into the same process.

property database

public database: pulumi.Output<string>;

property id

id: Output<ID>;

id is the provider-assigned unique ID for this managed resource. It is set during deployments and may be missing (undefined) during planning phases.

property name

public name: pulumi.Output<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property password

public password: pulumi.Output<string>;

Password used together with username, to login to the Microsoft SQL Server. Changing this forces a new resource to be created.

property resourceGroupName

public resourceGroupName: pulumi.Output<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property server

public server: pulumi.Output<string>;

The SQL server url. Changing this forces a new resource to be created.

property streamAnalyticsJobName

public streamAnalyticsJobName: pulumi.Output<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property table

public table: pulumi.Output<string>;

Table in the database that the output points to. Changing this forces a new resource to be created.

property urn

urn: Output<URN>;

urn is the stable logical URN used to distinctly address a resource, both before and after deployments.

property user

public user: pulumi.Output<string>;

Username used to login to the Microsoft SQL Server. Changing this forces a new resource to be created.

Resource OutputServiceBusQueue

class OutputServiceBusQueue extends CustomResource

Manages a Stream Analytics Output to a ServiceBus Queue.

Example Usage

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

const exampleResourceGroup = azure.core.getResourceGroup({
    name: "example-resources",
});
const exampleJob = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: azurerm_resource_group.example.name,
});
const exampleNamespace = new azure.servicebus.Namespace("exampleNamespace", {
    location: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.location),
    resourceGroupName: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.name),
    sku: "Standard",
});
const exampleQueue = new azure.servicebus.Queue("exampleQueue", {
    resourceGroupName: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.name),
    namespaceName: exampleNamespace.name,
    enablePartitioning: true,
});
const exampleOutputServiceBusQueue = new azure.streamanalytics.OutputServiceBusQueue("exampleOutputServiceBusQueue", {
    streamAnalyticsJobName: exampleJob.then(exampleJob => exampleJob.name),
    resourceGroupName: exampleJob.then(exampleJob => exampleJob.resourceGroupName),
    queueName: exampleQueue.name,
    servicebusNamespace: exampleNamespace.name,
    sharedAccessPolicyKey: exampleNamespace.defaultPrimaryKey,
    sharedAccessPolicyName: "RootManageSharedAccessKey",
    serialization: {
        format: "Avro",
    },
});

constructor

new OutputServiceBusQueue(name: string, args: OutputServiceBusQueueArgs, opts?: pulumi.CustomResourceOptions)

Create a OutputServiceBusQueue resource with the given unique name, arguments, and options.

  • name The unique name of the resource.
  • args The arguments to use to populate this resource's properties.
  • opts A bag of options that control this resource's behavior.

method get

public static get(name: string, id: pulumi.Input<pulumi.ID>, state?: OutputServiceBusQueueState, opts?: pulumi.CustomResourceOptions): OutputServiceBusQueue

Get an existing OutputServiceBusQueue resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

method getProvider

getProvider(moduleMember: string): ProviderResource | undefined

method isInstance

public static isInstance(obj: any): obj is OutputServiceBusQueue

Returns true if the given object is an instance of OutputServiceBusQueue. This is designed to work even when multiple copies of the Pulumi SDK have been loaded into the same process.

property id

id: Output<ID>;

id is the provider-assigned unique ID for this managed resource. It is set during deployments and may be missing (undefined) during planning phases.

property name

public name: pulumi.Output<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property queueName

public queueName: pulumi.Output<string>;

The name of the Service Bus Queue.

property resourceGroupName

public resourceGroupName: pulumi.Output<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

public serialization: pulumi.Output<OutputServiceBusQueueSerialization>;

A serialization block as defined below.

property servicebusNamespace

public servicebusNamespace: pulumi.Output<string>;

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

property sharedAccessPolicyKey

public sharedAccessPolicyKey: pulumi.Output<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

public sharedAccessPolicyName: pulumi.Output<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

public streamAnalyticsJobName: pulumi.Output<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property urn

urn: Output<URN>;

urn is the stable logical URN used to distinctly address a resource, both before and after deployments.

Resource OutputServicebusTopic

class OutputServicebusTopic extends CustomResource

Manages a Stream Analytics Output to a ServiceBus Topic.

Example Usage

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

const exampleResourceGroup = azure.core.getResourceGroup({
    name: "example-resources",
});
const exampleJob = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: azurerm_resource_group.example.name,
});
const exampleNamespace = new azure.servicebus.Namespace("exampleNamespace", {
    location: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.location),
    resourceGroupName: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.name),
    sku: "Standard",
});
const exampleTopic = new azure.servicebus.Topic("exampleTopic", {
    resourceGroupName: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.name),
    namespaceName: exampleNamespace.name,
    enablePartitioning: true,
});
const exampleOutputServicebusTopic = new azure.streamanalytics.OutputServicebusTopic("exampleOutputServicebusTopic", {
    streamAnalyticsJobName: exampleJob.then(exampleJob => exampleJob.name),
    resourceGroupName: exampleJob.then(exampleJob => exampleJob.resourceGroupName),
    topicName: exampleTopic.name,
    servicebusNamespace: exampleNamespace.name,
    sharedAccessPolicyKey: exampleNamespace.defaultPrimaryKey,
    sharedAccessPolicyName: "RootManageSharedAccessKey",
    serialization: {
        format: "Avro",
    },
});

constructor

new OutputServicebusTopic(name: string, args: OutputServicebusTopicArgs, opts?: pulumi.CustomResourceOptions)

Create a OutputServicebusTopic resource with the given unique name, arguments, and options.

  • name The unique name of the resource.
  • args The arguments to use to populate this resource's properties.
  • opts A bag of options that control this resource's behavior.

method get

public static get(name: string, id: pulumi.Input<pulumi.ID>, state?: OutputServicebusTopicState, opts?: pulumi.CustomResourceOptions): OutputServicebusTopic

Get an existing OutputServicebusTopic resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

method getProvider

getProvider(moduleMember: string): ProviderResource | undefined

method isInstance

public static isInstance(obj: any): obj is OutputServicebusTopic

Returns true if the given object is an instance of OutputServicebusTopic. This is designed to work even when multiple copies of the Pulumi SDK have been loaded into the same process.

property id

id: Output<ID>;

id is the provider-assigned unique ID for this managed resource. It is set during deployments and may be missing (undefined) during planning phases.

property name

public name: pulumi.Output<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property resourceGroupName

public resourceGroupName: pulumi.Output<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

public serialization: pulumi.Output<OutputServicebusTopicSerialization>;

A serialization block as defined below.

property servicebusNamespace

public servicebusNamespace: pulumi.Output<string>;

The namespace that is associated with the desired Event Hub, Service Bus Topic, Service Bus Topic, etc.

property sharedAccessPolicyKey

public sharedAccessPolicyKey: pulumi.Output<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

public sharedAccessPolicyName: pulumi.Output<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

public streamAnalyticsJobName: pulumi.Output<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property topicName

public topicName: pulumi.Output<string>;

The name of the Service Bus Topic.

property urn

urn: Output<URN>;

urn is the stable logical URN used to distinctly address a resource, both before and after deployments.

Resource ReferenceInputBlob

class ReferenceInputBlob extends CustomResource

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.

Example Usage

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

const exampleResourceGroup = azure.core.getResourceGroup({
    name: "example-resources",
});
const exampleJob = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: azurerm_resource_group.example.name,
});
const exampleAccount = new azure.storage.Account("exampleAccount", {
    resourceGroupName: azurerm_resource_group.example.name,
    location: azurerm_resource_group.example.location,
    accountTier: "Standard",
    accountReplicationType: "LRS",
});
const exampleContainer = new azure.storage.Container("exampleContainer", {
    storageAccountName: exampleAccount.name,
    containerAccessType: "private",
});
const test = new azure.streamanalytics.ReferenceInputBlob("test", {
    streamAnalyticsJobName: exampleJob.then(exampleJob => exampleJob.name),
    resourceGroupName: exampleJob.then(exampleJob => exampleJob.resourceGroupName),
    storageAccountName: exampleAccount.name,
    storageAccountKey: exampleAccount.primaryAccessKey,
    storageContainerName: exampleContainer.name,
    pathPattern: "some-random-pattern",
    dateFormat: "yyyy/MM/dd",
    timeFormat: "HH",
    serialization: {
        type: "Json",
        encoding: "UTF8",
    },
});

constructor

new ReferenceInputBlob(name: string, args: ReferenceInputBlobArgs, opts?: pulumi.CustomResourceOptions)

Create a ReferenceInputBlob resource with the given unique name, arguments, and options.

  • name The unique name of the resource.
  • args The arguments to use to populate this resource's properties.
  • opts A bag of options that control this resource's behavior.

method get

public static get(name: string, id: pulumi.Input<pulumi.ID>, state?: ReferenceInputBlobState, opts?: pulumi.CustomResourceOptions): ReferenceInputBlob

Get an existing ReferenceInputBlob resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

method getProvider

getProvider(moduleMember: string): ProviderResource | undefined

method isInstance

public static isInstance(obj: any): obj is ReferenceInputBlob

Returns true if the given object is an instance of ReferenceInputBlob. This is designed to work even when multiple copies of the Pulumi SDK have been loaded into the same process.

property dateFormat

public dateFormat: pulumi.Output<string>;

The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.

property id

id: Output<ID>;

id is the provider-assigned unique ID for this managed resource. It is set during deployments and may be missing (undefined) during planning phases.

property name

public name: pulumi.Output<string>;

The name of the Reference Input Blob. Changing this forces a new resource to be created.

property pathPattern

public pathPattern: pulumi.Output<string>;

The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.

property resourceGroupName

public resourceGroupName: pulumi.Output<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

public serialization: pulumi.Output<ReferenceInputBlobSerialization>;

A serialization block as defined below.

property storageAccountKey

public storageAccountKey: pulumi.Output<string>;

The Access Key which should be used to connect to this Storage Account.

property storageAccountName

public storageAccountName: pulumi.Output<string>;

The name of the Storage Account that has the blob container with reference data.

property storageContainerName

public storageContainerName: pulumi.Output<string>;

The name of the Container within the Storage Account.

property streamAnalyticsJobName

public streamAnalyticsJobName: pulumi.Output<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property timeFormat

public timeFormat: pulumi.Output<string>;

The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.

property urn

urn: Output<URN>;

urn is the stable logical URN used to distinctly address a resource, both before and after deployments.

Resource StreamInputBlob

class StreamInputBlob extends CustomResource

Manages a Stream Analytics Stream Input Blob.

Example Usage

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

const exampleResourceGroup = azure.core.getResourceGroup({
    name: "example-resources",
});
const exampleJob = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: azurerm_resource_group.example.name,
});
const exampleAccount = new azure.storage.Account("exampleAccount", {
    resourceGroupName: azurerm_resource_group.example.name,
    location: azurerm_resource_group.example.location,
    accountTier: "Standard",
    accountReplicationType: "LRS",
});
const exampleContainer = new azure.storage.Container("exampleContainer", {
    storageAccountName: exampleAccount.name,
    containerAccessType: "private",
});
const exampleStreamInputBlob = new azure.streamanalytics.StreamInputBlob("exampleStreamInputBlob", {
    streamAnalyticsJobName: exampleJob.then(exampleJob => exampleJob.name),
    resourceGroupName: exampleJob.then(exampleJob => exampleJob.resourceGroupName),
    storageAccountName: exampleAccount.name,
    storageAccountKey: exampleAccount.primaryAccessKey,
    storageContainerName: exampleContainer.name,
    pathPattern: "some-random-pattern",
    dateFormat: "yyyy/MM/dd",
    timeFormat: "HH",
    serialization: {
        type: "Json",
        encoding: "UTF8",
    },
});

constructor

new StreamInputBlob(name: string, args: StreamInputBlobArgs, opts?: pulumi.CustomResourceOptions)

Create a StreamInputBlob resource with the given unique name, arguments, and options.

  • name The unique name of the resource.
  • args The arguments to use to populate this resource's properties.
  • opts A bag of options that control this resource's behavior.

method get

public static get(name: string, id: pulumi.Input<pulumi.ID>, state?: StreamInputBlobState, opts?: pulumi.CustomResourceOptions): StreamInputBlob

Get an existing StreamInputBlob resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

method getProvider

getProvider(moduleMember: string): ProviderResource | undefined

method isInstance

public static isInstance(obj: any): obj is StreamInputBlob

Returns true if the given object is an instance of StreamInputBlob. This is designed to work even when multiple copies of the Pulumi SDK have been loaded into the same process.

property dateFormat

public dateFormat: pulumi.Output<string>;

The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.

property id

id: Output<ID>;

id is the provider-assigned unique ID for this managed resource. It is set during deployments and may be missing (undefined) during planning phases.

property name

public name: pulumi.Output<string>;

The name of the Stream Input Blob. Changing this forces a new resource to be created.

property pathPattern

public pathPattern: pulumi.Output<string>;

The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.

property resourceGroupName

public resourceGroupName: pulumi.Output<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

public serialization: pulumi.Output<StreamInputBlobSerialization>;

A serialization block as defined below.

property storageAccountKey

public storageAccountKey: pulumi.Output<string>;

The Access Key which should be used to connect to this Storage Account.

property storageAccountName

public storageAccountName: pulumi.Output<string>;

The name of the Storage Account.

property storageContainerName

public storageContainerName: pulumi.Output<string>;

The name of the Container within the Storage Account.

property streamAnalyticsJobName

public streamAnalyticsJobName: pulumi.Output<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property timeFormat

public timeFormat: pulumi.Output<string>;

The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.

property urn

urn: Output<URN>;

urn is the stable logical URN used to distinctly address a resource, both before and after deployments.

Resource StreamInputEventHub

class StreamInputEventHub extends CustomResource

Manages a Stream Analytics Stream Input EventHub.

Example Usage

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

const exampleResourceGroup = azure.core.getResourceGroup({
    name: "example-resources",
});
const exampleJob = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: azurerm_resource_group.example.name,
});
const exampleEventHubNamespace = new azure.eventhub.EventHubNamespace("exampleEventHubNamespace", {
    location: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.location),
    resourceGroupName: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.name),
    sku: "Standard",
    capacity: 1,
});
const exampleEventHub = new azure.eventhub.EventHub("exampleEventHub", {
    namespaceName: exampleEventHubNamespace.name,
    resourceGroupName: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.name),
    partitionCount: 2,
    messageRetention: 1,
});
const exampleConsumerGroup = new azure.eventhub.ConsumerGroup("exampleConsumerGroup", {
    namespaceName: exampleEventHubNamespace.name,
    eventhubName: exampleEventHub.name,
    resourceGroupName: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.name),
});
const exampleStreamInputEventHub = new azure.streamanalytics.StreamInputEventHub("exampleStreamInputEventHub", {
    streamAnalyticsJobName: exampleJob.then(exampleJob => exampleJob.name),
    resourceGroupName: exampleJob.then(exampleJob => exampleJob.resourceGroupName),
    eventhubConsumerGroupName: exampleConsumerGroup.name,
    eventhubName: exampleEventHub.name,
    servicebusNamespace: exampleEventHubNamespace.name,
    sharedAccessPolicyKey: exampleEventHubNamespace.defaultPrimaryKey,
    sharedAccessPolicyName: "RootManageSharedAccessKey",
    serialization: {
        type: "Json",
        encoding: "UTF8",
    },
});

constructor

new StreamInputEventHub(name: string, args: StreamInputEventHubArgs, opts?: pulumi.CustomResourceOptions)

Create a StreamInputEventHub resource with the given unique name, arguments, and options.

  • name The unique name of the resource.
  • args The arguments to use to populate this resource's properties.
  • opts A bag of options that control this resource's behavior.

method get

public static get(name: string, id: pulumi.Input<pulumi.ID>, state?: StreamInputEventHubState, opts?: pulumi.CustomResourceOptions): StreamInputEventHub

Get an existing StreamInputEventHub resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

method getProvider

getProvider(moduleMember: string): ProviderResource | undefined

method isInstance

public static isInstance(obj: any): obj is StreamInputEventHub

Returns true if the given object is an instance of StreamInputEventHub. This is designed to work even when multiple copies of the Pulumi SDK have been loaded into the same process.

property eventhubConsumerGroupName

public eventhubConsumerGroupName: pulumi.Output<string>;

The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub.

property eventhubName

public eventhubName: pulumi.Output<string>;

The name of the Event Hub.

property id

id: Output<ID>;

id is the provider-assigned unique ID for this managed resource. It is set during deployments and may be missing (undefined) during planning phases.

property name

public name: pulumi.Output<string>;

The name of the Stream Input EventHub. Changing this forces a new resource to be created.

property resourceGroupName

public resourceGroupName: pulumi.Output<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

public serialization: pulumi.Output<StreamInputEventHubSerialization>;

A serialization block as defined below.

property servicebusNamespace

public servicebusNamespace: pulumi.Output<string>;

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

property sharedAccessPolicyKey

public sharedAccessPolicyKey: pulumi.Output<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

public sharedAccessPolicyName: pulumi.Output<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

public streamAnalyticsJobName: pulumi.Output<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property urn

urn: Output<URN>;

urn is the stable logical URN used to distinctly address a resource, both before and after deployments.

Resource StreamInputIotHub

class StreamInputIotHub extends CustomResource

Manages a Stream Analytics Stream Input IoTHub.

Example Usage

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

const exampleResourceGroup = azure.core.getResourceGroup({
    name: "example-resources",
});
const exampleJob = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: azurerm_resource_group.example.name,
});
const exampleIoTHub = new azure.iot.IoTHub("exampleIoTHub", {
    resourceGroupName: azurerm_resource_group.example.name,
    location: azurerm_resource_group.example.location,
    sku: {
        name: "S1",
        capacity: "1",
    },
});
const exampleStreamInputIotHub = new azure.streamanalytics.StreamInputIotHub("exampleStreamInputIotHub", {
    streamAnalyticsJobName: exampleJob.then(exampleJob => exampleJob.name),
    resourceGroupName: exampleJob.then(exampleJob => exampleJob.resourceGroupName),
    endpoint: "messages/events",
    eventhubConsumerGroupName: `$Default`,
    iothubNamespace: exampleIoTHub.name,
    sharedAccessPolicyKey: exampleIoTHub.sharedAccessPolicies.apply(sharedAccessPolicies => sharedAccessPolicies[0].primaryKey),
    sharedAccessPolicyName: "iothubowner",
    serialization: {
        type: "Json",
        encoding: "UTF8",
    },
});

constructor

new StreamInputIotHub(name: string, args: StreamInputIotHubArgs, opts?: pulumi.CustomResourceOptions)

Create a StreamInputIotHub resource with the given unique name, arguments, and options.

  • name The unique name of the resource.
  • args The arguments to use to populate this resource's properties.
  • opts A bag of options that control this resource's behavior.

method get

public static get(name: string, id: pulumi.Input<pulumi.ID>, state?: StreamInputIotHubState, opts?: pulumi.CustomResourceOptions): StreamInputIotHub

Get an existing StreamInputIotHub resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

method getProvider

getProvider(moduleMember: string): ProviderResource | undefined

method isInstance

public static isInstance(obj: any): obj is StreamInputIotHub

Returns true if the given object is an instance of StreamInputIotHub. This is designed to work even when multiple copies of the Pulumi SDK have been loaded into the same process.

property endpoint

public endpoint: pulumi.Output<string>;

The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).

property eventhubConsumerGroupName

public eventhubConsumerGroupName: pulumi.Output<string>;

The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub.

property id

id: Output<ID>;

id is the provider-assigned unique ID for this managed resource. It is set during deployments and may be missing (undefined) during planning phases.

property iothubNamespace

public iothubNamespace: pulumi.Output<string>;

The name or the URI of the IoT Hub.

property name

public name: pulumi.Output<string>;

The name of the Stream Input IoTHub. Changing this forces a new resource to be created.

property resourceGroupName

public resourceGroupName: pulumi.Output<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

public serialization: pulumi.Output<StreamInputIotHubSerialization>;

A serialization block as defined below.

property sharedAccessPolicyKey

public sharedAccessPolicyKey: pulumi.Output<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

public sharedAccessPolicyName: pulumi.Output<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

public streamAnalyticsJobName: pulumi.Output<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property urn

urn: Output<URN>;

urn is the stable logical URN used to distinctly address a resource, both before and after deployments.

Functions

Function getJob

getJob(args: GetJobArgs, opts?: pulumi.InvokeOptions): Promise<GetJobResult>

Use this data source to access information about an existing Stream Analytics Job.

Example Usage

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

const example = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: "example-resources",
});
export const jobId = example.then(example => example.jobId);

Others

interface FunctionJavaScriptUDFArgs

interface FunctionJavaScriptUDFArgs

The set of arguments for constructing a FunctionJavaScriptUDF resource.

property inputs

inputs: pulumi.Input<pulumi.Input<FunctionJavaScriptUDFInput>[]>;

One or more input blocks as defined below.

property name

name?: pulumi.Input<string>;

The name of the JavaScript UDF Function. Changing this forces a new resource to be created.

property output

output: pulumi.Input<FunctionJavaScriptUDFOutput>;

An output blocks as defined below.

property resourceGroupName

resourceGroupName: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property script

script: pulumi.Input<string>;

The JavaScript of this UDF Function.

property streamAnalyticsJobName

streamAnalyticsJobName: pulumi.Input<string>;

The name of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.

interface FunctionJavaScriptUDFState

interface FunctionJavaScriptUDFState

Input properties used for looking up and filtering FunctionJavaScriptUDF resources.

property inputs

inputs?: pulumi.Input<pulumi.Input<FunctionJavaScriptUDFInput>[]>;

One or more input blocks as defined below.

property name

name?: pulumi.Input<string>;

The name of the JavaScript UDF Function. Changing this forces a new resource to be created.

property output

output?: pulumi.Input<FunctionJavaScriptUDFOutput>;

An output blocks as defined below.

property resourceGroupName

resourceGroupName?: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property script

script?: pulumi.Input<string>;

The JavaScript of this UDF Function.

property streamAnalyticsJobName

streamAnalyticsJobName?: pulumi.Input<string>;

The name of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.

interface GetJobArgs

interface GetJobArgs

A collection of arguments for invoking getJob.

property name

name: string;

Specifies the name of the Stream Analytics Job.

property resourceGroupName

resourceGroupName: string;

Specifies the name of the resource group the Stream Analytics Job is located in.

interface GetJobResult

interface GetJobResult

A collection of values returned by getJob.

property compatibilityLevel

compatibilityLevel: string;

The compatibility level for this job.

property dataLocale

dataLocale: string;

The Data Locale of the Job.

property eventsLateArrivalMaxDelayInSeconds

eventsLateArrivalMaxDelayInSeconds: number;

The maximum tolerable delay in seconds where events arriving late could be included.

property eventsOutOfOrderMaxDelayInSeconds

eventsOutOfOrderMaxDelayInSeconds: number;

The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.

property eventsOutOfOrderPolicy

eventsOutOfOrderPolicy: string;

The policy which should be applied to events which arrive out of order in the input event stream.

property id

id: string;

The provider-assigned unique ID for this managed resource.

property jobId

jobId: string;

The Job ID assigned by the Stream Analytics Job.

property location

location: string;

The Azure location where the Stream Analytics Job exists.

property name

name: string;

property outputErrorPolicy

outputErrorPolicy: string;

The policy which should be applied to events which arrive at the output and cannot be written to the external storage due to being malformed (such as missing column values, column values of wrong type or size).

property resourceGroupName

resourceGroupName: string;

property streamingUnits

streamingUnits: number;

The number of streaming units that the streaming job uses.

property transformationQuery

transformationQuery: string;

The query that will be run in the streaming job, written in Stream Analytics Query Language (SAQL).

interface JobArgs

interface JobArgs

The set of arguments for constructing a Job resource.

property compatibilityLevel

compatibilityLevel?: pulumi.Input<string>;

Specifies the compatibility level for this job - which controls certain runtime behaviours of the streaming job. Possible values are 1.0 and 1.1.

property dataLocale

dataLocale?: pulumi.Input<string>;

Specifies the Data Locale of the Job, which should be a supported .NET Culture.

property eventsLateArrivalMaxDelayInSeconds

eventsLateArrivalMaxDelayInSeconds?: pulumi.Input<number>;

Specifies the maximum tolerable delay in seconds where events arriving late could be included. Supported range is -1 (indefinite) to 1814399 (20d 23h 59m 59s). Default is 0.

property eventsOutOfOrderMaxDelayInSeconds

eventsOutOfOrderMaxDelayInSeconds?: pulumi.Input<number>;

Specifies the maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order. Supported range is 0 to 599 (9m 59s). Default is 5.

property eventsOutOfOrderPolicy

eventsOutOfOrderPolicy?: pulumi.Input<string>;

Specifies the policy which should be applied to events which arrive out of order in the input event stream. Possible values are Adjust and Drop. Default is Adjust.

property location

location?: pulumi.Input<string>;

The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.

property name

name?: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property outputErrorPolicy

outputErrorPolicy?: pulumi.Input<string>;

Specifies the policy which should be applied to events which arrive at the output and cannot be written to the external storage due to being malformed (such as missing column values, column values of wrong type or size). Possible values are Drop and Stop. Default is Drop.

property resourceGroupName

resourceGroupName: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.

property streamingUnits

streamingUnits: pulumi.Input<number>;

Specifies the number of streaming units that the streaming job uses. Supported values are 1, 3, 6 and multiples of 6 up to 120.

property tags

tags?: pulumi.Input<{[key: string]: pulumi.Input<string>}>;

A mapping of tags assigned to the resource.

property transformationQuery

transformationQuery: pulumi.Input<string>;

Specifies the query that will be run in the streaming job, written in Stream Analytics Query Language (SAQL).

interface JobState

interface JobState

Input properties used for looking up and filtering Job resources.

property compatibilityLevel

compatibilityLevel?: pulumi.Input<string>;

Specifies the compatibility level for this job - which controls certain runtime behaviours of the streaming job. Possible values are 1.0 and 1.1.

property dataLocale

dataLocale?: pulumi.Input<string>;

Specifies the Data Locale of the Job, which should be a supported .NET Culture.

property eventsLateArrivalMaxDelayInSeconds

eventsLateArrivalMaxDelayInSeconds?: pulumi.Input<number>;

Specifies the maximum tolerable delay in seconds where events arriving late could be included. Supported range is -1 (indefinite) to 1814399 (20d 23h 59m 59s). Default is 0.

property eventsOutOfOrderMaxDelayInSeconds

eventsOutOfOrderMaxDelayInSeconds?: pulumi.Input<number>;

Specifies the maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order. Supported range is 0 to 599 (9m 59s). Default is 5.

property eventsOutOfOrderPolicy

eventsOutOfOrderPolicy?: pulumi.Input<string>;

Specifies the policy which should be applied to events which arrive out of order in the input event stream. Possible values are Adjust and Drop. Default is Adjust.

property jobId

jobId?: pulumi.Input<string>;

The Job ID assigned by the Stream Analytics Job.

property location

location?: pulumi.Input<string>;

The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.

property name

name?: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property outputErrorPolicy

outputErrorPolicy?: pulumi.Input<string>;

Specifies the policy which should be applied to events which arrive at the output and cannot be written to the external storage due to being malformed (such as missing column values, column values of wrong type or size). Possible values are Drop and Stop. Default is Drop.

property resourceGroupName

resourceGroupName?: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.

property streamingUnits

streamingUnits?: pulumi.Input<number>;

Specifies the number of streaming units that the streaming job uses. Supported values are 1, 3, 6 and multiples of 6 up to 120.

property tags

tags?: pulumi.Input<{[key: string]: pulumi.Input<string>}>;

A mapping of tags assigned to the resource.

property transformationQuery

transformationQuery?: pulumi.Input<string>;

Specifies the query that will be run in the streaming job, written in Stream Analytics Query Language (SAQL).

interface OutputBlobArgs

interface OutputBlobArgs

The set of arguments for constructing a OutputBlob resource.

property dateFormat

dateFormat: pulumi.Input<string>;

The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.

property name

name?: pulumi.Input<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property pathPattern

pathPattern: pulumi.Input<string>;

The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.

property resourceGroupName

resourceGroupName: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization: pulumi.Input<OutputBlobSerialization>;

A serialization block as defined below.

property storageAccountKey

storageAccountKey: pulumi.Input<string>;

The Access Key which should be used to connect to this Storage Account.

property storageAccountName

storageAccountName: pulumi.Input<string>;

The name of the Storage Account.

property storageContainerName

storageContainerName: pulumi.Input<string>;

The name of the Container within the Storage Account.

property streamAnalyticsJobName

streamAnalyticsJobName: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property timeFormat

timeFormat: pulumi.Input<string>;

The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.

interface OutputBlobState

interface OutputBlobState

Input properties used for looking up and filtering OutputBlob resources.

property dateFormat

dateFormat?: pulumi.Input<string>;

The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.

property name

name?: pulumi.Input<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property pathPattern

pathPattern?: pulumi.Input<string>;

The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.

property resourceGroupName

resourceGroupName?: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization?: pulumi.Input<OutputBlobSerialization>;

A serialization block as defined below.

property storageAccountKey

storageAccountKey?: pulumi.Input<string>;

The Access Key which should be used to connect to this Storage Account.

property storageAccountName

storageAccountName?: pulumi.Input<string>;

The name of the Storage Account.

property storageContainerName

storageContainerName?: pulumi.Input<string>;

The name of the Container within the Storage Account.

property streamAnalyticsJobName

streamAnalyticsJobName?: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property timeFormat

timeFormat?: pulumi.Input<string>;

The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.

interface OutputEventHubArgs

interface OutputEventHubArgs

The set of arguments for constructing a OutputEventHub resource.

property eventhubName

eventhubName: pulumi.Input<string>;

The name of the Event Hub.

property name

name?: pulumi.Input<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property resourceGroupName

resourceGroupName: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization: pulumi.Input<OutputEventHubSerialization>;

A serialization block as defined below.

property servicebusNamespace

servicebusNamespace: pulumi.Input<string>;

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

property sharedAccessPolicyKey

sharedAccessPolicyKey: pulumi.Input<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

sharedAccessPolicyName: pulumi.Input<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

streamAnalyticsJobName: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

interface OutputEventHubState

interface OutputEventHubState

Input properties used for looking up and filtering OutputEventHub resources.

property eventhubName

eventhubName?: pulumi.Input<string>;

The name of the Event Hub.

property name

name?: pulumi.Input<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property resourceGroupName

resourceGroupName?: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization?: pulumi.Input<OutputEventHubSerialization>;

A serialization block as defined below.

property servicebusNamespace

servicebusNamespace?: pulumi.Input<string>;

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

property sharedAccessPolicyKey

sharedAccessPolicyKey?: pulumi.Input<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

sharedAccessPolicyName?: pulumi.Input<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

streamAnalyticsJobName?: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

interface OutputMssqlArgs

interface OutputMssqlArgs

The set of arguments for constructing a OutputMssql resource.

property database

database: pulumi.Input<string>;

property name

name?: pulumi.Input<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property password

password: pulumi.Input<string>;

Password used together with username, to login to the Microsoft SQL Server. Changing this forces a new resource to be created.

property resourceGroupName

resourceGroupName: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property server

server: pulumi.Input<string>;

The SQL server url. Changing this forces a new resource to be created.

property streamAnalyticsJobName

streamAnalyticsJobName: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property table

table: pulumi.Input<string>;

Table in the database that the output points to. Changing this forces a new resource to be created.

property user

user: pulumi.Input<string>;

Username used to login to the Microsoft SQL Server. Changing this forces a new resource to be created.

interface OutputMssqlState

interface OutputMssqlState

Input properties used for looking up and filtering OutputMssql resources.

property database

database?: pulumi.Input<string>;

property name

name?: pulumi.Input<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property password

password?: pulumi.Input<string>;

Password used together with username, to login to the Microsoft SQL Server. Changing this forces a new resource to be created.

property resourceGroupName

resourceGroupName?: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property server

server?: pulumi.Input<string>;

The SQL server url. Changing this forces a new resource to be created.

property streamAnalyticsJobName

streamAnalyticsJobName?: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property table

table?: pulumi.Input<string>;

Table in the database that the output points to. Changing this forces a new resource to be created.

property user

user?: pulumi.Input<string>;

Username used to login to the Microsoft SQL Server. Changing this forces a new resource to be created.

interface OutputServiceBusQueueArgs

interface OutputServiceBusQueueArgs

The set of arguments for constructing a OutputServiceBusQueue resource.

property name

name?: pulumi.Input<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property queueName

queueName: pulumi.Input<string>;

The name of the Service Bus Queue.

property resourceGroupName

resourceGroupName: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization: pulumi.Input<OutputServiceBusQueueSerialization>;

A serialization block as defined below.

property servicebusNamespace

servicebusNamespace: pulumi.Input<string>;

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

property sharedAccessPolicyKey

sharedAccessPolicyKey: pulumi.Input<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

sharedAccessPolicyName: pulumi.Input<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

streamAnalyticsJobName: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

interface OutputServiceBusQueueState

interface OutputServiceBusQueueState

Input properties used for looking up and filtering OutputServiceBusQueue resources.

property name

name?: pulumi.Input<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property queueName

queueName?: pulumi.Input<string>;

The name of the Service Bus Queue.

property resourceGroupName

resourceGroupName?: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization?: pulumi.Input<OutputServiceBusQueueSerialization>;

A serialization block as defined below.

property servicebusNamespace

servicebusNamespace?: pulumi.Input<string>;

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

property sharedAccessPolicyKey

sharedAccessPolicyKey?: pulumi.Input<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

sharedAccessPolicyName?: pulumi.Input<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

streamAnalyticsJobName?: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

interface OutputServicebusTopicArgs

interface OutputServicebusTopicArgs

The set of arguments for constructing a OutputServicebusTopic resource.

property name

name?: pulumi.Input<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property resourceGroupName

resourceGroupName: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization: pulumi.Input<OutputServicebusTopicSerialization>;

A serialization block as defined below.

property servicebusNamespace

servicebusNamespace: pulumi.Input<string>;

The namespace that is associated with the desired Event Hub, Service Bus Topic, Service Bus Topic, etc.

property sharedAccessPolicyKey

sharedAccessPolicyKey: pulumi.Input<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

sharedAccessPolicyName: pulumi.Input<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

streamAnalyticsJobName: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property topicName

topicName: pulumi.Input<string>;

The name of the Service Bus Topic.

interface OutputServicebusTopicState

interface OutputServicebusTopicState

Input properties used for looking up and filtering OutputServicebusTopic resources.

property name

name?: pulumi.Input<string>;

The name of the Stream Output. Changing this forces a new resource to be created.

property resourceGroupName

resourceGroupName?: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization?: pulumi.Input<OutputServicebusTopicSerialization>;

A serialization block as defined below.

property servicebusNamespace

servicebusNamespace?: pulumi.Input<string>;

The namespace that is associated with the desired Event Hub, Service Bus Topic, Service Bus Topic, etc.

property sharedAccessPolicyKey

sharedAccessPolicyKey?: pulumi.Input<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

sharedAccessPolicyName?: pulumi.Input<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

streamAnalyticsJobName?: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property topicName

topicName?: pulumi.Input<string>;

The name of the Service Bus Topic.

interface ReferenceInputBlobArgs

interface ReferenceInputBlobArgs

The set of arguments for constructing a ReferenceInputBlob resource.

property dateFormat

dateFormat: pulumi.Input<string>;

The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.

property name

name?: pulumi.Input<string>;

The name of the Reference Input Blob. Changing this forces a new resource to be created.

property pathPattern

pathPattern: pulumi.Input<string>;

The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.

property resourceGroupName

resourceGroupName: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization: pulumi.Input<ReferenceInputBlobSerialization>;

A serialization block as defined below.

property storageAccountKey

storageAccountKey: pulumi.Input<string>;

The Access Key which should be used to connect to this Storage Account.

property storageAccountName

storageAccountName: pulumi.Input<string>;

The name of the Storage Account that has the blob container with reference data.

property storageContainerName

storageContainerName: pulumi.Input<string>;

The name of the Container within the Storage Account.

property streamAnalyticsJobName

streamAnalyticsJobName: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property timeFormat

timeFormat: pulumi.Input<string>;

The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.

interface ReferenceInputBlobState

interface ReferenceInputBlobState

Input properties used for looking up and filtering ReferenceInputBlob resources.

property dateFormat

dateFormat?: pulumi.Input<string>;

The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.

property name

name?: pulumi.Input<string>;

The name of the Reference Input Blob. Changing this forces a new resource to be created.

property pathPattern

pathPattern?: pulumi.Input<string>;

The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.

property resourceGroupName

resourceGroupName?: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization?: pulumi.Input<ReferenceInputBlobSerialization>;

A serialization block as defined below.

property storageAccountKey

storageAccountKey?: pulumi.Input<string>;

The Access Key which should be used to connect to this Storage Account.

property storageAccountName

storageAccountName?: pulumi.Input<string>;

The name of the Storage Account that has the blob container with reference data.

property storageContainerName

storageContainerName?: pulumi.Input<string>;

The name of the Container within the Storage Account.

property streamAnalyticsJobName

streamAnalyticsJobName?: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property timeFormat

timeFormat?: pulumi.Input<string>;

The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.

interface StreamInputBlobArgs

interface StreamInputBlobArgs

The set of arguments for constructing a StreamInputBlob resource.

property dateFormat

dateFormat: pulumi.Input<string>;

The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.

property name

name?: pulumi.Input<string>;

The name of the Stream Input Blob. Changing this forces a new resource to be created.

property pathPattern

pathPattern: pulumi.Input<string>;

The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.

property resourceGroupName

resourceGroupName: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization: pulumi.Input<StreamInputBlobSerialization>;

A serialization block as defined below.

property storageAccountKey

storageAccountKey: pulumi.Input<string>;

The Access Key which should be used to connect to this Storage Account.

property storageAccountName

storageAccountName: pulumi.Input<string>;

The name of the Storage Account.

property storageContainerName

storageContainerName: pulumi.Input<string>;

The name of the Container within the Storage Account.

property streamAnalyticsJobName

streamAnalyticsJobName: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property timeFormat

timeFormat: pulumi.Input<string>;

The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.

interface StreamInputBlobState

interface StreamInputBlobState

Input properties used for looking up and filtering StreamInputBlob resources.

property dateFormat

dateFormat?: pulumi.Input<string>;

The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.

property name

name?: pulumi.Input<string>;

The name of the Stream Input Blob. Changing this forces a new resource to be created.

property pathPattern

pathPattern?: pulumi.Input<string>;

The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.

property resourceGroupName

resourceGroupName?: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization?: pulumi.Input<StreamInputBlobSerialization>;

A serialization block as defined below.

property storageAccountKey

storageAccountKey?: pulumi.Input<string>;

The Access Key which should be used to connect to this Storage Account.

property storageAccountName

storageAccountName?: pulumi.Input<string>;

The name of the Storage Account.

property storageContainerName

storageContainerName?: pulumi.Input<string>;

The name of the Container within the Storage Account.

property streamAnalyticsJobName

streamAnalyticsJobName?: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

property timeFormat

timeFormat?: pulumi.Input<string>;

The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.

interface StreamInputEventHubArgs

interface StreamInputEventHubArgs

The set of arguments for constructing a StreamInputEventHub resource.

property eventhubConsumerGroupName

eventhubConsumerGroupName: pulumi.Input<string>;

The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub.

property eventhubName

eventhubName: pulumi.Input<string>;

The name of the Event Hub.

property name

name?: pulumi.Input<string>;

The name of the Stream Input EventHub. Changing this forces a new resource to be created.

property resourceGroupName

resourceGroupName: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization: pulumi.Input<StreamInputEventHubSerialization>;

A serialization block as defined below.

property servicebusNamespace

servicebusNamespace: pulumi.Input<string>;

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

property sharedAccessPolicyKey

sharedAccessPolicyKey: pulumi.Input<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

sharedAccessPolicyName: pulumi.Input<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

streamAnalyticsJobName: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

interface StreamInputEventHubState

interface StreamInputEventHubState

Input properties used for looking up and filtering StreamInputEventHub resources.

property eventhubConsumerGroupName

eventhubConsumerGroupName?: pulumi.Input<string>;

The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub.

property eventhubName

eventhubName?: pulumi.Input<string>;

The name of the Event Hub.

property name

name?: pulumi.Input<string>;

The name of the Stream Input EventHub. Changing this forces a new resource to be created.

property resourceGroupName

resourceGroupName?: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization?: pulumi.Input<StreamInputEventHubSerialization>;

A serialization block as defined below.

property servicebusNamespace

servicebusNamespace?: pulumi.Input<string>;

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

property sharedAccessPolicyKey

sharedAccessPolicyKey?: pulumi.Input<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

sharedAccessPolicyName?: pulumi.Input<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

streamAnalyticsJobName?: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

interface StreamInputIotHubArgs

interface StreamInputIotHubArgs

The set of arguments for constructing a StreamInputIotHub resource.

property endpoint

endpoint: pulumi.Input<string>;

The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).

property eventhubConsumerGroupName

eventhubConsumerGroupName: pulumi.Input<string>;

The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub.

property iothubNamespace

iothubNamespace: pulumi.Input<string>;

The name or the URI of the IoT Hub.

property name

name?: pulumi.Input<string>;

The name of the Stream Input IoTHub. Changing this forces a new resource to be created.

property resourceGroupName

resourceGroupName: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization: pulumi.Input<StreamInputIotHubSerialization>;

A serialization block as defined below.

property sharedAccessPolicyKey

sharedAccessPolicyKey: pulumi.Input<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

sharedAccessPolicyName: pulumi.Input<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

streamAnalyticsJobName: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

interface StreamInputIotHubState

interface StreamInputIotHubState

Input properties used for looking up and filtering StreamInputIotHub resources.

property endpoint

endpoint?: pulumi.Input<string>;

The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).

property eventhubConsumerGroupName

eventhubConsumerGroupName?: pulumi.Input<string>;

The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub.

property iothubNamespace

iothubNamespace?: pulumi.Input<string>;

The name or the URI of the IoT Hub.

property name

name?: pulumi.Input<string>;

The name of the Stream Input IoTHub. Changing this forces a new resource to be created.

property resourceGroupName

resourceGroupName?: pulumi.Input<string>;

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

property serialization

serialization?: pulumi.Input<StreamInputIotHubSerialization>;

A serialization block as defined below.

property sharedAccessPolicyKey

sharedAccessPolicyKey?: pulumi.Input<string>;

The shared access policy key for the specified shared access policy.

property sharedAccessPolicyName

sharedAccessPolicyName?: pulumi.Input<string>;

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

property streamAnalyticsJobName

streamAnalyticsJobName?: pulumi.Input<string>;

The name of the Stream Analytics Job. Changing this forces a new resource to be created.