Streaming Jobs - Create Or Replace

Referentie

Service:: Stream Analytics

API-versie:: 2020-03-01

Hiermee maakt u een streamingtaak of vervangt u een al 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 minLength: 1 maxLength: 90 pattern: ^[-\w\._]+$	De naam van de resourcegroep. De naam is niet hoofdlettergevoelig.
subscriptionId	path	True	string minLength: 1	De id van het doelabonnement.
api-version	query	True	string minLength: 1	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 de huidige recordset altijd te overschrijven. Geef de laatst geziene ETag-waarde op om te voorkomen dat gelijktijdige wijzigingen per ongeluk worden overschreven.
If-None-Match		string	Stel deze optie in op *, zodat een nieuwe streamingtaak kan worden gemaakt, maar om te voorkomen dat een bestaande recordset wordt bijgewerkt. Andere waarden resulteren in een reactie van 412 Pre-condition Failed.

Aanvraagbody

Name	Type	Description
identity	Identity	Beschrijft de door het systeem toegewezen beheerde identiteit die aan deze taak is toegewezen, 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 bepaalde 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.dataLocale	string	De landinstellingen 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 (int32)	De maximaal toelaatbare vertraging in seconden waarin gebeurtenissen die te laat aankomen, kunnen worden opgenomen. Het ondersteunde bereik wordt -1 tot 1814399 (20.23:59:59 dagen) en -1 wordt gebruikt om voor onbepaalde tijd te wachten. Als de eigenschap afwezig is, wordt deze geïnterpreteerd als een waarde van -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer (int32)	De maximaal toelaatbare vertraging in seconden waarbij out-of-ordergebeurtenissen kunnen worden aangepast om weer in volgorde te zijn.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Hiermee wordt het beleid aangegeven dat moet worden toegepast op gebeurtenissen die niet in de volgorde van de invoer gebeurtenisstroom aankomen.
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	Geeft het beleid aan dat moet worden toegepast op gebeurtenissen die binnenkomen bij de uitvoer en niet naar de externe opslag kunnen worden geschreven vanwege een onjuiste indeling (ontbrekende kolomwaarden, kolomwaarden van onjuist type of grootte).
properties.outputStartMode	OutputStartMode	Deze eigenschap mag alleen worden gebruikt wanneer u wilt dat de taak onmiddellijk na het maken wordt gestart. Waarde kan JobStartTime, CustomTime of LastOutputEventTime zijn om aan te geven of het beginpunt van de uitvoergebeurtenisstroom moet worden gestart wanneer de taak wordt gestart, beginnen bij een aangepast gebruikerstijdstempel dat is opgegeven via de eigenschap outputStartTime of beginnen vanaf de laatste uitvoertijd van de gebeurtenis.
properties.outputStartTime	string (date-time)	Waarde is een iso-8601-geformatteerde 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 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 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. Kopteksten ETag: string
201 Created	StreamingJob	De streamingtaak is gemaakt of vervangen. Kopteksten ETag: string
Other Status Codes	Error	Fout.

Name

Type

Description

200 OK

StreamingJob

De streamingtaak is gemaakt of vervangen.

Kopteksten

ETag: string

201 Created

StreamingJob

De streamingtaak is gemaakt of vervangen.

Kopteksten

ETag: string

Other Status Codes

Error

Fout.

Beveiliging

azure_auth

Azure Active Directory OAuth2-stroom

Type: oauth2
Stroom: implicit
Autorisatie-URL: https://login.microsoftonline.com/common/oauth2/authorize

Bereiken

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)

Voorbeeldaanvraag

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


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", "fakeTokenPlaceholder", "key3", "fakeTokenPlaceholder", "randomKey",
                "fakeTokenPlaceholder"))
            .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("fakeTokenPlaceholder")))
                    .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().withServer("serverName").withDatabase("databaseName")
                    .withUser("<user>").withPassword("fakeTokenPlaceholder").withTable("tableName"))))
            .withFunctions(Arrays.asList()).create();
    }

    // Use "Map.of" if available
    @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

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

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

