Module streamanalytics

@pulumi/azure > streamanalytics

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

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

static isInstance(obj: any): boolean

Returns true if the given object is an instance of CustomResource. 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<{
    type: string;
}[]>;

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<{
    type: string;
}>;

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.

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("example", {
    location: "West Europe",
    name: "example-resources",
});
const exampleJob = new azure.streamanalytics.Job("example", {
    compatibilityLevel: "1.1",
    dataLocale: "en-GB",
    eventsLateArrivalMaxDelayInSeconds: 60,
    eventsOutOfOrderMaxDelayInSeconds: 50,
    eventsOutOfOrderPolicy: "Adjust",
    location: exampleResourceGroup.location,
    name: "example-job",
    outputErrorPolicy: "Drop",
    resourceGroupName: exampleResourceGroup.name,
    streamingUnits: 3,
    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

static isInstance(obj: any): boolean

Returns true if the given object is an instance of CustomResource. 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 behaviors 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>;

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).

property eventsOutOfOrderMaxDelayInSeconds

public eventsOutOfOrderMaxDelayInSeconds: pulumi.Output<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).

property eventsOutOfOrderPolicy

public eventsOutOfOrderPolicy: pulumi.Output<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.

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>;

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.

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 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.

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

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

static isInstance(obj: any): boolean

Returns true if the given object is an instance of CustomResource. 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 path_pattern, 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<{
    encoding: undefined | string;
    fieldDelimiter: undefined | string;
    format: undefined | string;
    type: string;
}>;

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 path_pattern, 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.

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 = pulumi.output(azure.core.getResourceGroup({
    name: "example-resources",
}));
const exampleJob = azurerm_resource_group_example.name.apply(name => azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: name,
}));
const testEventHub = new azure.eventhub.EventHub("test", {
    messageRetention: 1,
    name: "example-eventhub",
    namespaceName: azurerm_eventhub_namespace_example.name,
    partitionCount: 2,
    resourceGroupName: exampleResourceGroup.apply(exampleResourceGroup => exampleResourceGroup.name),
});
const testEventHubNamespace = new azure.eventhub.EventHubNamespace("test", {
    capacity: 1,
    kafkaEnabled: false,
    location: exampleResourceGroup.apply(exampleResourceGroup => exampleResourceGroup.location),
    name: "example-ehnamespace",
    resourceGroupName: exampleResourceGroup.apply(exampleResourceGroup => exampleResourceGroup.name),
    sku: "Standard",
});
const exampleOutputEventHub = new azure.streamanalytics.OutputEventHub("example", {
    eventhubName: azurerm_eventhub_example.name,
    name: "output-to-eventhub",
    resourceGroupName: exampleJob.apply(exampleJob => exampleJob.resourceGroupName),
    serialization: {
        type: "Avro",
    },
    servicebusNamespace: azurerm_eventhub_namespace_example.name,
    sharedAccessPolicyKey: azurerm_eventhub_namespace_example.defaultPrimaryKey,
    sharedAccessPolicyName: "RootManageSharedAccessKey",
    streamAnalyticsJobName: exampleJob.apply(exampleJob => exampleJob.name),
});

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

static isInstance(obj: any): boolean

Returns true if the given object is an instance of CustomResource. 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<{
    encoding: undefined | string;
    fieldDelimiter: undefined | string;
    format: undefined | string;
    type: string;
}>;

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.

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 = pulumi.output(azure.core.getResourceGroup({
    name: "example-resources",
}));
const exampleJob = azurerm_resource_group_example.name.apply(name => azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: name,
}));
const exampleNamespace = new azure.eventhub.Namespace("example", {
    location: exampleResourceGroup.apply(exampleResourceGroup => exampleResourceGroup.location),
    name: "example-namespace",
    resourceGroupName: exampleResourceGroup.apply(exampleResourceGroup => exampleResourceGroup.name),
    sku: "Standard",
});
const exampleQueue = new azure.eventhub.Queue("example", {
    enablePartitioning: true,
    name: "example-queue",
    namespaceName: exampleNamespace.name,
    resourceGroupName: exampleResourceGroup.apply(exampleResourceGroup => exampleResourceGroup.name),
});
const test = new azure.streamanalytics.OutputServiceBusQueue("test", {
    name: "blob-storage-output",
    queueName: exampleQueue.name,
    resourceGroupName: exampleJob.apply(exampleJob => exampleJob.resourceGroupName),
    serialization: {
        format: "Avro",
    },
    servicebusNamespace: exampleNamespace.name,
    sharedAccessPolicyKey: exampleNamespace.defaultPrimaryKey,
    sharedAccessPolicyName: "RootManageSharedAccessKey",
    streamAnalyticsJobName: exampleJob.apply(exampleJob => exampleJob.name),
});

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

