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.

streamanalytics¶

This provider is a derived work of the Terraform Provider distributed under MPL 2.0. If you encounter a bug or missing feature, first check the pulumi/pulumi-azure repo; however, if that doesn’t turn up anything, please consult the source terraform-providers/terraform-provider-azurerm repo.

class pulumi_azure.streamanalytics.AwaitableGetJobResult(compatibility_level=None, data_locale=None, events_late_arrival_max_delay_in_seconds=None, events_out_of_order_max_delay_in_seconds=None, events_out_of_order_policy=None, id=None, job_id=None, location=None, name=None, output_error_policy=None, resource_group_name=None, streaming_units=None, transformation_query=None)¶

class pulumi_azure.streamanalytics.FunctionJavaScriptUDF(resource_name, opts=None, inputs=None, name=None, output=None, resource_group_name=None, script=None, stream_analytics_job_name=None, __props__=None, __name__=None, __opts__=None)¶

Manages a JavaScript UDF Function within Stream Analytics Streaming Job.

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.get_resource_group(name="example-resources")
example_job = azure.streamanalytics.get_job(name="example-job",
    resource_group_name=azurerm_resource_group["example"]["name"])
example_function_java_script_udf = azure.streamanalytics.FunctionJavaScriptUDF("exampleFunctionJavaScriptUDF",
    stream_analytics_job_name=example_job.name,
    resource_group_name=example_job.resource_group_name,
    script="""function getRandomNumber(in) {
  return in;
}
""",
    input=[{
        "type": "bigint",
    }],
    output={
        "type": "bigint",
    })

Parameters

resource_name (str) – The name of the resource.
opts (pulumi.ResourceOptions) – Options for the resource.
inputs (pulumi.Input[list]) – One or more input blocks as defined below.
name (pulumi.Input[str]) – The name of the JavaScript UDF Function. Changing this forces a new resource to be created.
output (pulumi.Input[dict]) – An output blocks as defined below.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
script (pulumi.Input[str]) – The JavaScript of this UDF Function.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.

The inputs object supports the following:

type (pulumi.Input[str]) - The Data Type for the Input Argument of this JavaScript Function. Possible values include array, any, bigint, datetime, float, nvarchar(max) and record.

The output object supports the following:

type (pulumi.Input[str]) - The Data Type output from this JavaScript Function. Possible values include array, any, bigint, datetime, float, nvarchar(max) and record.

inputs: pulumi.Output[list] = None¶

One or more input blocks as defined below.

type (str) - The Data Type for the Input Argument of this JavaScript Function. Possible values include array, any, bigint, datetime, float, nvarchar(max) and record.

name: pulumi.Output[str] = None¶: The name of the JavaScript UDF Function. Changing this forces a new resource to be created.

output: pulumi.Output[dict] = None¶

An output blocks as defined below.

type (str) - The Data Type output from this JavaScript Function. Possible values include array, any, bigint, datetime, float, nvarchar(max) and record.

resource_group_name: pulumi.Output[str] = None¶: The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

script: pulumi.Output[str] = None¶: The JavaScript of this UDF Function.

stream_analytics_job_name: pulumi.Output[str] = None¶: The name of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.

static get(resource_name, id, opts=None, inputs=None, name=None, output=None, resource_group_name=None, script=None, stream_analytics_job_name=None)¶

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

Parameters

resource_name (str) – The unique name of the resulting resource.
id (str) – The unique provider ID of the resource to lookup.
opts (pulumi.ResourceOptions) – Options for the resource.
inputs (pulumi.Input[list]) – One or more input blocks as defined below.
name (pulumi.Input[str]) – The name of the JavaScript UDF Function. Changing this forces a new resource to be created.
output (pulumi.Input[dict]) – An output blocks as defined below.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
script (pulumi.Input[str]) – The JavaScript of this UDF Function.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job where this Function should be created. Changing this forces a new resource to be created.

The inputs object supports the following:

type (pulumi.Input[str]) - The Data Type for the Input Argument of this JavaScript Function. Possible values include array, any, bigint, datetime, float, nvarchar(max) and record.

The output object supports the following:

type (pulumi.Input[str]) - The Data Type output from this JavaScript Function. Possible values include array, any, bigint, datetime, float, nvarchar(max) and record.

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

class pulumi_azure.streamanalytics.GetJobResult(compatibility_level=None, data_locale=None, events_late_arrival_max_delay_in_seconds=None, events_out_of_order_max_delay_in_seconds=None, events_out_of_order_policy=None, id=None, job_id=None, location=None, name=None, output_error_policy=None, resource_group_name=None, streaming_units=None, transformation_query=None)¶

A collection of values returned by getJob.

compatibility_level = None¶: The compatibility level for this job.

data_locale = None¶: The Data Locale of the Job.

events_late_arrival_max_delay_in_seconds = None¶: The maximum tolerable delay in seconds where events arriving late could be included.

events_out_of_order_max_delay_in_seconds = None¶: The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.

events_out_of_order_policy = None¶: The policy which should be applied to events which arrive out of order in the input event stream.

id = None¶: The provider-assigned unique ID for this managed resource.

job_id = None¶: The Job ID assigned by the Stream Analytics Job.

location = None¶: The Azure location where the Stream Analytics Job exists.

output_error_policy = None¶: 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).

streaming_units = None¶: The number of streaming units that the streaming job uses.

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

class pulumi_azure.streamanalytics.Job(resource_name, opts=None, compatibility_level=None, data_locale=None, events_late_arrival_max_delay_in_seconds=None, events_out_of_order_max_delay_in_seconds=None, events_out_of_order_policy=None, location=None, name=None, output_error_policy=None, resource_group_name=None, streaming_units=None, tags=None, transformation_query=None, __props__=None, __name__=None, __opts__=None)¶