Voorbeeldrespons

Statuscode:: 201

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

{
  "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"
        }
      }
    ]
  }
}

Statuscode:: 200

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

{
  "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)

Voorbeeldaanvraag

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


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", "fakeTokenPlaceholder", "key3", "fakeTokenPlaceholder", "randomKey",
                "fakeTokenPlaceholder"))
            .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();
    }

    // Use "Map.of" if available
    @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

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

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

Voorbeeldrespons

Statuscode:: 201

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

{
  "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": []
  }
}

Statuscode:: 200

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

{
  "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 Azure Machine Learning-webservice-eindpunt.
AzureMachineLearningWebServiceOutputColumn	Beschrijft een uitvoerkolom voor het Azure Machine Learning-webservice-eindpunt.
AzureSqlDatabaseOutputDataSource	Beschrijft een Azure SQL-database-uitvoergegevensbron.
AzureSqlReferenceInputDataSource	Beschrijft een Azure SQL-databasereferentiegegevensbron voor invoergegevens.
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 bepaalde 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 de aandacht van de klant rechtvaardigen.
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	Hiermee wordt het beleid aangegeven dat moet worden toegepast op gebeurtenissen die niet in de volgorde van de invoer gebeurtenisstroom aankomen.
FileReferenceInputDataSource	Beschrijft een gegevensbron voor bestandsinvoer 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 invoergegevens bevinden 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 op waarin de uitvoer wordt geschreven. De momenteel ondersteunde waarden zijn 'lineSeparated' die aangeeft dat de uitvoer wordt opgemaakt door elk JSON-object gescheiden door een nieuwe regel en 'matrix' die aangeeft 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 wordt opgenomen in een streamingtaak.
OutputErrorPolicy	Geeft het beleid aan dat moet worden toegepast op gebeurtenissen die binnenkomen bij de uitvoer en niet naar de externe opslag kunnen worden geschreven vanwege een onjuiste indeling (ontbrekende kolomwaarden, kolomwaarden van onjuist type of grootte).
OutputStartMode	Waarde kan JobStartTime, CustomTime of LastOutputEventTime zijn om aan te geven of het beginpunt van de uitvoergebeurtenisstroom moet worden gestart wanneer de taak wordt gestart, beginnen bij een aangepast gebruikerstijdstempel dat is opgegeven via de eigenschap outputStartTime of beginnen vanaf de laatste uitvoertijd van de gebeurtenis.
ParquetSerialization	Beschrijft 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	Geeft het type gegevensvernieuwingsoptie aan.
ScalarFunctionProperties	De eigenschappen die zijn gekoppeld aan een scalaire functie.
ServiceBusQueueOutputDataSource	Beschrijft een gegevensbron voor uitvoer van een Service Bus-wachtrij.
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

Object

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 is gewijzigd tussen aanvragen. U kunt deze ook gebruiken in de If-Match of If-None-Match headers 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 wordt bijvoorbeeld het eindpunt beschreven.
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

Inventarisatie

Verificatiemodus. Geldige modi zijn ConnectionString, Msi en UserToken.

Waarde	Description
ConnectionString
Msi
UserToken

AvroSerialization

Object

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

Object

Beschrijft een Azure Data Lake Store-uitvoergegevensbron.

Name	Type	Default value	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. Waar {date} ook wordt weergegeven in filePathPrefix, wordt de waarde van deze eigenschap gebruikt als 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 om te verifiëren bij de gegevensbron. Een geldig vernieuwingstoken kan momenteel alleen worden verkregen via Azure Portal. Het is raadzaam om hier een dummytekenreekswaarde te plaatsen bij het maken van de gegevensbron en vervolgens naar Azure Portal te gaan 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. Waar {time} ook 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 UPN (User Principal Name) 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 dat het type uitvoer van de gegevensbron naar wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureFunctionOutputDataSource

Object

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 kunt opgeven in elke batch die 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 bevindt zich in bytes. Deze waarde is standaard 262.144 bytes (256 kB).
type	string: Microsoft.AzureFunction	Geeft aan dat het type uitvoer van de gegevensbron naar wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

Object

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 (int32)	Getal tussen 1 en 10000 met een beschrijving van het maximum aantal rijen voor elke Azure ML RRS-aanvraag. De standaardwaarde is 1000.
properties.endpoint	string	Het Request-Response eindpunt van de Azure Machine Learning-webservice uitvoeren. Meer informatie 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 Azure Machine Learning-webservice-eindpunt.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Een lijst met uitvoer van het eindpunt van de Azure Machine Learning-webservice.
type	string: Microsoft.MachineLearning/WebService	Geeft het bindingstype van de functie aan.

AzureMachineLearningWebServiceInputColumn

Object

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 in https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx.
mapTo	integer (int32)	De op nul gebaseerde index van de functieparameter waaraan deze invoer is toegewezen.
name	string	De naam van de invoerkolom.

AzureMachineLearningWebServiceInputs

Object

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

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

AzureMachineLearningWebServiceOutputColumn

Object

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 in https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx.
name	string	De naam van de uitvoerkolom.

AzureSqlDatabaseOutputDataSource

Object

Beschrijft een Azure SQL-database-uitvoergegevensbron.

Name	Type	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.database	string		De naam van de Azure SQL-database. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.maxBatchCount	number		Maximumaantal Batch's voor schrijven naar Sql-database, de standaardwaarde is 10.000. Optioneel voor PUT-aanvragen.
properties.maxWriterCount	number		Maximaal aantal schrijvers, momenteel zijn er slechts 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 die de Azure SQL-database bevat. 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 dat het type uitvoer van de gegevensbron naar wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureSqlReferenceInputDataSource

Object

Beschrijft een Azure SQL-databasereferentiegegevensbron voor invoergegevens.

Name	Type	Description
properties.database	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is de naam van de database waarnaar de 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. Dit geeft aan hoe vaak de gegevens worden opgehaald uit de database. Het is een datum/tijd-indeling.
properties.refreshType	RefreshType	Geeft het type gegevensvernieuwingsoptie aan.
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 aan dat referentiegegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureSynapseOutputDataSource

Object

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 die de Azure SQL-database bevat. 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 dat het type uitvoer van de gegevensbron naar wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureTableOutputDataSource

Object

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 (int32)	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 de 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 dat het type uitvoer van de gegevensbron naar wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

BlobOutputDataSource

Object

Beschrijft een blob-uitvoergegevensbron.

Name	Type	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.blobPathPrefix	string		Het voorvoegsel van het blobpad.
properties.container	string		De naam van een container binnen het gekoppelde opslagaccount. Deze container bevat de blob(s) waaruit moet worden gelezen of naar geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.dateFormat	string		De datumnotatie. Waar {date} ook wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de datumnotatie.
properties.pathPattern	string		Het padpatroon van de blob. Geen reguliere expressie. Het vertegenwoordigt een patroon waarmee blobnamen worden vergeleken om te bepalen of ze al dan niet als invoer of uitvoer voor de taak moeten worden opgenomen. 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 gedetailleerdere 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. Waar {time} ook wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de tijdnotatie.
type	string: Microsoft.Storage/Blob		Geeft aan dat het type uitvoer van de gegevensbron naar wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

BlobReferenceInputDataSource

Object

Beschrijft een blob-invoergegevensbron die referentiegegevens bevat.

Name	Type	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.container	string		De naam van een container binnen het gekoppelde opslagaccount. Deze container bevat de blob(s) waaruit moet worden gelezen of naar geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.dateFormat	string		De datumnotatie. Waar {date} ook wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de datumnotatie.
properties.pathPattern	string		Het padpatroon van de blob. Geen reguliere expressie. Het vertegenwoordigt een patroon waarmee blobnamen worden vergeleken om te bepalen of ze al dan niet als invoer of uitvoer voor de taak moeten worden opgenomen. 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 gedetailleerdere 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. Waar {time} ook wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de tijdnotatie.
type	string: Microsoft.Storage/Blob		Geeft het type invoergegevensbron aan dat referentiegegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).

