Streaming Jobs - Create Or Replace

Service:

Stream Analytics

API Version:

2020-03-01

Hiermee maakt u een streamingtaak of vervangt u een bestaande streamingtaak.

PUT https://management.azure.com/subscriptions/{subscriptionId}/resourcegroups/{resourceGroupName}/providers/Microsoft.StreamAnalytics/streamingjobs/{jobName}?api-version=2020-03-01

URI-parameters

Name	In	Vereist	Type	Description
jobName	path	True	string	De naam van de streamingtaak.
resourceGroupName	path	True	string	De naam van de resourcegroep. De naam is niet hoofdlettergevoelig. Regex pattern: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	De id van het doelabonnement.
api-version	query	True	string	De API-versie die voor deze bewerking moet worden gebruikt.

Aanvraagkoptekst

Name	Vereist	Type	Description
If-Match		string	De ETag van de streamingtaak. Laat deze waarde weg om altijd de huidige recordset te overschrijven. Geef de laatst gezienETag-waarde op om te voorkomen dat gelijktijdige wijzigingen per ongeluk worden overschreven.
If-None-Match		string	Stel in op *, zodat er een nieuwe streamingtaak kan worden gemaakt, maar om te voorkomen dat een bestaande recordset wordt bijgewerkt. Andere waarden resulteren in een 412 Pre-condition Failed-antwoord.

Aanvraagbody

Name	Type	Description
identity	Identity	Beschrijft de door het systeem toegewezen beheerde identiteit die aan deze taak is toegewezen en die kan worden gebruikt voor verificatie met invoer en uitvoer.
location	string	De geografische locatie waar de resource zich bevindt
properties.cluster	ClusterInfo	Het cluster waarop streamingtaken worden uitgevoerd.
properties.compatibilityLevel	CompatibilityLevel	Bepaalt bepaald runtimegedrag van de streamingtaak.
properties.contentStoragePolicy	ContentStoragePolicy	Geldige waarden zijn JobStorageAccount en SystemAccount. Als dit is ingesteld op JobStorageAccount, moet de gebruiker ook de eigenschap jobStorageAccount opgeven. .
properties.dataLocale	string	De landinstelling van de gegevens van de Stream Analytics-taak. Waarde moet de naam zijn van een ondersteunde .NET-cultuur uit de set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Standaard ingesteld op 'en-US' als er geen is opgegeven.
properties.eventsLateArrivalMaxDelayInSeconds	integer	De maximaal toegestane vertraging in seconden waarbij gebeurtenissen te laat aankomen, kunnen worden opgenomen. Het ondersteunde bereik is -1 tot 1814399 (20.23:59:59 dagen) en -1 wordt gebruikt om voor onbepaalde tijd wachten op te geven. Als de eigenschap afwezig is, wordt deze geïnterpreteerd als een waarde van -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	De maximaal toegestane vertraging in seconden waarbij gebeurtenissen die niet op volgorde zijn, kunnen worden aangepast om weer in orde te zijn.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Hiermee wordt het beleid aangegeven dat moet worden toegepast op gebeurtenissen die niet op volgorde binnenkomen in de invoer gebeurtenisstroom.
properties.functions	Function[]	Een lijst met een of meer functies voor de streamingtaak. De naameigenschap voor elke functie is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke transformatie.
properties.inputs	Input[]	Een lijst met een of meer invoergegevens voor de streamingtaak. De naameigenschap voor elke invoer is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke invoer.
properties.jobStorageAccount	JobStorageAccount	De eigenschappen die zijn gekoppeld aan een Azure Storage-account met MSI
properties.jobType	JobType	Beschrijft het type taak. Geldige modi zijn Cloud en 'Edge'.
properties.outputErrorPolicy	OutputErrorPolicy	Hiermee wordt het beleid aangegeven dat moet worden toegepast op gebeurtenissen die bij de uitvoer binnenkomen en niet naar de externe opslag kunnen worden geschreven vanwege een onjuiste indeling (ontbrekende kolomwaarden, kolomwaarden van het verkeerde type of de verkeerde grootte).
properties.outputStartMode	OutputStartMode	Deze eigenschap mag alleen worden gebruikt wanneer het gewenst is dat de taak onmiddellijk na het maken wordt gestart. De waarde kan JobStartTime, CustomTime of LastOutputEventTime zijn om aan te geven of het beginpunt van de uitvoergebeurtenisstroom moet beginnen wanneer de taak wordt gestart, moet beginnen met een aangepaste gebruikerstijdstempel die is opgegeven via de eigenschap outputStartTime of moet beginnen vanaf de laatste uitvoertijd van de gebeurtenis.
properties.outputStartTime	string	Waarde is een volgens ISO-8601 opgemaakte tijdstempel die het beginpunt van de uitvoergebeurtenisstroom aangeeft, of null om aan te geven dat de uitvoergebeurtenisstroom wordt gestart wanneer de streamingtaak wordt gestart. Deze eigenschap moet een waarde hebben als outputStartMode is ingesteld op CustomTime.
properties.outputs	Output[]	Een lijst met een of meer uitvoer voor de streamingtaak. De naameigenschap voor elke uitvoer is vereist wanneer u deze eigenschap opgeeft in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke uitvoer.
properties.sku	Sku	Beschrijft de SKU van de streamingtaak. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.transformation	Transformation	Geeft de query en het aantal streaming-eenheden aan dat moet worden gebruikt voor de streamingtaak. De naameigenschap van de transformatie is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke transformatie.
tags	object	Resourcetags.

Antwoorden

Name	Type	Description
200 OK	StreamingJob	De streamingtaak is gemaakt of vervangen. Headers ETag: string
201 Created	StreamingJob	De streamingtaak is gemaakt of vervangen. Headers ETag: string
Other Status Codes	Error	Fout.

Beveiliging

azure_auth

Azure Active Directory OAuth2-stroom

Type: oauth2
Flow: implicit
Authorization URL: https://login.microsoftonline.com/common/oauth2/authorize

Scopes

Name	Description
user_impersonation	Uw gebruikersaccount imiteren

Voorbeelden

Create a complete streaming job (a streaming job with a transformation, at least 1 input and at least 1 output)

Create a streaming job shell (a streaming job with no inputs, outputs, transformation, or functions)

Create a complete streaming job (a streaming job with a transformation, at least 1 input and at least 1 output)

Sample Request

HTTP

PUT https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804?api-version=2020-03-01

{
  "properties": {
    "sku": {
      "name": "Standard"
    },
    "eventsOutOfOrderPolicy": "Drop",
    "outputErrorPolicy": "Drop",
    "eventsOutOfOrderMaxDelayInSeconds": 0,
    "eventsLateArrivalMaxDelayInSeconds": 5,
    "dataLocale": "en-US",
    "compatibilityLevel": "1.0",
    "inputs": [
      {
        "properties": {
          "type": "Stream",
          "datasource": {
            "type": "Microsoft.Storage/Blob",
            "properties": {
              "storageAccounts": [
                {
                  "accountName": "yourAccountName",
                  "accountKey": "yourAccountKey=="
                }
              ],
              "container": "containerName",
              "pathPattern": ""
            }
          },
          "serialization": {
            "type": "Json",
            "properties": {
              "encoding": "UTF8"
            }
          }
        },
        "name": "inputtest"
      }
    ],
    "transformation": {
      "properties": {
        "streamingUnits": 1,
        "query": "Select Id, Name from inputtest"
      },
      "name": "transformationtest"
    },
    "outputs": [
      {
        "properties": {
          "datasource": {
            "type": "Microsoft.Sql/Server/Database",
            "properties": {
              "server": "serverName",
              "database": "databaseName",
              "user": "<user>",
              "password": "userPassword",
              "table": "tableName"
            }
          }
        },
        "name": "outputtest"
      }
    ],
    "functions": []
  },
  "location": "West US",
  "tags": {
    "key1": "value1",
    "randomKey": "randomValue",
    "key3": "value3"
  }
}

Java

import com.azure.resourcemanager.streamanalytics.fluent.models.InputInner;
import com.azure.resourcemanager.streamanalytics.fluent.models.OutputInner;
import com.azure.resourcemanager.streamanalytics.fluent.models.TransformationInner;
import com.azure.resourcemanager.streamanalytics.models.AzureSqlDatabaseOutputDataSource;
import com.azure.resourcemanager.streamanalytics.models.BlobStreamInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.CompatibilityLevel;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.EventsOutOfOrderPolicy;
import com.azure.resourcemanager.streamanalytics.models.JsonSerialization;
import com.azure.resourcemanager.streamanalytics.models.OutputErrorPolicy;
import com.azure.resourcemanager.streamanalytics.models.Sku;
import com.azure.resourcemanager.streamanalytics.models.SkuName;
import com.azure.resourcemanager.streamanalytics.models.StorageAccount;
import com.azure.resourcemanager.streamanalytics.models.StreamInputProperties;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