Manages a Stream Analytics Job.

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.ResourceGroup("exampleResourceGroup", location="West Europe")
example_job = azure.streamanalytics.Job("exampleJob",
    resource_group_name=example_resource_group.name,
    location=example_resource_group.location,
    compatibility_level="1.1",
    data_locale="en-GB",
    events_late_arrival_max_delay_in_seconds=60,
    events_out_of_order_max_delay_in_seconds=50,
    events_out_of_order_policy="Adjust",
    output_error_policy="Drop",
    streaming_units=3,
    tags={
        "environment": "Example",
    },
    transformation_query="""    SELECT *
    INTO [YourOutputAlias]
    FROM [YourInputAlias]
""")

Parameters

resource_name (str) – The name of the resource.
opts (pulumi.ResourceOptions) – Options for the resource.
compatibility_level (pulumi.Input[str]) – Specifies the compatibility level for this job - which controls certain runtime behaviours of the streaming job. Possible values are 1.0 and 1.1.
data_locale (pulumi.Input[str]) – Specifies the Data Locale of the Job, which should be a supported .NET Culture.aspx).
events_late_arrival_max_delay_in_seconds (pulumi.Input[float]) – 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.
events_out_of_order_max_delay_in_seconds (pulumi.Input[float]) – 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.
events_out_of_order_policy (pulumi.Input[str]) – 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.
location (pulumi.Input[str]) – The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.
output_error_policy (pulumi.Input[str]) – 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.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
streaming_units (pulumi.Input[float]) – Specifies the number of streaming units that the streaming job uses. Supported values are 1, 3, 6 and multiples of 6 up to 120.
tags (pulumi.Input[dict]) – A mapping of tags assigned to the resource.
transformation_query (pulumi.Input[str]) –
Specifies the query that will be run in the streaming job, written in Stream Analytics Query Language (SAQL).

compatibility_level: pulumi.Output[str] = None¶: Specifies the compatibility level for this job - which controls certain runtime behaviours of the streaming job. Possible values are 1.0 and 1.1.

data_locale: pulumi.Output[str] = None¶: Specifies the Data Locale of the Job, which should be a supported .NET Culture.aspx).

events_late_arrival_max_delay_in_seconds: pulumi.Output[float] = None¶: 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.

events_out_of_order_max_delay_in_seconds: pulumi.Output[float] = None¶: 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.

events_out_of_order_policy: pulumi.Output[str] = None¶: 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.

job_id: pulumi.Output[str] = None¶: The Job ID assigned by the Stream Analytics Job.

location: pulumi.Output[str] = None¶: The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.

name: pulumi.Output[str] = None¶: The name of the Stream Analytics Job. Changing this forces a new resource to be created.

output_error_policy: pulumi.Output[str] = None¶: 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.

resource_group_name: pulumi.Output[str] = None¶: The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.

streaming_units: pulumi.Output[float] = None¶: Specifies the number of streaming units that the streaming job uses. Supported values are 1, 3, 6 and multiples of 6 up to 120.

tags: pulumi.Output[dict] = None¶: A mapping of tags assigned to the resource.

transformation_query: pulumi.Output[str] = None¶: Specifies the query that will be run in the streaming job, written in Stream Analytics Query Language (SAQL).

static get(resource_name, id, opts=None, compatibility_level=None, data_locale=None, events_late_arrival_max_delay_in_seconds=None, events_out_of_order_max_delay_in_seconds=None, events_out_of_order_policy=None, job_id=None, location=None, name=None, output_error_policy=None, resource_group_name=None, streaming_units=None, tags=None, transformation_query=None)¶

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

Parameters

resource_name (str) – The unique name of the resulting resource.
id (str) – The unique provider ID of the resource to lookup.
opts (pulumi.ResourceOptions) – Options for the resource.
compatibility_level (pulumi.Input[str]) – Specifies the compatibility level for this job - which controls certain runtime behaviours of the streaming job. Possible values are 1.0 and 1.1.
data_locale (pulumi.Input[str]) –
Specifies the Data Locale of the Job, which should be a supported .NET Culture.aspx).
events_late_arrival_max_delay_in_seconds (pulumi.Input[float]) – 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.
events_out_of_order_max_delay_in_seconds (pulumi.Input[float]) – 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.
events_out_of_order_policy (pulumi.Input[str]) – 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.
job_id (pulumi.Input[str]) – The Job ID assigned by the Stream Analytics Job.
location (pulumi.Input[str]) – The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.
output_error_policy (pulumi.Input[str]) – 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.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
streaming_units (pulumi.Input[float]) – Specifies the number of streaming units that the streaming job uses. Supported values are 1, 3, 6 and multiples of 6 up to 120.
tags (pulumi.Input[dict]) – A mapping of tags assigned to the resource.
transformation_query (pulumi.Input[str]) –
Specifies the query that will be run in the streaming job, written in Stream Analytics Query Language (SAQL).

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

class pulumi_azure.streamanalytics.OutputBlob(resource_name, opts=None, date_format=None, name=None, path_pattern=None, resource_group_name=None, serialization=None, storage_account_key=None, storage_account_name=None, storage_container_name=None, stream_analytics_job_name=None, time_format=None, __props__=None, __name__=None, __opts__=None)¶

Manages a Stream Analytics Output to Blob Storage.

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.get_resource_group(name="example-resources")
example_job = azure.streamanalytics.get_job(name="example-job",
    resource_group_name=azurerm_resource_group["example"]["name"])
example_account = azure.storage.Account("exampleAccount",
    resource_group_name=example_resource_group.name,
    location=example_resource_group.location,
    account_tier="Standard",
    account_replication_type="LRS")
example_container = azure.storage.Container("exampleContainer",
    storage_account_name=example_account.name,
    container_access_type="private")
example_output_blob = azure.streamanalytics.OutputBlob("exampleOutputBlob",
    stream_analytics_job_name=example_job.name,
    resource_group_name=example_job.resource_group_name,
    storage_account_name=example_account.name,
    storage_account_key=example_account.primary_access_key,
    storage_container_name=example_container.name,
    path_pattern="some-pattern",
    date_format="yyyy-MM-dd",
    time_format="HH",
    serialization={
        "type": "Csv",
        "encoding": "UTF8",
        "fieldDelimiter": ",",
    })

Parameters