BlobStreamInputDataSource

Object

Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.

Name	Type	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.container	string		De naam van een container binnen het gekoppelde opslagaccount. Deze container bevat de blob(s) waaruit moet worden gelezen of naar geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.dateFormat	string		De datumnotatie. Waar {date} ook wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de datumnotatie.
properties.pathPattern	string		Het padpatroon van de blob. Geen reguliere expressie. Het vertegenwoordigt een patroon waarmee blobnamen worden vergeleken om te bepalen of ze al dan niet als invoer of uitvoer voor de taak moeten worden opgenomen. 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 gedetailleerdere uitleg en voorbeeld.
properties.sourcePartitionCount	integer (int32)		Het aantal partities van de gegevensbron voor de blob-invoer. 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. Waar {time} ook wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de tijdnotatie.
type	string: Microsoft.Storage/Blob		Geeft het type invoergegevensbron aan dat stroomgegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).

ClusterInfo

Object

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

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

CompatibilityLevel

Inventarisatie

Bepaalt bepaalde runtimegedrag van de streamingtaak.

Waarde	Description
1.0
1.2

Compression

Object

Beschrijft hoe invoergegevens worden gecomprimeerd

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

CompressionType

Inventarisatie

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

Waarde	Description
Deflate
GZip
None

ContentStoragePolicy