/** Samples for StreamingJobs CreateOrReplace. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/StreamingJob_Create_CompleteJob.json
     */
    /**
     * Sample code: Create a complete streaming job (a streaming job with a transformation, at least 1 input and at
     * least 1 output).
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager
            .streamingJobs()
            .define("sj7804")
            .withRegion("West US")
            .withExistingResourceGroup("sjrg3276")
            .withTags(mapOf("key1", "value1", "key3", "value3", "randomKey", "randomValue"))
            .withSku(new Sku().withName(SkuName.STANDARD))
            .withEventsOutOfOrderPolicy(EventsOutOfOrderPolicy.DROP)
            .withOutputErrorPolicy(OutputErrorPolicy.DROP)
            .withEventsOutOfOrderMaxDelayInSeconds(0)
            .withEventsLateArrivalMaxDelayInSeconds(5)
            .withDataLocale("en-US")
            .withCompatibilityLevel(CompatibilityLevel.ONE_ZERO)
            .withInputs(
                Arrays
                    .asList(
                        new InputInner()
                            .withProperties(
                                new StreamInputProperties()
                                    .withSerialization(new JsonSerialization().withEncoding(Encoding.UTF8))
                                    .withDatasource(
                                        new BlobStreamInputDataSource()
                                            .withStorageAccounts(
                                                Arrays
                                                    .asList(
                                                        new StorageAccount()
                                                            .withAccountName("yourAccountName")
                                                            .withAccountKey("yourAccountKey==")))
                                            .withContainer("containerName")
                                            .withPathPattern("")))
                            .withName("inputtest")))
            .withTransformation(
                new TransformationInner()
                    .withName("transformationtest")
                    .withStreamingUnits(1)
                    .withQuery("Select Id, Name from inputtest"))
            .withOutputs(
                Arrays
                    .asList(
                        new OutputInner()
                            .withName("outputtest")
                            .withDatasource(new AzureSqlDatabaseOutputDataSource())))
            .withFunctions(Arrays.asList())
            .create();
    }

    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/StreamingJob_Create_CompleteJob.json
func ExampleStreamingJobsClient_BeginCreateOrReplace_createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewStreamingJobsClient().BeginCreateOrReplace(ctx, "sjrg3276", "sj7804", armstreamanalytics.StreamingJob{
		Location: to.Ptr("West US"),
		Tags: map[string]*string{
			"key1":      to.Ptr("value1"),
			"key3":      to.Ptr("value3"),
			"randomKey": to.Ptr("randomValue"),
		},
		Properties: &armstreamanalytics.StreamingJobProperties{
			CompatibilityLevel:                 to.Ptr(armstreamanalytics.CompatibilityLevelOne0),
			DataLocale:                         to.Ptr("en-US"),
			EventsLateArrivalMaxDelayInSeconds: to.Ptr[int32](5),
			EventsOutOfOrderMaxDelayInSeconds:  to.Ptr[int32](0),
			EventsOutOfOrderPolicy:             to.Ptr(armstreamanalytics.EventsOutOfOrderPolicyDrop),
			Functions:                          []*armstreamanalytics.Function{},
			Inputs: []*armstreamanalytics.Input{
				{
					Name: to.Ptr("inputtest"),
					Properties: &armstreamanalytics.StreamInputProperties{
						Type: to.Ptr("Stream"),
						Serialization: &armstreamanalytics.JSONSerialization{
							Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
							Properties: &armstreamanalytics.JSONSerializationProperties{
								Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
							},
						},
						Datasource: &armstreamanalytics.BlobStreamInputDataSource{
							Type: to.Ptr("Microsoft.Storage/Blob"),
							Properties: &armstreamanalytics.BlobStreamInputDataSourceProperties{
								Container:   to.Ptr("containerName"),
								PathPattern: to.Ptr(""),
								StorageAccounts: []*armstreamanalytics.StorageAccount{
									{
										AccountKey:  to.Ptr("yourAccountKey=="),
										AccountName: to.Ptr("yourAccountName"),
									}},
							},
						},
					},
				}},
			OutputErrorPolicy: to.Ptr(armstreamanalytics.OutputErrorPolicyDrop),
			Outputs: []*armstreamanalytics.Output{
				{
					Name: to.Ptr("outputtest"),
					Properties: &armstreamanalytics.OutputProperties{
						Datasource: &armstreamanalytics.AzureSQLDatabaseOutputDataSource{
							Type: to.Ptr("Microsoft.Sql/Server/Database"),
							Properties: &armstreamanalytics.AzureSQLDatabaseOutputDataSourceProperties{
								Database: to.Ptr("databaseName"),
								Password: to.Ptr("userPassword"),
								Server:   to.Ptr("serverName"),
								Table:    to.Ptr("tableName"),
								User:     to.Ptr("<user>"),
							},
						},
					},
				}},
			SKU: &armstreamanalytics.SKU{
				Name: to.Ptr(armstreamanalytics.SKUNameStandard),
			},
			Transformation: &armstreamanalytics.Transformation{
				Name: to.Ptr("transformationtest"),
				Properties: &armstreamanalytics.TransformationProperties{
					Query:          to.Ptr("Select Id, Name from inputtest"),
					StreamingUnits: to.Ptr[int32](1),
				},
			},
		},
	}, &armstreamanalytics.StreamingJobsClientBeginCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: nil,
	})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.StreamingJob = armstreamanalytics.StreamingJob{
	// 	Name: to.Ptr("sj7804"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804"),
	// 	Location: to.Ptr("West US"),
	// 	Tags: map[string]*string{
	// 		"key1": to.Ptr("value1"),
	// 		"key3": to.Ptr("value3"),
	// 		"randomKey": to.Ptr("randomValue"),
	// 	},
	// 	Properties: &armstreamanalytics.StreamingJobProperties{
	// 		CompatibilityLevel: to.Ptr(armstreamanalytics.CompatibilityLevelOne0),
	// 		CreatedDate: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-05-11T04:37:11.540Z"); return t}()),
	// 		DataLocale: to.Ptr("en-US"),
	// 		EventsLateArrivalMaxDelayInSeconds: to.Ptr[int32](5),
	// 		EventsOutOfOrderMaxDelayInSeconds: to.Ptr[int32](0),
	// 		EventsOutOfOrderPolicy: to.Ptr(armstreamanalytics.EventsOutOfOrderPolicyDrop),
	// 		Functions: []*armstreamanalytics.Function{
	// 		},
	// 		Inputs: []*armstreamanalytics.Input{
	// 			{
	// 				Name: to.Ptr("inputtest"),
	// 				Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 				ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/inputs/inputtest"),
	// 				Properties: &armstreamanalytics.StreamInputProperties{
	// 					Type: to.Ptr("Stream"),
	// 					Etag: to.Ptr("ca88f8fa-605b-4c7f-8695-46f5faa60cd0"),
	// 					Serialization: &armstreamanalytics.JSONSerialization{
	// 						Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
	// 						Properties: &armstreamanalytics.JSONSerializationProperties{
	// 							Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 						},
	// 					},
	// 					Datasource: &armstreamanalytics.BlobStreamInputDataSource{
	// 						Type: to.Ptr("Microsoft.Storage/Blob"),
	// 						Properties: &armstreamanalytics.BlobStreamInputDataSourceProperties{
	// 							Container: to.Ptr("containerName"),
	// 							PathPattern: to.Ptr(""),
	// 							StorageAccounts: []*armstreamanalytics.StorageAccount{
	// 								{
	// 									AccountName: to.Ptr("accountName"),
	// 							}},
	// 						},
	// 					},
	// 				},
	// 		}},
	// 		JobID: to.Ptr("732e4b1d-94a7-43ae-8297-3ad04f1540b9"),
	// 		JobState: to.Ptr("Created"),
	// 		OutputErrorPolicy: to.Ptr(armstreamanalytics.OutputErrorPolicyDrop),
	// 		Outputs: []*armstreamanalytics.Output{
	// 			{
	// 				Name: to.Ptr("outputtest"),
	// 				Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
	// 				ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/outputs/outputtest"),
	// 				Properties: &armstreamanalytics.OutputProperties{
	// 					Datasource: &armstreamanalytics.AzureSQLDatabaseOutputDataSource{
	// 						Type: to.Ptr("Microsoft.Sql/Server/Database"),
	// 						Properties: &armstreamanalytics.AzureSQLDatabaseOutputDataSourceProperties{
	// 							Database: to.Ptr("databaseName"),
	// 							Server: to.Ptr("serverName"),
	// 							Table: to.Ptr("tableName"),
	// 							User: to.Ptr("userName"),
	// 						},
	// 					},
	// 					Etag: to.Ptr("62097c3c-b503-41ff-a56f-196a9598ab90"),
	// 				},
	// 		}},
	// 		ProvisioningState: to.Ptr("Succeeded"),
	// 		SKU: &armstreamanalytics.SKU{
	// 			Name: to.Ptr(armstreamanalytics.SKUNameStandard),
	// 		},
	// 		Transformation: &armstreamanalytics.Transformation{
	// 			Name: to.Ptr("transformationtest"),
	// 			Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/transformations"),
	// 			ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/transformations/transformationtest"),
	// 			Properties: &armstreamanalytics.TransformationProperties{
	// 				Etag: to.Ptr("91d8fcbe-60b3-49c3-9f21-9942b95602b8"),
	// 				Query: to.Ptr("Select Id, Name from inputtest"),
	// 				StreamingUnits: to.Ptr[int32](1),
	// 			},
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

JavaScript

const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Creates a streaming job or replaces an already existing streaming job.
 *
 * @summary Creates a streaming job or replaces an already existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/StreamingJob_Create_CompleteJob.json
 */