static isInstance(obj: any): boolean

Returns true if the given object is an instance of CustomResource. 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<{
    encoding: undefined | string;
    fieldDelimiter: undefined | string;
    format: undefined | string;
    type: string;
}>;

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.

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 exampleAccount = new azure.storage.Account("example", {
    accountReplicationType: "LRS",
    accountTier: "Standard",
    location: azurerm_resource_group_example.location,
    name: "examplestoracc",
    resourceGroupName: azurerm_resource_group_example.name,
});
const exampleResourceGroup = pulumi.output(azure.core.getResourceGroup({
    name: "example-resources",
}));
const exampleJob = azurerm_resource_group_example.name.apply(name => azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: name,
}));
const exampleContainer = new azure.storage.Container("example", {
    containerAccessType: "private",
    name: "example",
    resourceGroupName: azurerm_resource_group_example.name,
    storageAccountName: exampleAccount.name,
});
const test = new azure.streamanalytics.StreamInputEventHub("test", {
    dateFormat: "yyyy/MM/dd",
    name: "eventhub-stream-input",
    pathPattern: "some-random-pattern",
    resourceGroupName: exampleJob.apply(exampleJob => exampleJob.resourceGroupName),
    serialization: {
        encoding: "UTF8",
        type: "Json",
    },
    storageAccountKey: exampleAccount.primaryAccessKey,
    storageAccountName: exampleAccount.name,
    storageContainerName: exampleContainer.name,
    streamAnalyticsJobName: exampleJob.apply(exampleJob => exampleJob.name),
    timeFormat: "HH",
});

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

static isInstance(obj: any): boolean

Returns true if the given object is an instance of CustomResource. 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 path_pattern, 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<{
    encoding: undefined | string;
    fieldDelimiter: undefined | string;
    type: string;
}>;

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 path_pattern, 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.

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 testEventHubConsumerGroup = new azure.eventhub.EventHubConsumerGroup("test", {
    eventhubName: azurerm_eventhub_test.name,
    name: "example-consumergroup",
    namespaceName: azurerm_eventhub_namespace_test.name,
    resourceGroupName: azurerm_resource_group_test.name.apply(name => name),
});
const exampleResourceGroup = pulumi.output(azure.core.getResourceGroup({
    name: "example-resources",
}));
const exampleJob = azurerm_resource_group_example.name.apply(name => azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: name,
}));
const exampleEventHubNamespace = new azure.eventhub.EventHubNamespace("example", {
    capacity: 1,
    kafkaEnabled: false,
    location: exampleResourceGroup.apply(exampleResourceGroup => exampleResourceGroup.location),
    name: "example-namespace",
    resourceGroupName: exampleResourceGroup.apply(exampleResourceGroup => exampleResourceGroup.name),
    sku: "Standard",
});
const exampleEventHub = new azure.eventhub.EventHub("example", {
    messageRetention: 1,
    name: "example-eventhub",
    namespaceName: exampleEventHubNamespace.name,
    partitionCount: 2,
    resourceGroupName: exampleResourceGroup.apply(exampleResourceGroup => exampleResourceGroup.name),
});
const testStreamInputEventHub = new azure.streamanalytics.StreamInputEventHub("test", {
    eventhubConsumerGroupName: azurerm_eventhub_consumer_group_example.name,
    eventhubName: exampleEventHub.name,
    name: "eventhub-stream-input",
    resourceGroupName: exampleJob.apply(exampleJob => exampleJob.resourceGroupName),
    serialization: {
        encoding: "UTF8",
        type: "Json",
    },
    servicebusNamespace: exampleEventHubNamespace.name,
    sharedAccessPolicyKey: exampleEventHubNamespace.defaultPrimaryKey,
    sharedAccessPolicyName: "RootManageSharedAccessKey",
    streamAnalyticsJobName: exampleJob.apply(exampleJob => exampleJob.name),
});

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

static isInstance(obj: any): boolean

