OutputBlob

class OutputBlob : KotlinCustomResource

Manages a Stream Analytics Output to Blob Storage.

Example Usage

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azure.core.ResourceGroup;
import com.pulumi.azure.core.ResourceGroupArgs;
import com.pulumi.azure.streamanalytics.StreamanalyticsFunctions;
import com.pulumi.azure.streamanalytics.inputs.GetJobArgs;
import com.pulumi.azure.storage.Account;
import com.pulumi.azure.storage.AccountArgs;
import com.pulumi.azure.storage.Container;
import com.pulumi.azure.storage.ContainerArgs;
import com.pulumi.azure.streamanalytics.OutputBlob;
import com.pulumi.azure.streamanalytics.OutputBlobArgs;
import com.pulumi.azure.streamanalytics.inputs.OutputBlobSerializationArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var exampleResourceGroup = new ResourceGroup("exampleResourceGroup", ResourceGroupArgs.builder()
.location("West Europe")
.build());
final var exampleJob = StreamanalyticsFunctions.getJob(GetJobArgs.builder()
.name("example-job")
.resourceGroupName(exampleResourceGroup.name())
.build());
var exampleAccount = new Account("exampleAccount", AccountArgs.builder()
.resourceGroupName(exampleResourceGroup.name())
.location(exampleResourceGroup.location())
.accountTier("Standard")
.accountReplicationType("LRS")
.build());
var exampleContainer = new Container("exampleContainer", ContainerArgs.builder()
.storageAccountName(exampleAccount.name())
.containerAccessType("private")
.build());
var exampleOutputBlob = new OutputBlob("exampleOutputBlob", OutputBlobArgs.builder()
.streamAnalyticsJobName(exampleJob.applyValue(getJobResult -> getJobResult).applyValue(exampleJob -> exampleJob.applyValue(getJobResult -> getJobResult.name())))
.resourceGroupName(exampleJob.applyValue(getJobResult -> getJobResult).applyValue(exampleJob -> exampleJob.applyValue(getJobResult -> getJobResult.resourceGroupName())))
.storageAccountName(exampleAccount.name())
.storageAccountKey(exampleAccount.primaryAccessKey())
.storageContainerName(exampleContainer.name())
.pathPattern("some-pattern")
.dateFormat("yyyy-MM-dd")
.timeFormat("HH")
.serialization(OutputBlobSerializationArgs.builder()
.type("Csv")
.encoding("UTF8")
.fieldDelimiter(",")
.build())
.build());
}
}

Import

Stream Analytics Outputs to Blob Storage can be imported using the resource id, e.g.

$ pulumi import azure:streamanalytics/outputBlob:OutputBlob example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.StreamAnalytics/streamingJobs/job1/outputs/output1

Properties

Link copied to clipboard

The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.

Link copied to clipboard
val batchMaxWaitTime: Output<String>?

The maximum wait time per batch in hh:mm:ss e.g. 00:02:00 for two minutes.

Link copied to clipboard
val batchMinRows: Output<Int>?

The minimum number of rows per batch (must be between 0 and 1000000).

Link copied to clipboard
val dateFormat: Output<String>

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

Link copied to clipboard
val id: Output<String>
Link copied to clipboard
val name: Output<String>

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

Link copied to clipboard
val pathPattern: 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.

Link copied to clipboard
val pulumiChildResources: Set<KotlinResource>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

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

Link copied to clipboard

A serialization block as defined below.

Link copied to clipboard

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

Link copied to clipboard

The name of the Storage Account.

Link copied to clipboard

The name of the Container within the Storage Account.

Link copied to clipboard

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

Link copied to clipboard
val timeFormat: Output<String>

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

Link copied to clipboard
val urn: Output<String>