async function createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg3276";
  const jobName = "sj7804";
  const streamingJob = {
    compatibilityLevel: "1.0",
    dataLocale: "en-US",
    eventsLateArrivalMaxDelayInSeconds: 5,
    eventsOutOfOrderMaxDelayInSeconds: 0,
    eventsOutOfOrderPolicy: "Drop",
    functions: [],
    inputs: [
      {
        name: "inputtest",
        properties: {
          type: "Stream",
          datasource: {
            type: "Microsoft.Storage/Blob",
            container: "containerName",
            pathPattern: "",
            storageAccounts: [{ accountKey: "yourAccountKey==", accountName: "yourAccountName" }],
          },
          serialization: { type: "Json", encoding: "UTF8" },
        },
      },
    ],
    location: "West US",
    outputErrorPolicy: "Drop",
    outputs: [
      {
        name: "outputtest",
        datasource: {
          type: "Microsoft.Sql/Server/Database",
          database: "databaseName",
          password: "userPassword",
          server: "serverName",
          table: "tableName",
          user: "<user>",
        },
      },
    ],
    sku: { name: "Standard" },
    tags: { key1: "value1", key3: "value3", randomKey: "randomValue" },
    transformation: {
      name: "transformationtest",
      query: "Select Id, Name from inputtest",
      streamingUnits: 1,
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.streamingJobs.beginCreateOrReplaceAndWait(
    resourceGroupName,
    jobName,
    streamingJob
  );
  console.log(result);
}

createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output().catch(
  console.error
);

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Sample Response

Status code:

201

ETag: 87551cc5-1290-4d08-afcd-cdaa92e5ade0

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804",
  "name": "sj7804",
  "type": "Microsoft.StreamAnalytics/streamingjobs",
  "location": "West US",
  "tags": {
    "key1": "value1",
    "randomKey": "randomValue",
    "key3": "value3"
  },
  "properties": {
    "sku": {
      "name": "Standard"
    },
    "jobId": "732e4b1d-94a7-43ae-8297-3ad04f1540b9",
    "provisioningState": "Succeeded",
    "jobState": "Created",
    "eventsOutOfOrderPolicy": "Drop",
    "outputErrorPolicy": "Drop",
    "eventsOutOfOrderMaxDelayInSeconds": 0,
    "eventsLateArrivalMaxDelayInSeconds": 5,
    "dataLocale": "en-US",
    "createdDate": "2017-05-11T04:37:11.54Z",
    "compatibilityLevel": "1.0",
    "inputs": [
      {
        "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/inputs/inputtest",
        "name": "inputtest",
        "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
        "properties": {
          "type": "Stream",
          "datasource": {
            "type": "Microsoft.Storage/Blob",
            "properties": {
              "storageAccounts": [
                {
                  "accountName": "accountName"
                }
              ],
              "container": "containerName",
              "pathPattern": ""
            }
          },
          "serialization": {
            "type": "Json",
            "properties": {
              "encoding": "UTF8"
            }
          },
          "etag": "ca88f8fa-605b-4c7f-8695-46f5faa60cd0"
        }
      }
    ],
    "transformation": {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/transformations/transformationtest",
      "name": "transformationtest",
      "type": "Microsoft.StreamAnalytics/streamingjobs/transformations",
      "properties": {
        "streamingUnits": 1,
        "query": "Select Id, Name from inputtest",
        "etag": "91d8fcbe-60b3-49c3-9f21-9942b95602b8"
      }
    },
    "functions": [],
    "outputs": [
      {
        "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/outputs/outputtest",
        "name": "outputtest",
        "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
        "properties": {
          "datasource": {
            "type": "Microsoft.Sql/Server/Database",
            "properties": {
              "server": "serverName",
              "database": "databaseName",
              "table": "tableName",
              "user": "userName"
            }
          },
          "etag": "62097c3c-b503-41ff-a56f-196a9598ab90"
        }
      }
    ]
  }
}

Status code:

200

ETag: 87551cc5-1290-4d08-afcd-cdaa92e5ade0

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804",
  "name": "sj7804",
  "type": "Microsoft.StreamAnalytics/streamingjobs",
  "location": "West US",
  "tags": {
    "key1": "value1",
    "randomKey": "randomValue",
    "key3": "value3"
  },
  "properties": {
    "sku": {
      "name": "Standard"
    },
    "jobId": "732e4b1d-94a7-43ae-8297-3ad04f1540b9",
    "provisioningState": "Succeeded",
    "jobState": "Created",
    "eventsOutOfOrderPolicy": "Drop",
    "outputErrorPolicy": "Drop",
    "eventsOutOfOrderMaxDelayInSeconds": 0,
    "eventsLateArrivalMaxDelayInSeconds": 5,
    "dataLocale": "en-US",
    "createdDate": "2017-05-11T04:37:11.54Z",
    "compatibilityLevel": "1.0",
    "inputs": [
      {
        "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/inputs/inputtest",
        "name": "inputtest",
        "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
        "properties": {
          "type": "Stream",
          "datasource": {
            "type": "Microsoft.Storage/Blob",
            "properties": {
              "storageAccounts": [
                {
                  "accountName": "accountName"
                }
              ],
              "container": "containerName",
              "pathPattern": ""
            }
          },
          "serialization": {
            "type": "Json",
            "properties": {
              "encoding": "UTF8"
            }
          },
          "etag": "ca88f8fa-605b-4c7f-8695-46f5faa60cd0"
        }
      }
    ],
    "transformation": {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/transformations/transformationtest",
      "name": "transformationtest",
      "type": "Microsoft.StreamAnalytics/streamingjobs/transformations",
      "properties": {
        "streamingUnits": 1,
        "query": "Select Id, Name from inputtest",
        "etag": "91d8fcbe-60b3-49c3-9f21-9942b95602b8"
      }
    },
    "functions": [],
    "outputs": [
      {
        "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/outputs/outputtest",
        "name": "outputtest",
        "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
        "properties": {
          "datasource": {
            "type": "Microsoft.Sql/Server/Database",
            "properties": {
              "server": "serverName",
              "database": "databaseName",
              "table": "tableName",
              "user": "userName"
            }
          },
          "etag": "62097c3c-b503-41ff-a56f-196a9598ab90"
        }
      }
    ]
  }
}

Create a streaming job shell (a streaming job with no inputs, outputs, transformation, or functions)

Sample Request

HTTP

PUT https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg6936/providers/Microsoft.StreamAnalytics/streamingjobs/sj59?api-version=2020-03-01

{
  "properties": {
    "sku": {
      "name": "Standard"
    },
    "eventsOutOfOrderPolicy": "Drop",
    "outputErrorPolicy": "Drop",
    "eventsOutOfOrderMaxDelayInSeconds": 5,
    "eventsLateArrivalMaxDelayInSeconds": 16,
    "dataLocale": "en-US",
    "compatibilityLevel": "1.0",
    "inputs": [],
    "outputs": [],
    "functions": []
  },
  "location": "West US",
  "tags": {
    "key1": "value1",
    "randomKey": "randomValue",
    "key3": "value3"
  }
}

Java

import com.azure.resourcemanager.streamanalytics.models.CompatibilityLevel;
import com.azure.resourcemanager.streamanalytics.models.EventsOutOfOrderPolicy;
import com.azure.resourcemanager.streamanalytics.models.OutputErrorPolicy;
import com.azure.resourcemanager.streamanalytics.models.Sku;
import com.azure.resourcemanager.streamanalytics.models.SkuName;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

/** Samples for StreamingJobs CreateOrReplace. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/StreamingJob_Create_JobShell.json
     */
    /**
     * Sample code: Create a streaming job shell (a streaming job with no inputs, outputs, transformation, or
     * functions).
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager
            .streamingJobs()
            .define("sj59")
            .withRegion("West US")
            .withExistingResourceGroup("sjrg6936")
            .withTags(mapOf("key1", "value1", "key3", "value3", "randomKey", "randomValue"))
            .withSku(new Sku().withName(SkuName.STANDARD))
            .withEventsOutOfOrderPolicy(EventsOutOfOrderPolicy.DROP)
            .withOutputErrorPolicy(OutputErrorPolicy.DROP)
            .withEventsOutOfOrderMaxDelayInSeconds(5)
            .withEventsLateArrivalMaxDelayInSeconds(16)
            .withDataLocale("en-US")
            .withCompatibilityLevel(CompatibilityLevel.ONE_ZERO)
            .withInputs(Arrays.asList())
            .withOutputs(Arrays.asList())
            .withFunctions(Arrays.asList())
            .create();
    }

    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/StreamingJob_Create_JobShell.json
func ExampleStreamingJobsClient_BeginCreateOrReplace_createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewStreamingJobsClient().BeginCreateOrReplace(ctx, "sjrg6936", "sj59", armstreamanalytics.StreamingJob{
		Location: to.Ptr("West US"),
		Tags: map[string]*string{
			"key1":      to.Ptr("value1"),
			"key3":      to.Ptr("value3"),
			"randomKey": to.Ptr("randomValue"),
		},
		Properties: &armstreamanalytics.StreamingJobProperties{
			CompatibilityLevel:                 to.Ptr(armstreamanalytics.CompatibilityLevelOne0),
			DataLocale:                         to.Ptr("en-US"),
			EventsLateArrivalMaxDelayInSeconds: to.Ptr[int32](16),
			EventsOutOfOrderMaxDelayInSeconds:  to.Ptr[int32](5),
			EventsOutOfOrderPolicy:             to.Ptr(armstreamanalytics.EventsOutOfOrderPolicyDrop),
			Functions:                          []*armstreamanalytics.Function{},
			Inputs:                             []*armstreamanalytics.Input{},
			OutputErrorPolicy:                  to.Ptr(armstreamanalytics.OutputErrorPolicyDrop),
			Outputs:                            []*armstreamanalytics.Output{},
			SKU: &armstreamanalytics.SKU{
				Name: to.Ptr(armstreamanalytics.SKUNameStandard),
			},
		},
	}, &armstreamanalytics.StreamingJobsClientBeginCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: nil,
	})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.StreamingJob = armstreamanalytics.StreamingJob{
	// 	Name: to.Ptr("sj59"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6936/providers/Microsoft.StreamAnalytics/streamingjobs/sj59"),
	// 	Location: to.Ptr("West US"),
	// 	Tags: map[string]*string{
	// 		"key1": to.Ptr("value1"),
	// 		"key3": to.Ptr("value3"),
	// 		"randomKey": to.Ptr("randomValue"),
	// 	},
	// 	Properties: &armstreamanalytics.StreamingJobProperties{
	// 		CompatibilityLevel: to.Ptr(armstreamanalytics.CompatibilityLevelOne0),
	// 		CreatedDate: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-05-11T04:37:04.697Z"); return t}()),
	// 		DataLocale: to.Ptr("en-US"),
	// 		EventsLateArrivalMaxDelayInSeconds: to.Ptr[int32](16),
	// 		EventsOutOfOrderMaxDelayInSeconds: to.Ptr[int32](5),
	// 		EventsOutOfOrderPolicy: to.Ptr(armstreamanalytics.EventsOutOfOrderPolicyDrop),
	// 		Functions: []*armstreamanalytics.Function{
	// 		},
	// 		Inputs: []*armstreamanalytics.Input{
	// 		},
	// 		JobID: to.Ptr("d53ecc3c-fcb0-485d-9caf-25e20fcb2061"),
	// 		JobState: to.Ptr("Created"),
	// 		OutputErrorPolicy: to.Ptr(armstreamanalytics.OutputErrorPolicyDrop),
	// 		Outputs: []*armstreamanalytics.Output{
	// 		},
	// 		ProvisioningState: to.Ptr("Succeeded"),
	// 		SKU: &armstreamanalytics.SKU{
	// 			Name: to.Ptr(armstreamanalytics.SKUNameStandard),
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

JavaScript

const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Creates a streaming job or replaces an already existing streaming job.
 *
 * @summary Creates a streaming job or replaces an already existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/StreamingJob_Create_JobShell.json
 */