Inventarisatie

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

Waarde	Description
JobStorageAccount
SystemAccount

CsvSerialization

Object

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 voor het scheiden van csv-records (door komma's gescheiden waarden). 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

Object

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 door mensen leesbare bericht met een gedetailleerde beschrijving van de voorwaarde. Gelokaliseerd in de Accept-Language van de clientaanvraag.
since	string	De UTC-tijdstempel van het moment waarop de voorwaarde is gestart. Klanten moeten een bijbehorende gebeurtenis kunnen vinden in het ops-logboek rond deze tijd.

Diagnostics

Object

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

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 de aandacht van de klant rechtvaardigen.

DocumentDbOutputDataSource

Object

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 patroon van de verzamelingsnaam voor de verzamelingen die moeten worden gebruikt. De indeling van de verzamelingsnaam kan worden samengesteld met behulp van het optionele {partition}-token, waarbij partities beginnen vanaf 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 uitvoer gebeurtenissen die worden gebruikt om de primaire sleutel op te geven waarop bewerkingen voor invoegen of bijwerken zijn gebaseerd.
properties.partitionKey	string	De naam van het veld in uitvoer gebeurtenissen die worden gebruikt om de sleutel op te geven voor het partitioneren van uitvoer in verzamelingen. Als collectionNamePattern het token {partition} bevat, moet deze eigenschap worden opgegeven.
type	string: Microsoft.Storage/DocumentDB	Geeft aan dat het type uitvoer van de gegevensbron naar wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

Encoding

Inventarisatie

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.

Waarde	Description
UTF8

Error

Object

Veelvoorkomende foutweergave.

Name	Type	Description
error	Error	Eigenschappen van foutdefinities.

EventHubOutputDataSource

Object

Beschrijft een Event Hub-uitvoergegevensbron.

Name	Type	Default value	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 aan 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 dat het type uitvoer van de gegevensbron naar wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

EventHubStreamInputDataSource

Object

Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.

Name	Type	Default value	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 voor meerdere invoer op te geven, kan elk van deze invoer dezelfde gebeurtenissen ontvangen van de Event Hub. Als deze niet is opgegeven, gebruikt de invoer de standaardconsumentgroep van De Event Hub.
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 aan dat stroomgegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).