resource_name (str) – The name of the resource.
opts (pulumi.ResourceOptions) – Options for the resource.
date_format (pulumi.Input[str]) – The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
name (pulumi.Input[str]) – The name of the Stream Output. Changing this forces a new resource to be created.
path_pattern (pulumi.Input[str]) – 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.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
storage_account_key (pulumi.Input[str]) – The Access Key which should be used to connect to this Storage Account.
storage_account_name (pulumi.Input[str]) – The name of the Storage Account.
storage_container_name (pulumi.Input[str]) – The name of the Container within the Storage Account.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.
time_format (pulumi.Input[str]) – The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
format (pulumi.Input[str]) - Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
type (pulumi.Input[str]) - The serialization format used for outgoing data streams. Possible values are Avro, Csv and Json.

date_format: pulumi.Output[str] = None¶: The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.

name: pulumi.Output[str] = None¶: The name of the Stream Output. Changing this forces a new resource to be created.

path_pattern: pulumi.Output[str] = None¶: 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.

resource_group_name: pulumi.Output[str] = None¶: The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

serialization: pulumi.Output[dict] = None¶

A serialization block as defined below.

encoding (str) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (str) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
format (str) - Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
type (str) - The serialization format used for outgoing data streams. Possible values are Avro, Csv and Json.

storage_account_key: pulumi.Output[str] = None¶: The Access Key which should be used to connect to this Storage Account.

storage_account_name: pulumi.Output[str] = None¶: The name of the Storage Account.

storage_container_name: pulumi.Output[str] = None¶: The name of the Container within the Storage Account.

stream_analytics_job_name: pulumi.Output[str] = None¶: The name of the Stream Analytics Job. Changing this forces a new resource to be created.

time_format: pulumi.Output[str] = None¶: The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.

static get(resource_name, id, opts=None, date_format=None, name=None, path_pattern=None, resource_group_name=None, serialization=None, storage_account_key=None, storage_account_name=None, storage_container_name=None, stream_analytics_job_name=None, time_format=None)¶

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

Parameters

resource_name (str) – The unique name of the resulting resource.
id (str) – The unique provider ID of the resource to lookup.
opts (pulumi.ResourceOptions) – Options for the resource.
date_format (pulumi.Input[str]) – The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
name (pulumi.Input[str]) – The name of the Stream Output. Changing this forces a new resource to be created.
path_pattern (pulumi.Input[str]) – 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.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
storage_account_key (pulumi.Input[str]) – The Access Key which should be used to connect to this Storage Account.
storage_account_name (pulumi.Input[str]) – The name of the Storage Account.
storage_container_name (pulumi.Input[str]) – The name of the Container within the Storage Account.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.
time_format (pulumi.Input[str]) – The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
format (pulumi.Input[str]) - Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
type (pulumi.Input[str]) - The serialization format used for outgoing data streams. Possible values are Avro, Csv and Json.

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

class pulumi_azure.streamanalytics.OutputEventHub(resource_name, opts=None, eventhub_name=None, name=None, resource_group_name=None, serialization=None, servicebus_namespace=None, shared_access_policy_key=None, shared_access_policy_name=None, stream_analytics_job_name=None, __props__=None, __name__=None, __opts__=None)¶

Manages a Stream Analytics Output to an EventHub.

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.get_resource_group(name="example-resources")
example_job = azure.streamanalytics.get_job(name="example-job",
    resource_group_name=azurerm_resource_group["example"]["name"])
example_event_hub_namespace = azure.eventhub.EventHubNamespace("exampleEventHubNamespace",
    location=example_resource_group.location,
    resource_group_name=example_resource_group.name,
    sku="Standard",
    capacity=1)
example_event_hub = azure.eventhub.EventHub("exampleEventHub",
    namespace_name=example_event_hub_namespace.name,
    resource_group_name=example_resource_group.name,
    partition_count=2,
    message_retention=1)
example_output_event_hub = azure.streamanalytics.OutputEventHub("exampleOutputEventHub",
    stream_analytics_job_name=example_job.name,
    resource_group_name=example_job.resource_group_name,
    eventhub_name=example_event_hub.name,
    servicebus_namespace=example_event_hub_namespace.name,
    shared_access_policy_key=example_event_hub_namespace.default_primary_key,
    shared_access_policy_name="RootManageSharedAccessKey",
    serialization={
        "type": "Avro",
    })

Parameters

resource_name (str) – The name of the resource.
opts (pulumi.ResourceOptions) – Options for the resource.
eventhub_name (pulumi.Input[str]) – The name of the Event Hub.
name (pulumi.Input[str]) – The name of the Stream Output. Changing this forces a new resource to be created.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
servicebus_namespace (pulumi.Input[str]) – The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
shared_access_policy_key (pulumi.Input[str]) – The shared access policy key for the specified shared access policy.
shared_access_policy_name (pulumi.Input[str]) – The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
format (pulumi.Input[str]) - Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
type (pulumi.Input[str]) - The serialization format used for outgoing data streams. Possible values are Avro, Csv and Json.

eventhub_name: pulumi.Output[str] = None¶: The name of the Event Hub.

name: pulumi.Output[str] = None¶: The name of the Stream Output. Changing this forces a new resource to be created.

resource_group_name: pulumi.Output[str] = None¶: The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

serialization: pulumi.Output[dict] = None¶

A serialization block as defined below.

encoding (str) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (str) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
format (str) - Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
type (str) - The serialization format used for outgoing data streams. Possible values are Avro, Csv and Json.

servicebus_namespace: pulumi.Output[str] = None¶: The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

shared_access_policy_key: pulumi.Output[str] = None¶: The shared access policy key for the specified shared access policy.

shared_access_policy_name: pulumi.Output[str] = None¶: The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

stream_analytics_job_name: pulumi.Output[str] = None¶: The name of the Stream Analytics Job. Changing this forces a new resource to be created.

static get(resource_name, id, opts=None, eventhub_name=None, name=None, resource_group_name=None, serialization=None, servicebus_namespace=None, shared_access_policy_key=None, shared_access_policy_name=None, stream_analytics_job_name=None)¶

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

Parameters