async function createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg6936";
  const jobName = "sj59";
  const streamingJob = {
    compatibilityLevel: "1.0",
    dataLocale: "en-US",
    eventsLateArrivalMaxDelayInSeconds: 16,
    eventsOutOfOrderMaxDelayInSeconds: 5,
    eventsOutOfOrderPolicy: "Drop",
    functions: [],
    inputs: [],
    location: "West US",
    outputErrorPolicy: "Drop",
    outputs: [],
    sku: { name: "Standard" },
    tags: { key1: "value1", key3: "value3", randomKey: "randomValue" },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.streamingJobs.beginCreateOrReplaceAndWait(
    resourceGroupName,
    jobName,
    streamingJob
  );
  console.log(result);
}

createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions().catch(
  console.error
);

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Sample Response

Status code:

201

ETag: 3e6872bc-c9d0-45b6-91b6-da66f1773056

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6936/providers/Microsoft.StreamAnalytics/streamingjobs/sj59",
  "name": "sj59",
  "type": "Microsoft.StreamAnalytics/streamingjobs",
  "location": "West US",
  "tags": {
    "key1": "value1",
    "randomKey": "randomValue",
    "key3": "value3"
  },
  "properties": {
    "sku": {
      "name": "Standard"
    },
    "jobId": "d53ecc3c-fcb0-485d-9caf-25e20fcb2061",
    "provisioningState": "Succeeded",
    "jobState": "Created",
    "eventsOutOfOrderPolicy": "Drop",
    "outputErrorPolicy": "Drop",
    "eventsOutOfOrderMaxDelayInSeconds": 5,
    "eventsLateArrivalMaxDelayInSeconds": 16,
    "dataLocale": "en-US",
    "createdDate": "2017-05-11T04:37:04.697Z",
    "compatibilityLevel": "1.0",
    "inputs": [],
    "functions": [],
    "outputs": []
  }
}

Status code:

200

ETag: 3e6872bc-c9d0-45b6-91b6-da66f1773056

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6936/providers/Microsoft.StreamAnalytics/streamingjobs/sj59",
  "name": "sj59",
  "type": "Microsoft.StreamAnalytics/streamingjobs",
  "location": "West US",
  "tags": {
    "key1": "value1",
    "randomKey": "randomValue",
    "key3": "value3"
  },
  "properties": {
    "sku": {
      "name": "Standard"
    },
    "jobId": "d53ecc3c-fcb0-485d-9caf-25e20fcb2061",
    "provisioningState": "Succeeded",
    "jobState": "Created",
    "eventsOutOfOrderPolicy": "Drop",
    "outputErrorPolicy": "Drop",
    "eventsOutOfOrderMaxDelayInSeconds": 5,
    "eventsLateArrivalMaxDelayInSeconds": 16,
    "dataLocale": "en-US",
    "createdDate": "2017-05-11T04:37:04.697Z",
    "compatibilityLevel": "1.0",
    "inputs": [],
    "functions": [],
    "outputs": []
  }
}

Definities

Name	Description
AggregateFunctionProperties	De eigenschappen die zijn gekoppeld aan een statistische functie.
AuthenticationMode	Verificatiemodus. Geldige modi zijn ConnectionString, Msi en 'UserToken'.
AvroSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in Avro-indeling worden geschreven.
AzureDataLakeStoreOutputDataSource	Beschrijft een Azure Data Lake Store-uitvoergegevensbron.
AzureFunctionOutputDataSource	Definieert de metagegevens van AzureFunctionOutputDataSource
AzureMachineLearningWebServiceFunctionBinding	De binding met een Azure Machine Learning-webservice.
AzureMachineLearningWebServiceInputColumn	Beschrijft een invoerkolom voor het Azure Machine Learning-webservice-eindpunt.
AzureMachineLearningWebServiceInputs	De invoer voor het eindpunt van de Azure Machine Learning-webservice.
AzureMachineLearningWebServiceOutputColumn	Beschrijft een uitvoerkolom voor het Azure Machine Learning-webservice-eindpunt.
AzureSqlDatabaseOutputDataSource	Beschrijft een Azure SQL database-uitvoergegevensbron.
AzureSqlReferenceInputDataSource	Beschrijft een Azure SQL databasereferentieinvoergegevensbron.
AzureSynapseOutputDataSource	Beschrijft een Azure Synapse uitvoergegevensbron.
AzureTableOutputDataSource	Beschrijft een Azure Table-uitvoergegevensbron.
BlobOutputDataSource	Beschrijft een blob-uitvoergegevensbron.
BlobReferenceInputDataSource	Beschrijft een blob-invoergegevensbron die referentiegegevens bevat.
BlobStreamInputDataSource	Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.
ClusterInfo	De eigenschappen die zijn gekoppeld aan een Stream Analytics-cluster.
CompatibilityLevel	Bepaalt bepaald runtimegedrag van de streamingtaak.
Compression	Beschrijft hoe invoergegevens worden gecomprimeerd
CompressionType	Geeft het type compressie aan dat door de invoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).
ContentStoragePolicy	Geldige waarden zijn JobStorageAccount en SystemAccount. Als deze optie is ingesteld op JobStorageAccount, moet de gebruiker ook de eigenschap jobStorageAccount opgeven. .
CsvSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in CSV-indeling worden geschreven.
DiagnosticCondition	Voorwaarde die van toepassing is op de resource, of op de taak in het algemeen, die de aandacht van de klant rechtvaardigt.
Diagnostics	Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.
DocumentDbOutputDataSource	Beschrijft een DocumentDB-uitvoergegevensbron.
Encoding	Hiermee geeft u de codering van de binnenkomende gegevens in het geval van invoer en de codering van uitgaande gegevens in het geval van uitvoer.
Error	Veelvoorkomende foutweergave.
EventHubOutputDataSource	Beschrijft een Event Hub-uitvoergegevensbron.
EventHubStreamInputDataSource	Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.
EventHubV2OutputDataSource	Beschrijft een Event Hub-uitvoergegevensbron.
EventHubV2StreamInputDataSource	Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.
EventSerializationType	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).
EventsOutOfOrderPolicy	Geeft het beleid aan dat moet worden toegepast op gebeurtenissen die niet op volgorde binnenkomen in de invoer gebeurtenisstroom.
FileReferenceInputDataSource	Beschrijft een bestandsinvoergegevensbron die referentiegegevens bevat.
Function	Een functieobject, met alle informatie die is gekoppeld aan de benoemde functie. Alle functies bevinden zich onder een streamingtaak.
FunctionInput	Beschrijft één invoerparameter van een functie.
FunctionOutput	Beschrijft de uitvoer van een functie.
GatewayMessageBusOutputDataSource	Beschrijft een gateway message bus-uitvoergegevensbron.
GatewayMessageBusStreamInputDataSource	Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.
Identity	Beschrijft hoe identiteit wordt geverifieerd
Input	Een invoerobject, met alle informatie die is gekoppeld aan de benoemde invoer. Alle invoer bevindt zich onder een streamingtaak.
IoTHubStreamInputDataSource	Beschrijft een IoT Hub invoergegevensbron die stroomgegevens bevat.
JavaScriptFunctionBinding	De binding met een JavaScript-functie.
JobStorageAccount	De eigenschappen die zijn gekoppeld aan een Azure Storage-account met MSI
JobType	Beschrijft het type taak. Geldige modi zijn Cloud en 'Edge'.
JsonOutputSerializationFormat	Hiermee geeft u de indeling van de JSON waarin de uitvoer wordt geschreven. De momenteel ondersteunde waarden zijn 'lineSeparated' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt door elk JSON-object te laten scheiden door een nieuwe regel en 'matrix' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt als een matrix van JSON-objecten.
JsonSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in JSON-indeling worden geschreven.
Output	Een uitvoerobject, met alle informatie die is gekoppeld aan de benoemde uitvoer. Alle uitvoer bevindt zich onder een streamingtaak.
OutputErrorPolicy	Geeft het beleid aan dat moet worden toegepast op gebeurtenissen die bij de uitvoer binnenkomen en niet naar de externe opslag kunnen worden geschreven vanwege een onjuiste indeling (ontbrekende kolomwaarden, kolomwaarden van een onjuist type of een verkeerde grootte).
OutputStartMode	De waarde kan JobStartTime, CustomTime of LastOutputEventTime zijn om aan te geven of het beginpunt van de uitvoer gebeurtenisstroom moet starten wanneer de taak wordt gestart, moet beginnen met een aangepaste gebruikerstijdstempel die is opgegeven via de eigenschap outputStartTime of moet beginnen vanaf de laatste uitvoertijd van de gebeurtenis.
ParquetSerialization	Hierin wordt beschreven hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in Parquet-indeling worden geschreven.
PowerBIOutputDataSource	Beschrijft een Power BI-uitvoergegevensbron.
ReferenceInputProperties	De eigenschappen die zijn gekoppeld aan een invoer die referentiegegevens bevat.
RefreshType	Hiermee wordt het type optie voor het vernieuwen van gegevens aangegeven.
ScalarFunctionProperties	De eigenschappen die zijn gekoppeld aan een scalaire functie.
ServiceBusQueueOutputDataSource	Beschrijft een Service Bus Queue-uitvoergegevensbron.
ServiceBusTopicOutputDataSource	Beschrijft een gegevensbron voor de uitvoer van een Service Bus-onderwerp.
Sku	De eigenschappen die zijn gekoppeld aan een SKU.
SkuName	De naam van de SKU. Vereist voor PUT-aanvragen (CreateOrReplace).
StorageAccount	De eigenschappen die zijn gekoppeld aan een Azure Storage-account
StreamingJob	Een streamingtaakobject, met alle informatie die is gekoppeld aan de benoemde streamingtaak.
StreamInputProperties	De eigenschappen die zijn gekoppeld aan een invoer die stroomgegevens bevat.
Transformation	Een transformatieobject, met alle informatie die is gekoppeld aan de benoemde transformatie. Alle transformaties bevinden zich onder een streamingtaak.

AggregateFunctionProperties

De eigenschappen die zijn gekoppeld aan een statistische functie.