EventHubV2OutputDataSource

Object

Beschrijft een Event Hub-uitvoergegevensbron.

Name	Type	Default value	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 aan 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 dat het type uitvoer van de gegevensbron naar wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

EventHubV2StreamInputDataSource

Object

Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.

Name	Type	Default value	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 voor meerdere invoer op te geven, kan elk van deze invoer dezelfde gebeurtenissen ontvangen van de Event Hub. Als deze niet is opgegeven, gebruikt de invoer de standaardconsumentgroep van De Event Hub.
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 aan dat stroomgegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).

EventSerializationType

Inventarisatie

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

Waarde	Description
Avro
Csv
Json
Parquet

EventsOutOfOrderPolicy

Inventarisatie

Hiermee wordt het beleid aangegeven dat moet worden toegepast op gebeurtenissen die niet in de volgorde van de invoer gebeurtenisstroom aankomen.

Waarde	Description
Adjust
Drop

FileReferenceInputDataSource

Object

Beschrijft een gegevensbron voor bestandsinvoer die referentiegegevens bevat.

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

Function

Object

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

FunctionInput

Object

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 in 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 standaardwaarde is onwaar.

FunctionOutput

Object

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 in https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

Object

Beschrijft een gateway message bus-uitvoergegevensbron.

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

GatewayMessageBusStreamInputDataSource

Object

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 aan dat stroomgegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).

Identity

Object

Beschrijft hoe identiteit wordt geverifieerd

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

Input

Object

Een invoerobject met alle informatie die is gekoppeld aan de benoemde invoer. Alle invoergegevens bevinden 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	Type hulpbron

IoTHubStreamInputDataSource

Object

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 standaardconsumentgroep van de IoT Hub.
properties.endpoint	string	Het IoT Hub-eindpunt waarmee verbinding moet worden gemaakt (bijvoorbeeld berichten/gebeurtenissen, berichten/operationsMonitoringEvents, 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 serviceverbinding bevatten. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Geeft het type invoergegevensbron aan dat stroomgegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).

JavaScriptFunctionBinding

Object

De binding met een JavaScript-functie.

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

JobStorageAccount

Object

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

Name	Type	Default value	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

Inventarisatie

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

Waarde	Description
Cloud
Edge

JsonOutputSerializationFormat

Inventarisatie

Hiermee geeft u de indeling van de JSON op waarin de uitvoer wordt geschreven. De momenteel ondersteunde waarden zijn 'lineSeparated' die aangeeft dat de uitvoer wordt opgemaakt door elk JSON-object gescheiden door een nieuwe regel en 'matrix' die aangeeft dat de uitvoer wordt opgemaakt als een matrix van JSON-objecten.

Waarde	Description
Array
LineSeparated

JsonSerialization

Object

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. Met deze eigenschap geeft u de indeling van de JSON op waarin de uitvoer wordt geschreven. De momenteel ondersteunde waarden zijn 'lineSeparated' die aangeeft dat de uitvoer wordt opgemaakt door elk JSON-object gescheiden door een nieuwe regel en 'matrix' die aangeeft dat de uitvoer wordt opgemaakt als een matrix van JSON-objecten. De standaardwaarde is 'lineSeparated' als u null links laat.
type	string: Json	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

Output

Object

Een uitvoerobject met alle informatie die is gekoppeld aan de benoemde uitvoer. Alle uitvoer wordt opgenomen in 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 de aandacht van de klant rechtvaardigen.
properties.etag	string	De huidige entiteitstag voor de uitvoer. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource is gewijzigd tussen aanvragen. U kunt deze ook gebruiken in de If-Match of If-None-Match headers 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 (int32)	Het venster Grootte om een Stream Analytics-uitvoer te beperken tot.
properties.timeWindow	string	Het tijdsbestek voor het filteren van Stream Analytics-taakuitvoer.
type	string	Type hulpbron