resource_name (str) – The unique name of the resulting resource.
id (str) – The unique provider ID of the resource to lookup.
opts (pulumi.ResourceOptions) – Options for the resource.
eventhub_name (pulumi.Input[str]) – The name of the Event Hub.
name (pulumi.Input[str]) – The name of the Stream Output. Changing this forces a new resource to be created.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
servicebus_namespace (pulumi.Input[str]) – The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
shared_access_policy_key (pulumi.Input[str]) – The shared access policy key for the specified shared access policy.
shared_access_policy_name (pulumi.Input[str]) – The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
format (pulumi.Input[str]) - Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
type (pulumi.Input[str]) - The serialization format used for outgoing data streams. Possible values are Avro, Csv and Json.

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

class pulumi_azure.streamanalytics.OutputMssql(resource_name, opts=None, database=None, name=None, password=None, resource_group_name=None, server=None, stream_analytics_job_name=None, table=None, user=None, __props__=None, __name__=None, __opts__=None)¶

Manages a Stream Analytics Output to Microsoft SQL Server Database.

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.get_resource_group(name="example-resources")
example_job = azure.streamanalytics.get_job(name="example-job",
    resource_group_name=azurerm_resource_group["example"]["name"])
example_sql_server = azure.sql.SqlServer("exampleSqlServer",
    resource_group_name=azurerm_resource_group["example"]["name"],
    location=azurerm_resource_group["example"]["location"],
    version="12.0",
    administrator_login="dbadmin",
    administrator_login_password="example-password")
example_database = azure.sql.Database("exampleDatabase",
    resource_group_name=azurerm_resource_group["example"]["name"],
    location=azurerm_resource_group["example"]["location"],
    server_name=example_sql_server.name,
    requested_service_objective_name="S0",
    collation="SQL_LATIN1_GENERAL_CP1_CI_AS",
    max_size_bytes="268435456000",
    create_mode="Default")
example_output_mssql = azure.streamanalytics.OutputMssql("exampleOutputMssql",
    stream_analytics_job_name=azurerm_stream_analytics_job["example"]["name"],
    resource_group_name=azurerm_stream_analytics_job["example"]["resource_group_name"],
    server=example_sql_server.fully_qualified_domain_name,
    user=example_sql_server.administrator_login,
    password=example_sql_server.administrator_login_password,
    database=example_database.name,
    table="ExampleTable")

Parameters

resource_name (str) – The name of the resource.
opts (pulumi.ResourceOptions) – Options for the resource.
name (pulumi.Input[str]) – The name of the Stream Output. Changing this forces a new resource to be created.
password (pulumi.Input[str]) – Password used together with username, to login to the Microsoft SQL Server. Changing this forces a new resource to be created.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
server (pulumi.Input[str]) – The SQL server url. Changing this forces a new resource to be created.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.
table (pulumi.Input[str]) – Table in the database that the output points to. Changing this forces a new resource to be created.
user (pulumi.Input[str]) – Username used to login to the Microsoft SQL Server. Changing this forces a new resource to be created.

name: pulumi.Output[str] = None¶: The name of the Stream Output. Changing this forces a new resource to be created.

password: pulumi.Output[str] = None¶: Password used together with username, to login to the Microsoft SQL Server. Changing this forces a new resource to be created.

resource_group_name: pulumi.Output[str] = None¶: The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

server: pulumi.Output[str] = None¶: The SQL server url. Changing this forces a new resource to be created.

stream_analytics_job_name: pulumi.Output[str] = None¶: The name of the Stream Analytics Job. Changing this forces a new resource to be created.

table: pulumi.Output[str] = None¶: Table in the database that the output points to. Changing this forces a new resource to be created.

user: pulumi.Output[str] = None¶: Username used to login to the Microsoft SQL Server. Changing this forces a new resource to be created.

static get(resource_name, id, opts=None, database=None, name=None, password=None, resource_group_name=None, server=None, stream_analytics_job_name=None, table=None, user=None)¶

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

Parameters

resource_name (str) – The unique name of the resulting resource.
id (str) – The unique provider ID of the resource to lookup.
opts (pulumi.ResourceOptions) – Options for the resource.
name (pulumi.Input[str]) – The name of the Stream Output. Changing this forces a new resource to be created.
password (pulumi.Input[str]) – Password used together with username, to login to the Microsoft SQL Server. Changing this forces a new resource to be created.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
server (pulumi.Input[str]) – The SQL server url. Changing this forces a new resource to be created.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.
table (pulumi.Input[str]) – Table in the database that the output points to. Changing this forces a new resource to be created.
user (pulumi.Input[str]) – Username used to login to the Microsoft SQL Server. Changing this forces a new resource to be created.

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

class pulumi_azure.streamanalytics.OutputServiceBusQueue(resource_name, opts=None, name=None, queue_name=None, resource_group_name=None, serialization=None, servicebus_namespace=None, shared_access_policy_key=None, shared_access_policy_name=None, stream_analytics_job_name=None, __props__=None, __name__=None, __opts__=None)¶

Manages a Stream Analytics Output to a ServiceBus Queue.

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.get_resource_group(name="example-resources")
example_job = azure.streamanalytics.get_job(name="example-job",
    resource_group_name=azurerm_resource_group["example"]["name"])
example_namespace = azure.servicebus.Namespace("exampleNamespace",
    location=example_resource_group.location,
    resource_group_name=example_resource_group.name,
    sku="Standard")
example_queue = azure.servicebus.Queue("exampleQueue",
    resource_group_name=example_resource_group.name,
    namespace_name=example_namespace.name,
    enable_partitioning=True)
example_output_service_bus_queue = azure.streamanalytics.OutputServiceBusQueue("exampleOutputServiceBusQueue",
    stream_analytics_job_name=example_job.name,
    resource_group_name=example_job.resource_group_name,
    queue_name=example_queue.name,
    servicebus_namespace=example_namespace.name,
    shared_access_policy_key=example_namespace.default_primary_key,
    shared_access_policy_name="RootManageSharedAccessKey",
    serialization={
        "format": "Avro",
    })

Parameters