Name	Type	Description
etag	string	De huidige entiteitstag voor de functie. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource tussen aanvragen is gewijzigd. U kunt deze ook gebruiken in de headers If-Match of If-None-Match voor schrijfbewerkingen voor optimistische gelijktijdigheid.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	De fysieke binding van de functie. In het geval van de Azure Machine Learning-webservice beschrijft dit bijvoorbeeld het eindpunt.
properties.inputs	FunctionInput[]	Beschrijft één invoerparameter van een functie.
properties.output	FunctionOutput	Beschrijft de uitvoer van een functie.
type	string: Aggregate	Geeft het type functie aan.

AuthenticationMode

Verificatiemodus. Geldige modi zijn ConnectionString, Msi en 'UserToken'.

Name	Type	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in Avro-indeling worden geschreven.

Name	Type	Description
type	string: Avro	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Beschrijft een Azure Data Lake Store-uitvoergegevensbron.

Name	Type	Standaardwaarde	Description
properties.accountName	string		De naam van het Azure Data Lake Store-account. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.dateFormat	string		De datumnotatie. Overal waar {date} wordt weergegeven in filePathPrefix, wordt de waarde van deze eigenschap gebruikt als de datumnotatie.
properties.filePathPrefix	string		De locatie van het bestand waarnaar de uitvoer moet worden geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.refreshToken	string		Een vernieuwingstoken dat kan worden gebruikt om een geldig toegangstoken te verkrijgen dat vervolgens kan worden gebruikt voor verificatie bij de gegevensbron. Een geldig vernieuwingstoken is momenteel alleen verkrijgbaar via Azure Portal. Het wordt aanbevolen om hier een waarde voor een dummytekenreeks te plaatsen wanneer u de gegevensbron maakt en vervolgens naar de Azure-portal gaat om de gegevensbron te verifiëren die deze eigenschap bijwerkt met een geldig vernieuwingstoken. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.tenantId	string		De tenant-id van de gebruiker die is gebruikt om het vernieuwingstoken te verkrijgen. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.timeFormat	string		De tijdnotatie. Overal waar {time} wordt weergegeven in filePathPrefix, wordt de waarde van deze eigenschap gebruikt als de tijdnotatie.
properties.tokenUserDisplayName	string		De weergavenaam van de gebruiker die is gebruikt om het vernieuwingstoken te verkrijgen. Gebruik deze eigenschap om te onthouden welke gebruiker is gebruikt om het vernieuwingstoken te verkrijgen.
properties.tokenUserPrincipalName	string		De USER Principal Name (UPN) van de gebruiker die is gebruikt om het vernieuwingstoken te verkrijgen. Gebruik deze eigenschap om te onthouden welke gebruiker is gebruikt om het vernieuwingstoken te verkrijgen.
type	string: Microsoft.DataLake/Accounts		Geeft aan naar welk type uitvoer van de gegevensbron wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureFunctionOutputDataSource

Definieert de metagegevens van AzureFunctionOutputDataSource

Name	Type	Description
properties.apiKey	string	Als u een Azure-functie uit een ander abonnement wilt gebruiken, kunt u dit doen door de sleutel op te geven voor toegang tot uw functie.
properties.functionAppName	string	De naam van uw Azure Functions-app.
properties.functionName	string	De naam van de functie in uw Azure Functions-app.
properties.maxBatchCount	number	Een eigenschap waarmee u het maximum aantal gebeurtenissen in elke batch kunt opgeven dat naar Azure Functions wordt verzonden. De standaardwaarde is 100.
properties.maxBatchSize	number	Een eigenschap waarmee u de maximale grootte kunt instellen voor elke uitvoerbatch die naar uw Azure-functie wordt verzonden. De invoereenheid is in bytes. Deze waarde is standaard 262.144 bytes (256 kB).
type	string: Microsoft.AzureFunction	Geeft aan naar welk type gegevensbronuitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

De binding met een Azure Machine Learning-webservice.

Name	Type	Description
properties.apiKey	string	De API-sleutel die wordt gebruikt voor verificatie met Request-Response eindpunt.
properties.batchSize	integer	Getal tussen 1 en 10000 dat het maximum aantal rijen beschrijft voor elke Azure ML RRS-uitvoeringsaanvraag. De standaardwaarde is 1000.
properties.endpoint	string	Het Request-Response eindpunt van de Azure Machine Learning-webservice uitvoeren. Meer informatie vindt u hier: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
properties.inputs	AzureMachineLearningWebServiceInputs	De invoer voor het eindpunt van de Azure Machine Learning-webservice.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Een lijst met uitvoer van het eindpunt van de Azure Machine Learning-webservice.
type	string: Microsoft.MachineLearning/WebService	Geeft het type functiebinding aan.

AzureMachineLearningWebServiceInputColumn

Beschrijft een invoerkolom voor het Azure Machine Learning-webservice-eindpunt.

Name	Type	Description
dataType	string	Het gegevenstype (ondersteund door Azure Machine Learning) van de invoerkolom. Een lijst met geldige Azure Machine Learning-gegevenstypen wordt beschreven op https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
mapTo	integer	De op nul gebaseerde index van de functieparameter waaraan deze invoer wordt toegewezen.
name	string	De naam van de invoerkolom.

AzureMachineLearningWebServiceInputs

De invoer voor het eindpunt van de Azure Machine Learning-webservice.

Name	Type	Description
columnNames	AzureMachineLearningWebServiceInputColumn[]	Een lijst met invoerkolommen voor het Eindpunt van de Azure Machine Learning-webservice.
name	string	De naam van de invoer. Dit is de naam die is opgegeven tijdens het ontwerpen van het eindpunt.

AzureMachineLearningWebServiceOutputColumn

Beschrijft een uitvoerkolom voor het Azure Machine Learning-webservice-eindpunt.

Name	Type	Description
dataType	string	Het gegevenstype (ondersteund door Azure Machine Learning) van de uitvoerkolom. Een lijst met geldige Azure Machine Learning-gegevenstypen wordt beschreven op https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
name	string	De naam van de uitvoerkolom.

AzureSqlDatabaseOutputDataSource

Beschrijft een Azure SQL database-uitvoergegevensbron.

Name	Type	Standaardwaarde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.database	string		De naam van de Azure SQL-database. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.maxBatchCount	number		Het maximale aantal batchs voor schrijven naar sql-database, de standaardwaarde is 10.000. Optioneel voor PUT-aanvragen.
properties.maxWriterCount	number		Maximaal aantal schrijvers, momenteel zijn alleen 1 (enkele schrijver) en 0 (op basis van querypartitie) beschikbaar. Optioneel voor PUT-aanvragen.
properties.password	string		Het wachtwoord dat wordt gebruikt om verbinding te maken met de Azure SQL-database. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.server	string		De naam van de SQL-server met de Azure SQL database. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.table	string		De naam van de tabel in de Azure SQL database. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.user	string		De gebruikersnaam die wordt gebruikt om verbinding te maken met de Azure SQL-database. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.Sql/Server/Database		Geeft aan naar welk type gegevensbronuitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureSqlReferenceInputDataSource

Beschrijft een Azure SQL databasereferentieinvoergegevensbron.

Name	Type	Description
properties.database	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is de naam van de database waarnaar uitvoer wordt geschreven.
properties.deltaSnapshotQuery	string	Dit element is gekoppeld aan het gegevensbronelement. Deze query wordt gebruikt om incrementele wijzigingen op te halen uit de SQL-database. Als u deze optie wilt gebruiken, raden we u aan tijdelijke tabellen te gebruiken in Azure SQL Database.
properties.fullSnapshotQuery	string	Dit element is gekoppeld aan het gegevensbronelement. Deze query wordt gebruikt om gegevens op te halen uit de SQL-database.
properties.password	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is het wachtwoord dat wordt gebruikt om verbinding te maken met het SQL Database-exemplaar.
properties.refreshRate	string	Dit element is gekoppeld aan het gegevensbronelement. Hiermee wordt aangegeven hoe vaak de gegevens uit de database worden opgehaald. Het heeft de datum/tijd-indeling.
properties.refreshType	RefreshType	Hiermee wordt het type optie voor het vernieuwen van gegevens aangegeven.
properties.server	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is de naam van de server die de database bevat waarnaar wordt geschreven.
properties.table	string	Dit element is gekoppeld aan het gegevensbronelement. De naam van de tabel in de Azure SQL database.
properties.user	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is de gebruikersnaam die wordt gebruikt om verbinding te maken met het SQL Database exemplaar.
type	string: Microsoft.Sql/Server/Database	Geeft het type invoergegevensbron met referentiegegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureSynapseOutputDataSource

Beschrijft een Azure Synapse uitvoergegevensbron.

Name	Type	Description
properties.database	string	De naam van de Azure SQL-database. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.password	string	Het wachtwoord dat wordt gebruikt om verbinding te maken met de Azure SQL-database. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.server	string	De naam van de SQL-server met de Azure SQL database. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.table	string	De naam van de tabel in de Azure SQL database. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.user	string	De gebruikersnaam die wordt gebruikt om verbinding te maken met de Azure SQL-database. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.Sql/Server/DataWarehouse	Geeft aan naar welk type gegevensbronuitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureTableOutputDataSource

Beschrijft een Azure Table-uitvoergegevensbron.

Name	Type	Description
properties.accountKey	string	De accountsleutel voor het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.accountName	string	De naam van het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.batchSize	integer	Het aantal rijen dat tegelijk naar de Azure-tabel moet worden geschreven.
properties.columnsToRemove	string[]	Indien opgegeven, is elk item in de matrix de naam van een kolom die moet worden verwijderd (indien aanwezig) uit uitvoer gebeurtenisentiteiten.
properties.partitionKey	string	Dit element geeft de naam aan van een kolom uit de SELECT-instructie in de query die wordt gebruikt als de partitiesleutel voor de Azure-tabel. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.rowKey	string	Dit element geeft de naam aan van een kolom uit de SELECT-instructie in de query die wordt gebruikt als de rijsleutel voor de Azure-tabel. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.table	string	De naam van de Azure-tabel. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.Storage/Table	Geeft aan naar welk type gegevensbronuitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

BlobOutputDataSource

Beschrijft een blob-uitvoergegevensbron.