OutputErrorPolicy

Inventarisatie

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

Waarde	Description
Drop
Stop

OutputStartMode

Inventarisatie

Waarde kan JobStartTime, CustomTime of LastOutputEventTime zijn om aan te geven of het beginpunt van de uitvoergebeurtenisstroom moet worden gestart wanneer de taak wordt gestart, beginnen bij een aangepast gebruikerstijdstempel dat is opgegeven via de eigenschap outputStartTime of beginnen vanaf de laatste uitvoertijd van de gebeurtenis.

Waarde	Description
CustomTime
JobStartTime
LastOutputEventTime

ParquetSerialization

Object

Beschrijft 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

Object

Beschrijft een Power BI-uitvoergegevensbron.

Name	Type	Default value	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 om te verifiëren bij de gegevensbron. Een geldig vernieuwingstoken kan momenteel alleen worden verkregen via Azure Portal. Het is raadzaam om hier een dummytekenreekswaarde te plaatsen bij het maken van de gegevensbron en vervolgens naar Azure Portal te gaan 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 UPN (User Principal Name) 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 dat het type uitvoer van de gegevensbron naar wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

ReferenceInputProperties

Object

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 de aandacht van de klant rechtvaardigen.
etag	string	De huidige entiteitstag voor de invoer. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource is gewijzigd tussen aanvragen. 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 worden 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 is of gegevens streamt. Vereist voor PUT-aanvragen (CreateOrReplace).

RefreshType

Inventarisatie

Geeft het type gegevensvernieuwingsoptie aan.

Waarde	Description
RefreshPeriodicallyWithDelta
RefreshPeriodicallyWithFull
Static

ScalarFunctionProperties

Object

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 is gewijzigd tussen aanvragen. U kunt deze ook gebruiken in de If-Match of If-None-Match headers 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 wordt bijvoorbeeld het eindpunt beschreven.
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

Object

Beschrijft een gegevensbron voor uitvoer van een Service Bus-wachtrij.

Name	Type	Default value	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 dat het type uitvoer van de gegevensbron naar wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

ServiceBusTopicOutputDataSource

Object

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

Name	Type	Default value	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 Service Bus-onderwerpuitvoer. 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 dat het type uitvoer van de gegevensbron naar wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).

Sku

Object

De eigenschappen die zijn gekoppeld aan een SKU.

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

SkuName

Inventarisatie

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

Waarde	Description
Standard

StorageAccount

Object

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

Object

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

Name	Type	Description
id	string	Volledig gekwalificeerde resource-id voor de resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Beschrijft de door het systeem toegewezen beheerde identiteit die aan deze taak is toegewezen, 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 bepaalde 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 (date-time)	Waarde is een MET ISO-8601 opgemaakte UTC-tijdstempel die aangeeft wanneer de streamingtaak is gemaakt.
properties.dataLocale	string	De landinstellingen 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 is gewijzigd tussen aanvragen. U kunt deze ook gebruiken in de If-Match of If-None-Match headers voor schrijfbewerkingen voor optimistische gelijktijdigheid.
properties.eventsLateArrivalMaxDelayInSeconds	integer (int32)	De maximaal toelaatbare vertraging in seconden waarin gebeurtenissen die te laat aankomen, kunnen worden opgenomen. Het ondersteunde bereik wordt -1 tot 1814399 (20.23:59:59 dagen) en -1 wordt gebruikt om voor onbepaalde tijd te wachten. Als de eigenschap afwezig is, wordt deze geïnterpreteerd als een waarde van -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer (int32)	De maximaal toelaatbare vertraging in seconden waarbij out-of-ordergebeurtenissen kunnen worden aangepast om weer in volgorde te zijn.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Hiermee wordt het beleid aangegeven dat moet worden toegepast op gebeurtenissen die niet in de volgorde van de invoer gebeurtenisstroom aankomen.
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 (date-time)	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 toont dit de meest recente waarde in die set.
properties.outputErrorPolicy	OutputErrorPolicy	Geeft het beleid aan dat moet worden toegepast op gebeurtenissen die binnenkomen bij de uitvoer en niet naar de externe opslag kunnen worden geschreven vanwege een onjuiste indeling (ontbrekende kolomwaarden, kolomwaarden van onjuist type of grootte).
properties.outputStartMode	OutputStartMode	Deze eigenschap mag alleen worden gebruikt wanneer u wilt dat de taak onmiddellijk na het maken wordt gestart. Waarde kan JobStartTime, CustomTime of LastOutputEventTime zijn om aan te geven of het beginpunt van de uitvoergebeurtenisstroom moet worden gestart wanneer de taak wordt gestart, beginnen bij een aangepast gebruikerstijdstempel dat is opgegeven via de eigenschap outputStartTime of beginnen vanaf de laatste uitvoertijd van de gebeurtenis.
properties.outputStartTime	string (date-time)	Waarde is een iso-8601-geformatteerde 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 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 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