resource_name (str) – The name of the resource.
opts (pulumi.ResourceOptions) – Options for the resource.
name (pulumi.Input[str]) – The name of the Stream Output. Changing this forces a new resource to be created.
queue_name (pulumi.Input[str]) – The name of the Service Bus Queue.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
servicebus_namespace (pulumi.Input[str]) – The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
shared_access_policy_key (pulumi.Input[str]) – The shared access policy key for the specified shared access policy.
shared_access_policy_name (pulumi.Input[str]) – The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
format (pulumi.Input[str]) - Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
type (pulumi.Input[str]) - The serialization format used for outgoing data streams. Possible values are Avro, Csv and Json.

name: pulumi.Output[str] = None¶: The name of the Stream Output. Changing this forces a new resource to be created.

queue_name: pulumi.Output[str] = None¶: The name of the Service Bus Queue.

resource_group_name: pulumi.Output[str] = None¶: The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

serialization: pulumi.Output[dict] = None¶

A serialization block as defined below.

encoding (str) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (str) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
format (str) - Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
type (str) - The serialization format used for outgoing data streams. Possible values are Avro, Csv and Json.

servicebus_namespace: pulumi.Output[str] = None¶: The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

shared_access_policy_key: pulumi.Output[str] = None¶: The shared access policy key for the specified shared access policy.

shared_access_policy_name: pulumi.Output[str] = None¶: The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

stream_analytics_job_name: pulumi.Output[str] = None¶: The name of the Stream Analytics Job. Changing this forces a new resource to be created.

static get(resource_name, id, opts=None, name=None, queue_name=None, resource_group_name=None, serialization=None, servicebus_namespace=None, shared_access_policy_key=None, shared_access_policy_name=None, stream_analytics_job_name=None)¶

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

Parameters

resource_name (str) – The unique name of the resulting resource.
id (str) – The unique provider ID of the resource to lookup.
opts (pulumi.ResourceOptions) – Options for the resource.
name (pulumi.Input[str]) – The name of the Stream Output. Changing this forces a new resource to be created.
queue_name (pulumi.Input[str]) – The name of the Service Bus Queue.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
servicebus_namespace (pulumi.Input[str]) – The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
shared_access_policy_key (pulumi.Input[str]) – The shared access policy key for the specified shared access policy.
shared_access_policy_name (pulumi.Input[str]) – The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
format (pulumi.Input[str]) - Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
type (pulumi.Input[str]) - The serialization format used for outgoing data streams. Possible values are Avro, Csv and Json.

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

class pulumi_azure.streamanalytics.OutputServicebusTopic(resource_name, opts=None, name=None, resource_group_name=None, serialization=None, servicebus_namespace=None, shared_access_policy_key=None, shared_access_policy_name=None, stream_analytics_job_name=None, topic_name=None, __props__=None, __name__=None, __opts__=None)¶

Manages a Stream Analytics Output to a ServiceBus Topic.

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.get_resource_group(name="example-resources")
example_job = azure.streamanalytics.get_job(name="example-job",
    resource_group_name=azurerm_resource_group["example"]["name"])
example_namespace = azure.servicebus.Namespace("exampleNamespace",
    location=example_resource_group.location,
    resource_group_name=example_resource_group.name,
    sku="Standard")
example_topic = azure.servicebus.Topic("exampleTopic",
    resource_group_name=example_resource_group.name,
    namespace_name=example_namespace.name,
    enable_partitioning=True)
example_output_servicebus_topic = azure.streamanalytics.OutputServicebusTopic("exampleOutputServicebusTopic",
    stream_analytics_job_name=example_job.name,
    resource_group_name=example_job.resource_group_name,
    topic_name=example_topic.name,
    servicebus_namespace=example_namespace.name,
    shared_access_policy_key=example_namespace.default_primary_key,
    shared_access_policy_name="RootManageSharedAccessKey",
    serialization={
        "format": "Avro",
    })

Parameters

resource_name (str) – The name of the resource.
opts (pulumi.ResourceOptions) – Options for the resource.
name (pulumi.Input[str]) – The name of the Stream Output. Changing this forces a new resource to be created.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
servicebus_namespace (pulumi.Input[str]) – The namespace that is associated with the desired Event Hub, Service Bus Topic, Service Bus Topic, etc.
shared_access_policy_key (pulumi.Input[str]) – The shared access policy key for the specified shared access policy.
shared_access_policy_name (pulumi.Input[str]) – The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.
topic_name (pulumi.Input[str]) – The name of the Service Bus Topic.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
format (pulumi.Input[str]) - Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
type (pulumi.Input[str]) - The serialization format used for outgoing data streams. Possible values are Avro, Csv and Json.

name: pulumi.Output[str] = None¶: The name of the Stream Output. Changing this forces a new resource to be created.

resource_group_name: pulumi.Output[str] = None¶: The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

serialization: pulumi.Output[dict] = None¶

A serialization block as defined below.

encoding (str) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (str) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
format (str) - Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
type (str) - The serialization format used for outgoing data streams. Possible values are Avro, Csv and Json.

servicebus_namespace: pulumi.Output[str] = None¶: The namespace that is associated with the desired Event Hub, Service Bus Topic, Service Bus Topic, etc.

shared_access_policy_key: pulumi.Output[str] = None¶: The shared access policy key for the specified shared access policy.

shared_access_policy_name: pulumi.Output[str] = None¶: The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

stream_analytics_job_name: pulumi.Output[str] = None¶: The name of the Stream Analytics Job. Changing this forces a new resource to be created.

topic_name: pulumi.Output[str] = None¶: The name of the Service Bus Topic.

static get(resource_name, id, opts=None, name=None, resource_group_name=None, serialization=None, servicebus_namespace=None, shared_access_policy_key=None, shared_access_policy_name=None, stream_analytics_job_name=None, topic_name=None)¶

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

Parameters