Name	Type	Standaardwaarde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.blobPathPrefix	string		Voorvoegsel van blobpad.
properties.container	string		De naam van een container in het gekoppelde opslagaccount. Deze container bevat de blob(s) waaruit moet worden gelezen of geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.dateFormat	string		De datumnotatie. Overal waar {date} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de datumnotatie.
properties.pathPattern	string		Het blobpadpatroon. Geen reguliere expressie. Het vertegenwoordigt een patroon waarmee blobnamen worden vergeleken om te bepalen of ze moeten worden opgenomen als invoer of uitvoer voor de taak. Zie https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input of https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output voor een meer gedetailleerde uitleg en voorbeeld.
properties.storageAccounts	StorageAccount[]		Een lijst met een of meer Azure Storage-accounts. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.timeFormat	string		De tijdnotatie. Overal waar {time} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de tijdnotatie.
type	string: Microsoft.Storage/Blob		Geeft aan naar welk type gegevensbronuitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

BlobReferenceInputDataSource

Beschrijft een blob-invoergegevensbron die referentiegegevens bevat.

Name	Type	Standaardwaarde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.container	string		De naam van een container in het gekoppelde opslagaccount. Deze container bevat de blob(s) waaruit moet worden gelezen of geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.dateFormat	string		De datumnotatie. Overal waar {date} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als datumnotatie.
properties.pathPattern	string		Het blobpadpatroon. Geen reguliere expressie. Het vertegenwoordigt een patroon waarmee blobnamen worden vergeleken om te bepalen of ze moeten worden opgenomen als invoer of uitvoer voor de taak. Zie https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input of https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output voor een meer gedetailleerde uitleg en voorbeeld.
properties.storageAccounts	StorageAccount[]		Een lijst met een of meer Azure Storage-accounts. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.timeFormat	string		De tijdnotatie. Overal waar {time} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de tijdnotatie.
type	string: Microsoft.Storage/Blob		Geeft het type invoergegevensbron met referentiegegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

BlobStreamInputDataSource

Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.

Name	Type	Standaardwaarde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.container	string		De naam van een container in het gekoppelde opslagaccount. Deze container bevat de blob(s) waaruit moet worden gelezen of geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.dateFormat	string		De datumnotatie. Overal waar {date} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de datumnotatie.
properties.pathPattern	string		Het blobpadpatroon. Geen reguliere expressie. Het vertegenwoordigt een patroon waarmee blobnamen worden vergeleken om te bepalen of ze moeten worden opgenomen als invoer of uitvoer voor de taak. Zie https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input of https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output voor een meer gedetailleerde uitleg en voorbeeld.
properties.sourcePartitionCount	integer		Het aantal partities van de blob-invoergegevensbron. Bereik 1 - 1024.
properties.storageAccounts	StorageAccount[]		Een lijst met een of meer Azure Storage-accounts. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.timeFormat	string		De tijdnotatie. Overal waar {time} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de tijdnotatie.
type	string: Microsoft.Storage/Blob		Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

ClusterInfo

De eigenschappen die zijn gekoppeld aan een Stream Analytics-cluster.

Name	Type	Description
id	string	De resource-id van het cluster.

CompatibilityLevel

Bepaalt bepaald runtimegedrag van de streamingtaak.

Name	Type	Description
1.0	string
1.2	string

Compression

Beschrijft hoe invoergegevens worden gecomprimeerd

Name	Type	Standaardwaarde	Description
type	CompressionType	None	Geeft het type compressie aan dat door de invoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

CompressionType

Geeft het type compressie aan dat door de invoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

Name	Type	Description
Deflate	string
GZip	string
None	string

ContentStoragePolicy

Geldige waarden zijn JobStorageAccount en SystemAccount. Als deze optie is ingesteld op JobStorageAccount, moet de gebruiker ook de eigenschap jobStorageAccount opgeven. .

Name	Type	Description
JobStorageAccount	string
SystemAccount	string

CsvSerialization

Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in CSV-indeling worden geschreven.

Name	Type	Description
properties.encoding	Encoding	Hiermee geeft u de codering van de binnenkomende gegevens in het geval van invoer en de codering van uitgaande gegevens in het geval van uitvoer. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.fieldDelimiter	string	Hiermee geeft u het scheidingsteken op dat wordt gebruikt om csv-records (door komma's gescheiden waarden) te scheiden. Zie https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input of https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output voor een lijst met ondersteunde waarden. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Csv	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

DiagnosticCondition

Voorwaarde die van toepassing is op de resource, of op de taak in het algemeen, die de aandacht van de klant rechtvaardigt.

Name	Type	Description
code	string	De ondoorzichtige diagnostische code.
message	string	Het voor mensen leesbare bericht waarin de voorwaarde in detail wordt beschreven. Gelokaliseerd in de Accept-Language van de clientaanvraag.
since	string	Het UTC-tijdstempel van wanneer de voorwaarde is gestart. Klanten moeten rond deze tijd een bijbehorende gebeurtenis kunnen vinden in het ops-logboek.

Diagnostics

Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.

Name	Type	Description
conditions	DiagnosticCondition[]	Een verzameling van nul of meer voorwaarden die van toepassing zijn op de resource of op de taak in het algemeen, die aandacht van de klant vereisen.

DocumentDbOutputDataSource

Beschrijft een DocumentDB-uitvoergegevensbron.

Name	Type	Description
properties.accountId	string	De documentDB-accountnaam of -id. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.accountKey	string	De accountsleutel voor het DocumentDB-account. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.collectionNamePattern	string	Het naampatroon van de verzameling voor de verzamelingen die moeten worden gebruikt. De naamindeling van de verzameling kan worden samengesteld met het optionele token {partition}, waarbij partities beginnen met 0. Zie de sectie DocumentDB van https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output voor meer informatie. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.database	string	De naam van de DocumentDB-database. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.documentId	string	De naam van het veld in uitvoerevenementen die worden gebruikt om de primaire sleutel op te geven waarop invoeg- of updatebewerkingen zijn gebaseerd.
properties.partitionKey	string	De naam van het veld in uitvoerevenementen die worden gebruikt om de sleutel op te geven voor het partitioneren van uitvoer tussen verzamelingen. Als 'collectionNamePattern' het token {partition} bevat, moet deze eigenschap worden opgegeven.
type	string: Microsoft.Storage/DocumentDB	Geeft aan naar welk type gegevensbronuitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

Encoding

Hiermee geeft u de codering van de binnenkomende gegevens in het geval van invoer en de codering van uitgaande gegevens in het geval van uitvoer.

Name	Type	Description
UTF8	string

Error

Veelvoorkomende foutweergave.

Name	Type	Description
error	Error	Eigenschappen van foutdefinitie.

EventHubOutputDataSource

Beschrijft een Event Hub-uitvoergegevensbron.

Name	Type	Standaardwaarde	Description
authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.eventHubName	string		De naam van de Event Hub. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.partitionKey	string		De sleutel/kolom die wordt gebruikt om te bepalen naar welke partitie gebeurtenisgegevens moeten worden verzonden.
properties.propertyColumns	string[]		De eigenschappen die zijn gekoppeld aan deze Event Hub-uitvoer.
serviceBusNamespace	string		De naamruimte die is gekoppeld aan de gewenste Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyKey	string		De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyName	string		De naam van het beleid voor gedeelde toegang voor de Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Geeft aan naar welk type gegevensbronuitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

EventHubStreamInputDataSource

Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.

Name	Type	Standaardwaarde	Description
authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.consumerGroupName	string		De naam van een Event Hub-consumentengroep die moet worden gebruikt om gebeurtenissen uit de Event Hub te lezen. Door afzonderlijke namen van consumentengroepen op te geven voor meerdere invoergegevens, kan elk van deze invoer dezelfde gebeurtenissen ontvangen van de Event Hub. Als dit niet is opgegeven, wordt voor de invoer de standaardconsumenergroep van de Event Hub gebruikt.
properties.eventHubName	string		De naam van de Event Hub. Vereist voor PUT-aanvragen (CreateOrReplace).
serviceBusNamespace	string		De naamruimte die is gekoppeld aan de gewenste Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyKey	string		De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyName	string		De naam van het beleid voor gedeelde toegang voor de Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

EventHubV2OutputDataSource

Beschrijft een Event Hub-uitvoergegevensbron.

Name	Type	Standaardwaarde	Description
authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.eventHubName	string		De naam van de Event Hub. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.partitionKey	string		De sleutel/kolom die wordt gebruikt om te bepalen naar welke partitie gebeurtenisgegevens moeten worden verzonden.
properties.propertyColumns	string[]		De eigenschappen die zijn gekoppeld aan deze Event Hub-uitvoer.
serviceBusNamespace	string		De naamruimte die is gekoppeld aan de gewenste Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyKey	string		De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyName	string		De naam van het beleid voor gedeelde toegang voor de Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Geeft aan naar welk type gegevensbronuitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

EventHubV2StreamInputDataSource

Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.

Name	Type	Standaardwaarde	Description
authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.consumerGroupName	string		De naam van een Event Hub-consumentengroep die moet worden gebruikt om gebeurtenissen uit de Event Hub te lezen. Door afzonderlijke namen van consumentengroepen op te geven voor meerdere invoergegevens, kan elk van deze invoer dezelfde gebeurtenissen ontvangen van de Event Hub. Als dit niet is opgegeven, wordt voor de invoer de standaardconsumenergroep van de Event Hub gebruikt.
properties.eventHubName	string		De naam van de Event Hub. Vereist voor PUT-aanvragen (CreateOrReplace).
serviceBusNamespace	string		De naamruimte die is gekoppeld aan de gewenste Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyKey	string		De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyName	string		De naam van het beleid voor gedeelde toegang voor de Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

EventSerializationType

Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

Name	Type	Description
Avro	string
Csv	string
Json	string
Parquet	string

EventsOutOfOrderPolicy

Geeft het beleid aan dat moet worden toegepast op gebeurtenissen die niet op volgorde binnenkomen in de invoer gebeurtenisstroom.

Name	Type	Description
Adjust	string
Drop	string

FileReferenceInputDataSource

Beschrijft een bestandsinvoergegevensbron die referentiegegevens bevat.

Name	Type	Description
properties.path	string	Het pad van het bestand.
type	string: File	Geeft het type invoergegevensbron met referentiegegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

Function

Een functieobject, met alle informatie die is gekoppeld aan de benoemde functie. Alle functies bevinden zich onder een streamingtaak.

Name	Type	Description
id	string	Resource-id
name	string	Resourcenaam
properties	FunctionProperties: AggregateFunctionProperties ScalarFunctionProperties	De eigenschappen die zijn gekoppeld aan een functie.
type	string	Resourcetype

FunctionInput

Beschrijft één invoerparameter van een functie.

Name	Type	Description
dataType	string	Het gegevenstype (ondersteund door Azure Stream Analytics) van de functie-invoerparameter. Een lijst met geldige Azure Stream Analytics-gegevenstypen wordt beschreven op https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	Een vlag die aangeeft of de parameter een configuratieparameter is. Waar als deze invoerparameter naar verwachting een constante is. De standaardinstelling is onwaar.

FunctionOutput

Beschrijft de uitvoer van een functie.

Name	Type	Description
dataType	string	Het gegevenstype (ondersteund door Azure Stream Analytics) van de functie-uitvoer. Een lijst met geldige Azure Stream Analytics-gegevenstypen wordt beschreven op https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

Beschrijft een gateway message bus-uitvoergegevensbron.

Name	Type	Description
properties.topic	string	De naam van het Service Bus-onderwerp.
type	string: GatewayMessageBus	Geeft aan naar welk type uitvoer van de gegevensbron wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.

Name	Type	Description
properties.topic	string	De naam van het Service Bus-onderwerp.
type	string: GatewayMessageBus	Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

Identity

Beschrijft hoe identiteit wordt geverifieerd

Name	Type	Description
principalId	string	De id van de identiteitsprincipal
tenantId	string	De tenantId van de identiteit
type	string	Het identiteitstype

Input

Een invoerobject, met alle informatie die is gekoppeld aan de benoemde invoer. Alle invoer bevindt zich onder een streamingtaak.

Name	Type	Description
id	string	Resource-id
name	string	Resourcenaam
properties	InputProperties: ReferenceInputProperties StreamInputProperties	De eigenschappen die zijn gekoppeld aan een invoer. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string	Resourcetype

IoTHubStreamInputDataSource

Beschrijft een IoT Hub invoergegevensbron die stroomgegevens bevat.

Name	Type	Description
properties.consumerGroupName	string	De naam van een IoT Hub consumentengroep die moet worden gebruikt om gebeurtenissen uit de IoT Hub te lezen. Als dit niet is opgegeven, gebruikt de invoer de standaardconsumenergroep van de IoT Hub.
properties.endpoint	string	De IoT Hub eindpunt om verbinding mee te maken (bijvoorbeeld berichten/gebeurtenissen, berichten/bewerkingenMonitoringEvents, enzovoort).
properties.iotHubNamespace	string	De naam of de URI van de IoT Hub. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.sharedAccessPolicyKey	string	De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.sharedAccessPolicyName	string	De naam van het beleid voor gedeelde toegang voor de IoT Hub. Dit beleid moet ten minste de machtiging Service connect bevatten. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

JavaScriptFunctionBinding

De binding met een JavaScript-functie.

Name	Type	Description
properties.script	string	De JavaScript-code met één functiedefinitie. Bijvoorbeeld: 'functie (x, y) { return x + y; }'
type	string: Microsoft.StreamAnalytics/JavascriptUdf	Geeft het type functiebinding aan.

JobStorageAccount

De eigenschappen die zijn gekoppeld aan een Azure Storage-account met MSI

Name	Type	Standaardwaarde	Description
accountKey	string		De accountsleutel voor het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace).
accountName	string		De naam van het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace).
authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.