Returns true if the given object is an instance of CustomResource. 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<{
    encoding: undefined | string;
    fieldDelimiter: undefined | string;
    type: string;
}>;

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.

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 testIoTHub = new azure.iot.IoTHub("test", {
    location: azurerm_resource_group_example.location,
    name: "example-iothub",
    resourceGroupName: azurerm_resource_group_example.name,
    sku: {
        capacity: 1,
        name: "S1",
        tier: "Standard",
    },
});
const exampleResourceGroup = pulumi.output(azure.core.getResourceGroup({
    name: "example-resources",
}));
const exampleJob = azurerm_resource_group_example.name.apply(name => azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: name,
}));
const testStreamInputIotHub = new azure.streamanalytics.StreamInputIotHub("test", {
    endpoint: "messages/events",
    eventhubConsumerGroupName: "$Default",
    iothubNamespace: azurerm_iothub_example.name,
    name: "example-iothub-input",
    resourceGroupName: exampleJob.apply(exampleJob => exampleJob.resourceGroupName),
    serialization: {
        encoding: "UTF8",
        type: "Json",
    },
    sharedAccessPolicyKey: azurerm_iothub_example.sharedAccessPolicy.apply(sharedAccessPolicy => sharedAccessPolicy.0.primaryKey),
    sharedAccessPolicyName: "iothubowner",
    streamAnalyticsJobName: exampleJob.apply(exampleJob => exampleJob.name),
});

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

static isInstance(obj: any): boolean

Returns true if the given object is an instance of CustomResource. 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<{
    encoding: undefined | string;
    fieldDelimiter: undefined | string;
    type: string;
}>;

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.

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 test = pulumi.output(azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: "example-resources",
}));

export const jobId = test.apply(test => test.jobId);

interface FunctionJavaScriptUDFArgs

The set of arguments for constructing a FunctionJavaScriptUDF resource.

property inputs

inputs: pulumi.Input<pulumi.Input<{
    type: pulumi.Input<string>;
}>[]>;

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<{
    type: pulumi.Input<string>;
}>;

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

Input properties used for looking up and filtering FunctionJavaScriptUDF resources.

property inputs

inputs?: pulumi.Input<pulumi.Input<{
    type: pulumi.Input<string>;
}>[]>;

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<{
    type: pulumi.Input<string>;
}>;

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

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

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;

id is 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

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 behaviors 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).

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).

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.

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.

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 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

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 behaviors 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).

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).

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.

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.

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 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

The set of arguments for constructing a OutputBlob resource.

property dateFormat

dateFormat: pulumi.Input<string>;

The date format. Wherever {date} appears in path_pattern, 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<{
    encoding: pulumi.Input<string>;
    fieldDelimiter: pulumi.Input<string>;
    format: pulumi.Input<string>;
    type: pulumi.Input<string>;
}>;

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 path_pattern, the value of this property is used as the time format instead.

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 path_pattern, 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<{
    encoding: pulumi.Input<string>;
    fieldDelimiter: pulumi.Input<string>;
    format: pulumi.Input<string>;
    type: pulumi.Input<string>;
}>;

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 path_pattern, the value of this property is used as the time format instead.

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<{
    encoding: pulumi.Input<string>;
    fieldDelimiter: pulumi.Input<string>;
    format: pulumi.Input<string>;
    type: pulumi.Input<string>;
}>;

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

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<{
    encoding: pulumi.Input<string>;
    fieldDelimiter: pulumi.Input<string>;
    format: pulumi.Input<string>;
    type: pulumi.Input<string>;
}>;

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 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<{
    encoding: pulumi.Input<string>;
    fieldDelimiter: pulumi.Input<string>;
    format: pulumi.Input<string>;
    type: pulumi.Input<string>;
}>;

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

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<{
    encoding: pulumi.Input<string>;
    fieldDelimiter: pulumi.Input<string>;
    format: pulumi.Input<string>;
    type: pulumi.Input<string>;
}>;

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 StreamInputBlobArgs

The set of arguments for constructing a StreamInputBlob resource.

property dateFormat

dateFormat: pulumi.Input<string>;

The date format. Wherever {date} appears in path_pattern, 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<{
    encoding: pulumi.Input<string>;
    fieldDelimiter: pulumi.Input<string>;
    type: pulumi.Input<string>;
}>;

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 path_pattern, the value of this property is used as the time format instead.

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 path_pattern, 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<{
    encoding: pulumi.Input<string>;
    fieldDelimiter: pulumi.Input<string>;
    type: pulumi.Input<string>;
}>;

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 path_pattern, the value of this property is used as the time format instead.

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<{
    encoding: pulumi.Input<string>;
    fieldDelimiter: pulumi.Input<string>;
    type: pulumi.Input<string>;
}>;

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

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<{
    encoding: pulumi.Input<string>;
    fieldDelimiter: pulumi.Input<string>;
    type: pulumi.Input<string>;
}>;

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

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<{
    encoding: pulumi.Input<string>;
    fieldDelimiter: pulumi.Input<string>;
    type: pulumi.Input<string>;
}>;

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

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<{
    encoding: pulumi.Input<string>;
    fieldDelimiter: pulumi.Input<string>;
    type: pulumi.Input<string>;
}>;

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.