resource_name (str) – The unique name of the resulting resource.
id (str) – The unique provider ID of the resource to lookup.
opts (pulumi.ResourceOptions) – Options for the resource.
name (pulumi.Input[str]) – The name of the Stream Output. Changing this forces a new resource to be created.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
servicebus_namespace (pulumi.Input[str]) – The namespace that is associated with the desired Event Hub, Service Bus Topic, Service Bus Topic, etc.
shared_access_policy_key (pulumi.Input[str]) – The shared access policy key for the specified shared access policy.
shared_access_policy_name (pulumi.Input[str]) – The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.
topic_name (pulumi.Input[str]) – The name of the Service Bus Topic.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
format (pulumi.Input[str]) - Specifies the format of the JSON the output will be written in. Possible values are Array and LineSeparated.
type (pulumi.Input[str]) - The serialization format used for outgoing data streams. Possible values are Avro, Csv and Json.

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

class pulumi_azure.streamanalytics.ReferenceInputBlob(resource_name, opts=None, date_format=None, name=None, path_pattern=None, resource_group_name=None, serialization=None, storage_account_key=None, storage_account_name=None, storage_container_name=None, stream_analytics_job_name=None, time_format=None, __props__=None, __name__=None, __opts__=None)¶

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.

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.get_resource_group(name="example-resources")
example_job = azure.streamanalytics.get_job(name="example-job",
    resource_group_name=azurerm_resource_group["example"]["name"])
example_account = azure.storage.Account("exampleAccount",
    resource_group_name=azurerm_resource_group["example"]["name"],
    location=azurerm_resource_group["example"]["location"],
    account_tier="Standard",
    account_replication_type="LRS")
example_container = azure.storage.Container("exampleContainer",
    storage_account_name=example_account.name,
    container_access_type="private")
test = azure.streamanalytics.ReferenceInputBlob("test",
    stream_analytics_job_name=example_job.name,
    resource_group_name=example_job.resource_group_name,
    storage_account_name=example_account.name,
    storage_account_key=example_account.primary_access_key,
    storage_container_name=example_container.name,
    path_pattern="some-random-pattern",
    date_format="yyyy/MM/dd",
    time_format="HH",
    serialization={
        "type": "Json",
        "encoding": "UTF8",
    })

Parameters

resource_name (str) – The name of the resource.
opts (pulumi.ResourceOptions) – Options for the resource.
date_format (pulumi.Input[str]) – The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
name (pulumi.Input[str]) – The name of the Reference Input Blob. Changing this forces a new resource to be created.
path_pattern (pulumi.Input[str]) – 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.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
storage_account_key (pulumi.Input[str]) – The Access Key which should be used to connect to this Storage Account.
storage_account_name (pulumi.Input[str]) – The name of the Storage Account that has the blob container with reference data.
storage_container_name (pulumi.Input[str]) – The name of the Container within the Storage Account.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.
time_format (pulumi.Input[str]) – The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
type (pulumi.Input[str]) - The serialization format used for the reference data. Possible values are Avro, Csv and Json.

date_format: pulumi.Output[str] = None¶: The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.

name: pulumi.Output[str] = None¶: The name of the Reference Input Blob. Changing this forces a new resource to be created.

path_pattern: pulumi.Output[str] = None¶: 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.

resource_group_name: pulumi.Output[str] = None¶: The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

serialization: pulumi.Output[dict] = None¶

A serialization block as defined below.

encoding (str) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (str) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
type (str) - The serialization format used for the reference data. Possible values are Avro, Csv and Json.

storage_account_key: pulumi.Output[str] = None¶: The Access Key which should be used to connect to this Storage Account.

storage_account_name: pulumi.Output[str] = None¶: The name of the Storage Account that has the blob container with reference data.

storage_container_name: pulumi.Output[str] = None¶: The name of the Container within the Storage Account.

stream_analytics_job_name: pulumi.Output[str] = None¶: The name of the Stream Analytics Job. Changing this forces a new resource to be created.

time_format: pulumi.Output[str] = None¶: The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.

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

Parameters

resource_name (str) – The unique name of the resulting resource.
id (str) – The unique provider ID of the resource to lookup.
opts (pulumi.ResourceOptions) – Options for the resource.
date_format (pulumi.Input[str]) – The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
name (pulumi.Input[str]) – The name of the Reference Input Blob. Changing this forces a new resource to be created.
path_pattern (pulumi.Input[str]) – 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.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
storage_account_key (pulumi.Input[str]) – The Access Key which should be used to connect to this Storage Account.
storage_account_name (pulumi.Input[str]) – The name of the Storage Account that has the blob container with reference data.
storage_container_name (pulumi.Input[str]) – The name of the Container within the Storage Account.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.
time_format (pulumi.Input[str]) – The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
type (pulumi.Input[str]) - The serialization format used for the reference data. Possible values are Avro, Csv and Json.

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

class pulumi_azure.streamanalytics.StreamInputBlob(resource_name, opts=None, date_format=None, name=None, path_pattern=None, resource_group_name=None, serialization=None, storage_account_key=None, storage_account_name=None, storage_container_name=None, stream_analytics_job_name=None, time_format=None, __props__=None, __name__=None, __opts__=None)¶

Manages a Stream Analytics Stream Input Blob.

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.get_resource_group(name="example-resources")
example_job = azure.streamanalytics.get_job(name="example-job",
    resource_group_name=azurerm_resource_group["example"]["name"])
example_account = azure.storage.Account("exampleAccount",
    resource_group_name=azurerm_resource_group["example"]["name"],
    location=azurerm_resource_group["example"]["location"],
    account_tier="Standard",
    account_replication_type="LRS")
example_container = azure.storage.Container("exampleContainer",
    storage_account_name=example_account.name,
    container_access_type="private")
example_stream_input_blob = azure.streamanalytics.StreamInputBlob("exampleStreamInputBlob",
    stream_analytics_job_name=example_job.name,
    resource_group_name=example_job.resource_group_name,
    storage_account_name=example_account.name,
    storage_account_key=example_account.primary_access_key,
    storage_container_name=example_container.name,
    path_pattern="some-random-pattern",
    date_format="yyyy/MM/dd",
    time_format="HH",
    serialization={
        "type": "Json",
        "encoding": "UTF8",
    })

Parameters