JobType

Beschrijft het type taak. Geldige modi zijn Cloud en 'Edge'.

Name	Type	Description
Cloud	string
Edge	string

JsonOutputSerializationFormat

Hiermee geeft u de indeling van de JSON waarin de uitvoer wordt geschreven. De momenteel ondersteunde waarden zijn 'lineSeparated' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt door elk JSON-object te laten scheiden door een nieuwe regel en 'matrix' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt als een matrix van JSON-objecten.

Name	Type	Description
Array	string
LineSeparated	string

JsonSerialization

Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in JSON-indeling worden geschreven.

Name	Type	Description
properties.encoding	Encoding	Hiermee geeft u de codering van de binnenkomende gegevens in het geval van invoer en de codering van uitgaande gegevens in het geval van uitvoer. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Deze eigenschap is alleen van toepassing op JSON-serialisatie van uitvoer. Deze is niet van toepassing op invoer. Deze eigenschap geeft de indeling op van de JSON waarin de uitvoer wordt geschreven. De momenteel ondersteunde waarden zijn 'lineSeparated' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt door elk JSON-object te laten scheiden door een nieuwe regel en 'matrix' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt als een matrix van JSON-objecten. De standaardwaarde is 'lineSeparated' als deze waarde null blijft.
type	string: Json	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

Output

Een uitvoerobject, met alle informatie die is gekoppeld aan de benoemde uitvoer. Alle uitvoer bevindt zich onder een streamingtaak.

Name	Type	Description
id	string	Resource-id
name	string	Resourcenaam
properties.datasource	OutputDataSource: AzureDataLakeStoreOutputDataSource AzureFunctionOutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource AzureTableOutputDataSource BlobOutputDataSource DocumentDbOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource GatewayMessageBusOutputDataSource PowerBIOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource	Beschrijft de gegevensbron waarnaar uitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.diagnostics	Diagnostics	Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.
properties.etag	string	De huidige entiteitstag voor de uitvoer. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource tussen aanvragen is gewijzigd. U kunt deze ook gebruiken in de headers If-Match of If-None-Match voor schrijfbewerkingen voor optimistische gelijktijdigheid.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer worden geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.sizeWindow	integer	Het groottevenster om een Stream Analytics-uitvoer te beperken tot.
properties.timeWindow	string	Het tijdsbestek voor het filteren van uitvoer van Stream Analytics-taken.
type	string	Resourcetype

OutputErrorPolicy

Geeft het beleid aan dat moet worden toegepast op gebeurtenissen die bij de uitvoer binnenkomen en niet naar de externe opslag kunnen worden geschreven vanwege een onjuiste indeling (ontbrekende kolomwaarden, kolomwaarden van een onjuist type of een verkeerde grootte).

Name	Type	Description
Drop	string
Stop	string

OutputStartMode

De waarde kan JobStartTime, CustomTime of LastOutputEventTime zijn om aan te geven of het beginpunt van de uitvoer gebeurtenisstroom moet starten wanneer de taak wordt gestart, moet beginnen met een aangepaste gebruikerstijdstempel die is opgegeven via de eigenschap outputStartTime of moet beginnen vanaf de laatste uitvoertijd van de gebeurtenis.

Name	Type	Description
CustomTime	string
JobStartTime	string
LastOutputEventTime	string

ParquetSerialization

Hierin wordt beschreven hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in Parquet-indeling worden geschreven.

Name	Type	Description
type	string: Parquet	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

PowerBIOutputDataSource

Beschrijft een Power BI-uitvoergegevensbron.

Name	Type	Standaardwaarde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.dataset	string		De naam van de Power BI-gegevensset. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.groupId	string		De id van de Power BI-groep.
properties.groupName	string		De naam van de Power BI-groep. Gebruik deze eigenschap om te onthouden welke specifieke Power BI-groeps-id is gebruikt.
properties.refreshToken	string		Een vernieuwingstoken dat kan worden gebruikt om een geldig toegangstoken te verkrijgen dat vervolgens kan worden gebruikt voor verificatie bij de gegevensbron. Een geldig vernieuwingstoken is momenteel alleen verkrijgbaar via Azure Portal. Het wordt aanbevolen om hier een waarde voor een dummytekenreeks te plaatsen wanneer u de gegevensbron maakt en vervolgens naar de Azure-portal gaat om de gegevensbron te verifiëren die deze eigenschap bijwerkt met een geldig vernieuwingstoken. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.table	string		De naam van de Power BI-tabel onder de opgegeven gegevensset. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.tokenUserDisplayName	string		De weergavenaam van de gebruiker die is gebruikt om het vernieuwingstoken te verkrijgen. Gebruik deze eigenschap om te onthouden welke gebruiker is gebruikt om het vernieuwingstoken te verkrijgen.
properties.tokenUserPrincipalName	string		De USER Principal Name (UPN) van de gebruiker die is gebruikt om het vernieuwingstoken te verkrijgen. Gebruik deze eigenschap om te onthouden welke gebruiker is gebruikt om het vernieuwingstoken te verkrijgen.
type	string: PowerBI		Geeft aan naar welk type uitvoer van de gegevensbron wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

ReferenceInputProperties

De eigenschappen die zijn gekoppeld aan een invoer die referentiegegevens bevat.

Name	Type	Description
compression	Compression	Beschrijft hoe invoergegevens worden gecomprimeerd
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Beschrijft een invoergegevensbron die referentiegegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).
diagnostics	Diagnostics	Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.
etag	string	De huidige entiteitstag voor de invoer. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource tussen aanvragen is gewijzigd. U kunt deze ook gebruiken in de If-Match- of If-None-Match-headers voor schrijfbewerkingen voor optimistische gelijktijdigheid.
partitionKey	string	partitionKey beschrijft een sleutel in de invoergegevens die wordt gebruikt voor het partitioneren van de invoergegevens
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer worden geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Reference	Geeft aan of de invoer een bron van referentiegegevens of stroomgegevens is. Vereist voor PUT-aanvragen (CreateOrReplace).

RefreshType

Hiermee wordt het type optie voor het vernieuwen van gegevens aangegeven.

Name	Type	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

ScalarFunctionProperties

De eigenschappen die zijn gekoppeld aan een scalaire functie.

Name	Type	Description
etag	string	De huidige entiteitstag voor de functie. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource tussen aanvragen is gewijzigd. U kunt deze ook gebruiken in de headers If-Match of If-None-Match voor schrijfbewerkingen voor optimistische gelijktijdigheid.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	De fysieke binding van de functie. In het geval van de Azure Machine Learning-webservice beschrijft dit bijvoorbeeld het eindpunt.
properties.inputs	FunctionInput[]	Beschrijft één invoerparameter van een functie.
properties.output	FunctionOutput	Beschrijft de uitvoer van een functie.
type	string: Scalar	Geeft het type functie aan.