Object

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 de aandacht van de klant rechtvaardigen.
etag	string	De huidige entiteitstag voor de invoer. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource is gewijzigd tussen aanvragen. 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 worden 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 is of gegevens streamt. Vereist voor PUT-aanvragen (CreateOrReplace).

Transformation

Object

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

Name	Type	Default value	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 is gewijzigd tussen aanvragen. U kunt deze ook gebruiken in de If-Match of If-None-Match headers 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 (int32)	3	Hiermee geeft u het aantal streaming-eenheden op dat door de streamingtaak wordt gebruikt.
properties.validStreamingUnits	integer[] (int32)		Hiermee geeft u de geldige streaming-eenheden op waarmee een streamingtaak kan worden geschaald.
type	string		Type hulpbron

Delen via

Streaming Jobs - Create Or Replace

URI-parameters

Aanvraagkoptekst

Aanvraagbody

Antwoorden

Beveiliging

azure_auth

Bereiken

Voorbeelden

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

Voorbeeldaanvraag

Voorbeeldrespons

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

Voorbeeldaanvraag

Voorbeeldrespons

Definities

AggregateFunctionProperties

AuthenticationMode

AvroSerialization

AzureDataLakeStoreOutputDataSource

AzureFunctionOutputDataSource

AzureMachineLearningWebServiceFunctionBinding

AzureMachineLearningWebServiceInputColumn

AzureMachineLearningWebServiceInputs

AzureMachineLearningWebServiceOutputColumn

AzureSqlDatabaseOutputDataSource

AzureSqlReferenceInputDataSource

AzureSynapseOutputDataSource

AzureTableOutputDataSource

BlobOutputDataSource

BlobReferenceInputDataSource

BlobStreamInputDataSource

ClusterInfo

CompatibilityLevel

Compression

CompressionType

ContentStoragePolicy

CsvSerialization

DiagnosticCondition

Diagnostics

DocumentDbOutputDataSource

Encoding

Error

EventHubOutputDataSource

EventHubStreamInputDataSource

EventHubV2OutputDataSource

EventHubV2StreamInputDataSource

EventSerializationType

EventsOutOfOrderPolicy

FileReferenceInputDataSource

Function

FunctionInput

FunctionOutput

GatewayMessageBusOutputDataSource

GatewayMessageBusStreamInputDataSource

Identity

Input

IoTHubStreamInputDataSource

JavaScriptFunctionBinding

JobStorageAccount

JobType

JsonOutputSerializationFormat

JsonSerialization

Output

OutputErrorPolicy

OutputStartMode

ParquetSerialization

PowerBIOutputDataSource

ReferenceInputProperties

RefreshType

ScalarFunctionProperties

ServiceBusQueueOutputDataSource

ServiceBusTopicOutputDataSource

Sku

SkuName

StorageAccount

StreamingJob

StreamInputProperties

Transformation