resource_name (str) – The name of the resource.
opts (pulumi.ResourceOptions) – Options for the resource.
date_format (pulumi.Input[str]) – The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
name (pulumi.Input[str]) – The name of the Stream Input Blob. Changing this forces a new resource to be created.
path_pattern (pulumi.Input[str]) – 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.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
storage_account_key (pulumi.Input[str]) – The Access Key which should be used to connect to this Storage Account.
storage_account_name (pulumi.Input[str]) – The name of the Storage Account.
storage_container_name (pulumi.Input[str]) – The name of the Container within the Storage Account.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.
time_format (pulumi.Input[str]) – The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
type (pulumi.Input[str]) - The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.

date_format: pulumi.Output[str] = None¶: The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.

name: pulumi.Output[str] = None¶: The name of the Stream Input Blob. Changing this forces a new resource to be created.

path_pattern: pulumi.Output[str] = None¶: 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.

resource_group_name: pulumi.Output[str] = None¶: The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

serialization: pulumi.Output[dict] = None¶

A serialization block as defined below.

encoding (str) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (str) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
type (str) - The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.

storage_account_key: pulumi.Output[str] = None¶: The Access Key which should be used to connect to this Storage Account.

storage_account_name: pulumi.Output[str] = None¶: The name of the Storage Account.

storage_container_name: pulumi.Output[str] = None¶: The name of the Container within the Storage Account.

stream_analytics_job_name: pulumi.Output[str] = None¶: The name of the Stream Analytics Job. Changing this forces a new resource to be created.

time_format: pulumi.Output[str] = None¶: The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.

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

Parameters

resource_name (str) – The unique name of the resulting resource.
id (str) – The unique provider ID of the resource to lookup.
opts (pulumi.ResourceOptions) – Options for the resource.
date_format (pulumi.Input[str]) – The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.
name (pulumi.Input[str]) – The name of the Stream Input Blob. Changing this forces a new resource to be created.
path_pattern (pulumi.Input[str]) – 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.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
storage_account_key (pulumi.Input[str]) – The Access Key which should be used to connect to this Storage Account.
storage_account_name (pulumi.Input[str]) – The name of the Storage Account.
storage_container_name (pulumi.Input[str]) – The name of the Container within the Storage Account.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.
time_format (pulumi.Input[str]) – The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
type (pulumi.Input[str]) - The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

class pulumi_azure.streamanalytics.StreamInputEventHub(resource_name, opts=None, eventhub_consumer_group_name=None, eventhub_name=None, name=None, resource_group_name=None, serialization=None, servicebus_namespace=None, shared_access_policy_key=None, shared_access_policy_name=None, stream_analytics_job_name=None, __props__=None, __name__=None, __opts__=None)¶

Manages a Stream Analytics Stream Input EventHub.

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.get_resource_group(name="example-resources")
example_job = azure.streamanalytics.get_job(name="example-job",
    resource_group_name=azurerm_resource_group["example"]["name"])
example_event_hub_namespace = azure.eventhub.EventHubNamespace("exampleEventHubNamespace",
    location=example_resource_group.location,
    resource_group_name=example_resource_group.name,
    sku="Standard",
    capacity=1)
example_event_hub = azure.eventhub.EventHub("exampleEventHub",
    namespace_name=example_event_hub_namespace.name,
    resource_group_name=example_resource_group.name,
    partition_count=2,
    message_retention=1)
example_consumer_group = azure.eventhub.ConsumerGroup("exampleConsumerGroup",
    namespace_name=example_event_hub_namespace.name,
    eventhub_name=example_event_hub.name,
    resource_group_name=example_resource_group.name)
example_stream_input_event_hub = azure.streamanalytics.StreamInputEventHub("exampleStreamInputEventHub",
    stream_analytics_job_name=example_job.name,
    resource_group_name=example_job.resource_group_name,
    eventhub_consumer_group_name=example_consumer_group.name,
    eventhub_name=example_event_hub.name,
    servicebus_namespace=example_event_hub_namespace.name,
    shared_access_policy_key=example_event_hub_namespace.default_primary_key,
    shared_access_policy_name="RootManageSharedAccessKey",
    serialization={
        "type": "Json",
        "encoding": "UTF8",
    })

Parameters

resource_name (str) – The name of the resource.
opts (pulumi.ResourceOptions) – Options for the resource.
eventhub_consumer_group_name (pulumi.Input[str]) – 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.
eventhub_name (pulumi.Input[str]) – The name of the Event Hub.
name (pulumi.Input[str]) – The name of the Stream Input EventHub. Changing this forces a new resource to be created.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
servicebus_namespace (pulumi.Input[str]) – The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
shared_access_policy_key (pulumi.Input[str]) – The shared access policy key for the specified shared access policy.
shared_access_policy_name (pulumi.Input[str]) – The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
type (pulumi.Input[str]) - The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.

eventhub_consumer_group_name: pulumi.Output[str] = None¶: 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.

eventhub_name: pulumi.Output[str] = None¶: The name of the Event Hub.

name: pulumi.Output[str] = None¶: The name of the Stream Input EventHub. Changing this forces a new resource to be created.

resource_group_name: pulumi.Output[str] = None¶: The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

serialization: pulumi.Output[dict] = None¶

A serialization block as defined below.

encoding (str) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (str) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
type (str) - The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.

servicebus_namespace: pulumi.Output[str] = None¶: The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

shared_access_policy_key: pulumi.Output[str] = None¶: The shared access policy key for the specified shared access policy.

shared_access_policy_name: pulumi.Output[str] = None¶: The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

stream_analytics_job_name: pulumi.Output[str] = None¶: The name of the Stream Analytics Job. Changing this forces a new resource to be created.

static get(resource_name, id, opts=None, eventhub_consumer_group_name=None, eventhub_name=None, name=None, resource_group_name=None, serialization=None, servicebus_namespace=None, shared_access_policy_key=None, shared_access_policy_name=None, stream_analytics_job_name=None)¶

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

Parameters