ServiceBusQueueOutputDataSource

Beschrijft een Service Bus Queue-uitvoergegevensbron.

Name	Type	Standaardwaarde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.propertyColumns	string[]		Een tekenreeksmatrix van de namen van uitvoerkolommen die als aangepaste eigenschappen aan Service Bus-berichten moeten worden gekoppeld.
properties.queueName	string		De naam van de Service Bus-wachtrij. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.serviceBusNamespace	string		De naamruimte die is gekoppeld aan de gewenste Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.sharedAccessPolicyKey	string		De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.sharedAccessPolicyName	string		De naam van het beleid voor gedeelde toegang voor de Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.systemPropertyColumns	object		De systeemeigenschappen die zijn gekoppeld aan de Service Bus-wachtrij. De volgende systeemeigenschappen worden ondersteund: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
type	string: Microsoft.ServiceBus/Queue		Geeft aan naar welk type gegevensbronuitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

ServiceBusTopicOutputDataSource

Beschrijft een gegevensbron voor de uitvoer van een Service Bus-onderwerp.

Name	Type	Standaardwaarde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.propertyColumns	string[]		Een tekenreeksmatrix van de namen van uitvoerkolommen die als aangepaste eigenschappen aan Service Bus-berichten moeten worden gekoppeld.
properties.serviceBusNamespace	string		De naamruimte die is gekoppeld aan de gewenste Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.sharedAccessPolicyKey	string		De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.sharedAccessPolicyName	string		De naam van het beleid voor gedeelde toegang voor de Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.systemPropertyColumns	object		De systeemeigenschappen die zijn gekoppeld aan de uitvoer van het Service Bus-onderwerp. De volgende systeemeigenschappen worden ondersteund: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
properties.topicName	string		De naam van het Service Bus-onderwerp. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.ServiceBus/Topic		Geeft aan naar welk type gegevensbronuitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

Sku

De eigenschappen die zijn gekoppeld aan een SKU.

Name	Type	Description
name	SkuName	De naam van de SKU. Vereist voor PUT-aanvragen (CreateOrReplace).

SkuName

De naam van de SKU. Vereist voor PUT-aanvragen (CreateOrReplace).

Name	Type	Description
Standard	string

StorageAccount

De eigenschappen die zijn gekoppeld aan een Azure Storage-account

Name	Type	Description
accountKey	string	De accountsleutel voor het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace).
accountName	string	De naam van het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace).

StreamingJob

Een streamingtaakobject, met alle informatie die is gekoppeld aan de benoemde streamingtaak.

Name	Type	Description
id	string	Volledig gekwalificeerde resource-id voor de resource. Bijvoorbeeld - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Beschrijft de door het systeem toegewezen beheerde identiteit die aan deze taak is toegewezen en die kan worden gebruikt voor verificatie met invoer en uitvoer.
location	string	De geografische locatie waar de resource zich bevindt
name	string	De naam van de resource
properties.cluster	ClusterInfo	Het cluster waarop streamingtaken worden uitgevoerd.
properties.compatibilityLevel	CompatibilityLevel	Bepaalt bepaald runtimegedrag van de streamingtaak.
properties.contentStoragePolicy	ContentStoragePolicy	Geldige waarden zijn JobStorageAccount en SystemAccount. Als deze optie is ingesteld op JobStorageAccount, moet de gebruiker ook de eigenschap jobStorageAccount opgeven. .
properties.createdDate	string	Waarde is een UTC-tijdstempel met ISO-8601-indeling die aangeeft wanneer de streamingtaak is gemaakt.
properties.dataLocale	string	De landinstelling van de gegevens van de Stream Analytics-taak. Waarde moet de naam zijn van een ondersteunde .NET-cultuur uit de set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Standaard ingesteld op 'en-US' als er geen is opgegeven.
properties.etag	string	De huidige entiteitstag voor de streamingtaak. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource tussen aanvragen is gewijzigd. U kunt deze ook gebruiken in de If-Match- of If-None-Match-headers voor schrijfbewerkingen voor optimistische gelijktijdigheid.
properties.eventsLateArrivalMaxDelayInSeconds	integer	De maximaal toegestane vertraging in seconden waarbij gebeurtenissen te laat aankomen, kunnen worden opgenomen. Het ondersteunde bereik is -1 tot 1814399 (20.23:59:59 dagen) en -1 wordt gebruikt om voor onbepaalde tijd wachten op te geven. Als de eigenschap afwezig is, wordt deze geïnterpreteerd als een waarde van -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	De maximaal toegestane vertraging in seconden waarbij gebeurtenissen die niet op volgorde zijn, kunnen worden aangepast om weer in orde te zijn.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Hiermee wordt het beleid aangegeven dat moet worden toegepast op gebeurtenissen die niet op volgorde binnenkomen in de invoer gebeurtenisstroom.
properties.functions	Function[]	Een lijst met een of meer functies voor de streamingtaak. De naameigenschap voor elke functie is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke transformatie.
properties.inputs	Input[]	Een lijst met een of meer invoergegevens voor de streamingtaak. De naameigenschap voor elke invoer is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke invoer.
properties.jobId	string	Een GUID die de streamingtaak uniek identificeert. Deze GUID wordt gegenereerd bij het maken van de streamingtaak.
properties.jobState	string	Beschrijft de status van de streamingtaak.
properties.jobStorageAccount	JobStorageAccount	De eigenschappen die zijn gekoppeld aan een Azure Storage-account met MSI
properties.jobType	JobType	Beschrijft het type taak. Geldige modi zijn Cloud en 'Edge'.
properties.lastOutputEventTime	string	Waarde is een tijdstempel met ISO-8601-indeling die de laatste uitvoergebeurtenistijd van de streamingtaak aangeeft of null die aangeeft dat de uitvoer nog niet is geproduceerd. In het geval van meerdere uitvoer of meerdere streams, wordt de meest recente waarde in die set weergegeven.
properties.outputErrorPolicy	OutputErrorPolicy	Hiermee wordt het beleid aangegeven dat moet worden toegepast op gebeurtenissen die bij de uitvoer binnenkomen en niet naar de externe opslag kunnen worden geschreven vanwege een onjuiste indeling (ontbrekende kolomwaarden, kolomwaarden van het verkeerde type of de verkeerde grootte).
properties.outputStartMode	OutputStartMode	Deze eigenschap mag alleen worden gebruikt wanneer het gewenst is dat de taak onmiddellijk na het maken wordt gestart. De waarde kan JobStartTime, CustomTime of LastOutputEventTime zijn om aan te geven of het beginpunt van de uitvoergebeurtenisstroom moet beginnen wanneer de taak wordt gestart, moet beginnen met een aangepaste gebruikerstijdstempel die is opgegeven via de eigenschap outputStartTime of moet beginnen vanaf de laatste uitvoertijd van de gebeurtenis.
properties.outputStartTime	string	Waarde is een volgens ISO-8601 opgemaakte tijdstempel die het beginpunt van de uitvoergebeurtenisstroom aangeeft, of null om aan te geven dat de uitvoergebeurtenisstroom wordt gestart wanneer de streamingtaak wordt gestart. Deze eigenschap moet een waarde hebben als outputStartMode is ingesteld op CustomTime.
properties.outputs	Output[]	Een lijst met een of meer uitvoer voor de streamingtaak. De naameigenschap voor elke uitvoer is vereist wanneer u deze eigenschap opgeeft in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke uitvoer.
properties.provisioningState	string	Beschrijft de inrichtingsstatus van de streamingtaak.
properties.sku	Sku	Beschrijft de SKU van de streamingtaak. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.transformation	Transformation	Geeft de query en het aantal streaming-eenheden aan dat moet worden gebruikt voor de streamingtaak. De naameigenschap van de transformatie is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke transformatie.
tags	object	Resourcetags.
type	string	Het type resource. Bijvoorbeeld Microsoft.Compute/virtualMachines of Microsoft.Storage/storageAccounts.

StreamInputProperties

De eigenschappen die zijn gekoppeld aan een invoer die stroomgegevens bevat.

Name	Type	Description
compression	Compression	Beschrijft hoe invoergegevens worden gecomprimeerd
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Beschrijft een invoergegevensbron die stroomgegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).
diagnostics	Diagnostics	Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.
etag	string	De huidige entiteitstag voor de invoer. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource tussen aanvragen is gewijzigd. U kunt deze ook gebruiken in de If-Match- of If-None-Match-headers voor schrijfbewerkingen voor optimistische gelijktijdigheid.
partitionKey	string	partitionKey beschrijft een sleutel in de invoergegevens die wordt gebruikt voor het partitioneren van de invoergegevens
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer worden geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Stream	Geeft aan of de invoer een bron van referentiegegevens of stroomgegevens is. Vereist voor PUT-aanvragen (CreateOrReplace).

Transformation

Een transformatieobject, met alle informatie die is gekoppeld aan de benoemde transformatie. Alle transformaties bevinden zich onder een streamingtaak.

Name	Type	Standaardwaarde	Description
id	string		Resource-id
name	string		Resourcenaam
properties.etag	string		De huidige entiteitstag voor de transformatie. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource tussen aanvragen is gewijzigd. U kunt deze ook gebruiken in de headers If-Match of If-None-Match voor schrijfbewerkingen voor optimistische gelijktijdigheid.
properties.query	string		Hiermee geeft u de query op die wordt uitgevoerd in de streamingtaak. Meer informatie over de Stream Analytics Query Language (SAQL) vindt u hier: https://msdn.microsoft.com/library/azure/dn834998 . Vereist voor PUT-aanvragen (CreateOrReplace).
properties.streamingUnits	integer	3	Hiermee geeft u het aantal streaming-eenheden op dat door de streamingtaak wordt gebruikt.
properties.validStreamingUnits	integer[]		Hiermee geeft u de geldige streaming-eenheden op waarmee een streamingtaak kan worden geschaald.
type	string		Resourcetype