resource_name (str) – The unique name of the resulting resource.
id (str) – The unique provider ID of the resource to lookup.
opts (pulumi.ResourceOptions) – Options for the resource.
eventhub_consumer_group_name (pulumi.Input[str]) – 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.
eventhub_name (pulumi.Input[str]) – The name of the Event Hub.
name (pulumi.Input[str]) – The name of the Stream Input EventHub. Changing this forces a new resource to be created.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
servicebus_namespace (pulumi.Input[str]) – The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.
shared_access_policy_key (pulumi.Input[str]) – The shared access policy key for the specified shared access policy.
shared_access_policy_name (pulumi.Input[str]) – The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
type (pulumi.Input[str]) - The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

class pulumi_azure.streamanalytics.StreamInputIotHub(resource_name, opts=None, endpoint=None, eventhub_consumer_group_name=None, iothub_namespace=None, name=None, resource_group_name=None, serialization=None, shared_access_policy_key=None, shared_access_policy_name=None, stream_analytics_job_name=None, __props__=None, __name__=None, __opts__=None)¶

Manages a Stream Analytics Stream Input IoTHub.

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.get_resource_group(name="example-resources")
example_job = azure.streamanalytics.get_job(name="example-job",
    resource_group_name=azurerm_resource_group["example"]["name"])
example_io_t_hub = azure.iot.IoTHub("exampleIoTHub",
    resource_group_name=azurerm_resource_group["example"]["name"],
    location=azurerm_resource_group["example"]["location"],
    sku={
        "name": "S1",
        "capacity": "1",
    })
example_stream_input_iot_hub = azure.streamanalytics.StreamInputIotHub("exampleStreamInputIotHub",
    stream_analytics_job_name=example_job.name,
    resource_group_name=example_job.resource_group_name,
    endpoint="messages/events",
    eventhub_consumer_group_name="$Default",
    iothub_namespace=example_io_t_hub.name,
    shared_access_policy_key=example_io_t_hub.shared_access_policies[0]["primary_key"],
    shared_access_policy_name="iothubowner",
    serialization={
        "type": "Json",
        "encoding": "UTF8",
    })

Parameters

resource_name (str) – The name of the resource.
opts (pulumi.ResourceOptions) – Options for the resource.
endpoint (pulumi.Input[str]) – The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).
eventhub_consumer_group_name (pulumi.Input[str]) – 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.
iothub_namespace (pulumi.Input[str]) – The name or the URI of the IoT Hub.
name (pulumi.Input[str]) – The name of the Stream Input IoTHub. Changing this forces a new resource to be created.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
shared_access_policy_key (pulumi.Input[str]) – The shared access policy key for the specified shared access policy.
shared_access_policy_name (pulumi.Input[str]) – The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
type (pulumi.Input[str]) - The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.

endpoint: pulumi.Output[str] = None¶: The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).

eventhub_consumer_group_name: pulumi.Output[str] = None¶: 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.

iothub_namespace: pulumi.Output[str] = None¶: The name or the URI of the IoT Hub.

name: pulumi.Output[str] = None¶: The name of the Stream Input IoTHub. Changing this forces a new resource to be created.

resource_group_name: pulumi.Output[str] = None¶: The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

serialization: pulumi.Output[dict] = None¶

A serialization block as defined below.

encoding (str) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (str) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
type (str) - The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.

shared_access_policy_key: pulumi.Output[str] = None¶: The shared access policy key for the specified shared access policy.

shared_access_policy_name: pulumi.Output[str] = None¶: The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

stream_analytics_job_name: pulumi.Output[str] = None¶: The name of the Stream Analytics Job. Changing this forces a new resource to be created.

static get(resource_name, id, opts=None, endpoint=None, eventhub_consumer_group_name=None, iothub_namespace=None, name=None, resource_group_name=None, serialization=None, shared_access_policy_key=None, shared_access_policy_name=None, stream_analytics_job_name=None)¶

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

Parameters

resource_name (str) – The unique name of the resulting resource.
id (str) – The unique provider ID of the resource to lookup.
opts (pulumi.ResourceOptions) – Options for the resource.
endpoint (pulumi.Input[str]) – The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).
eventhub_consumer_group_name (pulumi.Input[str]) – 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.
iothub_namespace (pulumi.Input[str]) – The name or the URI of the IoT Hub.
name (pulumi.Input[str]) – The name of the Stream Input IoTHub. Changing this forces a new resource to be created.
resource_group_name (pulumi.Input[str]) – The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
serialization (pulumi.Input[dict]) – A serialization block as defined below.
shared_access_policy_key (pulumi.Input[str]) – The shared access policy key for the specified shared access policy.
shared_access_policy_name (pulumi.Input[str]) – The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.
stream_analytics_job_name (pulumi.Input[str]) – The name of the Stream Analytics Job. Changing this forces a new resource to be created.

The serialization object supports the following:

encoding (pulumi.Input[str]) - The encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. It currently can only be set to UTF8.
fieldDelimiter (pulumi.Input[str]) - The delimiter that will be used to separate comma-separated value (CSV) records. Possible values are ` (space),,(comma), (tab),|(pipe) and;`.
type (pulumi.Input[str]) - The serialization format used for incoming data streams. Possible values are Avro, Csv and Json.

translate_output_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of output properties into a format of their choosing before writing those properties to the resource object.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

translate_input_property(prop)¶

Provides subclasses of Resource an opportunity to translate names of input properties into a format of their choosing before sending those properties to the Pulumi engine.

Parameters: prop (str) – A property name.
Returns: A potentially transformed property name.
Return type: str

pulumi_azure.streamanalytics.get_job(name=None, resource_group_name=None, opts=None)¶

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

import pulumi
import pulumi_azure as azure

example = azure.streamanalytics.get_job(name="example-job",
    resource_group_name="example-resources")
pulumi.export("jobId", example.job_id)

Parameters

name (str) – Specifies the name of the Stream Analytics Job.
resource_group_name (str) – Specifies the name of the resource group the Stream Analytics Job is located in.

The Pulumi Platform

Get Started

Migrate to Pulumi

Solutions for All Teams and Engineers

Any Code

Any Cloud

streamanalytics¶

On This Page