Streaming Jobs - Create Or Replace

Dienst:

Stream Analytics

API-Version:

2020-03-01

Erstellt einen Streamingauftrag oder ersetzt einen bereits vorhandenen Streamingauftrag.

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

URI-Parameter

Name	In	Erforderlich	Typ	Beschreibung
jobName	path	True	string	Der Name des Streamingauftrags.
resourceGroupName	path	True	string minLength: 1 maxLength: 90 pattern: ^[-\w\._\(\)]+$	Der Name der Ressourcengruppe. Bei dem Namen wird die Groß-/Kleinschreibung nicht beachtet.
subscriptionId	path	True	string minLength: 1	Die ID des Zielabonnements.
api-version	query	True	string minLength: 1	Die API-Version, die für diesen Vorgang verwendet werden soll.

Anforderungsheader

Name	Erforderlich	Typ	Beschreibung
If-Match		string	Das ETag des Streamingauftrags. Lassen Sie diesen Wert aus, um den aktuellen Datensatzsatz immer zu überschreiben. Geben Sie den zuletzt gesehenen ETag-Wert an, um zu verhindern, dass gleichzeitige Änderungen versehentlich überschrieben werden.
If-None-Match		string	Legen Sie auf '*' fest, damit ein neuer Streamingauftrag erstellt werden kann, aber um zu verhindern, dass ein vorhandener Datensatzsatz aktualisiert wird. Andere Werte führen zu einer Fehlerantwort von 412 Vorbedingung.

Anforderungstext

Name	Typ	Beschreibung
identity	Identity	Beschreibt die diesem Auftrag zugewiesene verwaltete Identität, die für die Authentifizierung mit Eingaben und Ausgaben verwendet werden kann.
location	string	Der geografische Standort, an dem sich die Ressource befindet
properties.cluster	ClusterInfo	Der Cluster, auf dem Streamingaufträge ausgeführt werden.
properties.compatibilityLevel	CompatibilityLevel	Steuert bestimmte Laufzeitverhalten des Streamingauftrags.
properties.contentStoragePolicy	ContentStoragePolicy	Gültige Werte sind JobStorageAccount und SystemAccount. Wenn dieser Wert auf "JobStorageAccount" festgelegt ist, muss der Benutzer auch die Eigenschaft "jobStorageAccount" angeben. .
properties.dataLocale	string	Das Datengebietsschema des Datenanalyseauftrags. Der Wert sollte der Name einer unterstützten .NET-Kultur aus dem set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspxsein. Wird standardmäßig auf 'en-US' festgelegt, wenn keine angegeben ist.
properties.eventsLateArrivalMaxDelayInSeconds	integer (int32)	Die maximale tolerierbare Verzögerung in Sekunden, bei der Ereignisse, die verspätet eintreffen, enthalten sein könnten. Der unterstützte Bereich wird auf 1814399 (20.23:59:59:59 Tage) -1, und -1 wird verwendet, um die Wartezeit auf unbestimmte Zeit anzugeben. Wenn die Eigenschaft nicht vorhanden ist, wird sie interpretiert, um einen Wert von -1 zu haben.
properties.eventsOutOfOrderMaxDelayInSeconds	integer (int32)	Die maximale tolerierbare Verzögerung in Sekunden, bei der Out-of-Order-Ereignisse angepasst werden können, um in der Reihenfolge wieder zu sein.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Gibt die Richtlinie an, die auf Ereignisse angewendet werden soll, die im Eingabeereignisdatenstrom außerhalb der Reihenfolge eingehen.
properties.functions	Function[]	Eine Liste mit einer oder mehreren Funktionen für den Streamingauftrag. Die Name-Eigenschaft für jede Funktion ist erforderlich, wenn Sie diese Eigenschaft in einer PUT-Anforderung angeben. Diese Eigenschaft kann nicht über einen PATCH-Vorgang geändert werden. Sie müssen die PATCH-API verwenden, die für die einzelne Transformation verfügbar ist.
properties.inputs	Input[]	Eine Liste mit mindestens einer Eingabe für den Streamingauftrag. Die Name-Eigenschaft für jede Eingabe ist erforderlich, wenn Sie diese Eigenschaft in einer PUT-Anforderung angeben. Diese Eigenschaft kann nicht über einen PATCH-Vorgang geändert werden. Sie müssen die PATCH-API verwenden, die für die einzelnen Eingaben verfügbar ist.
properties.jobStorageAccount	JobStorageAccount	Die Eigenschaften, die einem Azure Storage-Konto mit MSI zugeordnet sind
properties.jobType	JobType	Beschreibt den Typ des Auftrags. Gültige Modi sind Cloud und "Edge".
properties.outputErrorPolicy	OutputErrorPolicy	Gibt die Richtlinie an, die auf Ereignisse angewendet werden soll, die an der Ausgabe eingehen und aufgrund falscher Spaltenwerte, spaltenwerte falscher Typ oder Größe nicht in den externen Speicher geschrieben werden können.
properties.outputStartMode	OutputStartMode	Diese Eigenschaft sollte nur verwendet werden, wenn gewünscht wird, dass der Auftrag sofort beim Erstellen gestartet wird. Der Wert kann JobStartTime, CustomTime oder LastOutputEventTime sein, um anzugeben, ob der Startpunkt des Ausgabeereignisdatenstroms gestartet werden soll, wenn der Auftrag gestartet wird, mit einem benutzerdefinierten Benutzerzeitstempel beginnen, der über die outputStartTime-Eigenschaft angegeben ist, oder von der letzten Ereignisausgabezeit beginnen soll.
properties.outputStartTime	string (date-time)	Der Wert ist entweder ein formatierter ISO-8601-Zeitstempel, der den Startpunkt des Ausgabeereignisdatenstroms angibt, oder NULL, um anzugeben, dass der Ausgabeereignisdatenstrom bei jedem Start des Streamingauftrags gestartet wird. Diese Eigenschaft muss einen Wert aufweisen, wenn outputStartMode auf CustomTime festgelegt ist.
properties.outputs	Output[]	Eine Liste mit einer oder mehreren Ausgaben für den Streamingauftrag. Die Name-Eigenschaft für jede Ausgabe ist erforderlich, wenn Sie diese Eigenschaft in einer PUT-Anforderung angeben. Diese Eigenschaft kann nicht über einen PATCH-Vorgang geändert werden. Sie müssen die PATCH-API verwenden, die für die einzelne Ausgabe verfügbar ist.
properties.sku	Sku	Beschreibt die SKU des Streamingauftrags. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.transformation	Transformation	Gibt die Abfrage und die Anzahl der Streamingeinheiten an, die für den Streamingauftrag verwendet werden sollen. Die Namenseigenschaft der Transformation ist erforderlich, wenn Sie diese Eigenschaft in einer PUT-Anforderung angeben. Diese Eigenschaft kann nicht über einen PATCH-Vorgang geändert werden. Sie müssen die PATCH-API verwenden, die für die einzelne Transformation verfügbar ist.
tags	object	Ressourcentags.

Antworten

Name	Typ	Beschreibung
200 OK	StreamingJob	Der Streamingauftrag wurde erfolgreich erstellt oder ersetzt. Header ETag: string
201 Created	StreamingJob	Der Streamingauftrag wurde erfolgreich erstellt oder ersetzt. Header ETag: string
Other Status Codes	Error	Fehler.

Sicherheit

azure_auth

Azure Active Directory OAuth2-Fluss

Typ: oauth2
Ablauf: implicit
Autorisierungs-URL: https://login.microsoftonline.com/common/oauth2/authorize

Bereiche

Name	Beschreibung
user_impersonation	Identitätswechsel ihres Benutzerkontos

Beispiele

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)

Beispielanforderung

HTTP

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

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

Java

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

/**
 * Samples for StreamingJobs CreateOrReplace.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/
     * StreamingJob_Create_CompleteJob.json
     */
    /**
     * Sample code: Create a complete streaming job (a streaming job with a transformation, at least 1 input and at
     * least 1 output).
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager.streamingJobs().define("sj7804").withRegion("West US").withExistingResourceGroup("sjrg3276")
            .withTags(mapOf("key1", "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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

JavaScript

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

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

createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output().catch(
  console.error
);

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

Beispiel für eine Antwort

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)

Beispielanforderung

HTTP

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

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

Java

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

/**
 * Samples for StreamingJobs CreateOrReplace.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/
     * StreamingJob_Create_JobShell.json
     */
    /**
     * Sample code: Create a streaming job shell (a streaming job with no inputs, outputs, transformation, or
     * functions).
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager.streamingJobs().define("sj59").withRegion("West US").withExistingResourceGroup("sjrg6936")
            .withTags(mapOf("key1", "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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

JavaScript

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

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

createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions().catch(
  console.error
);

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

Beispiel für eine Antwort

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

Definitionen

Name	Beschreibung
AggregateFunctionProperties	Die Eigenschaften, die einer Aggregatfunktion zugeordnet sind.
AuthenticationMode	Authentifizierungsmodus. Gültige Modi sind ConnectionString, Msi und "UserToken".
AvroSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im Avro-Format geschrieben werden.
AzureDataLakeStoreOutputDataSource	Beschreibt eine Azure Data Lake Store-Ausgabedatenquelle.
AzureFunctionOutputDataSource	Definiert die Metadaten von AzureFunctionOutputDataSource
AzureMachineLearningWebServiceFunctionBinding	Die Bindung an einen Azure Machine Learning-Webdienst.
AzureMachineLearningWebServiceInputColumn	Beschreibt eine Eingabespalte für den Azure Machine Learning-Webdienstendpunkt.
AzureMachineLearningWebServiceInputs	Die Eingaben für den Azure Machine Learning-Webdienstendpunkt.
AzureMachineLearningWebServiceOutputColumn	Beschreibt eine Ausgabespalte für den Azure Machine Learning-Webdienstendpunkt.
AzureSqlDatabaseOutputDataSource	Beschreibt eine Azure SQL-Datenbankausgabedatenquelle.
AzureSqlReferenceInputDataSource	Beschreibt eine Azure SQL-Datenbankreferenz-Eingabedatenquelle.
AzureSynapseOutputDataSource	Beschreibt eine Azure Synapse-Ausgabedatenquelle.
AzureTableOutputDataSource	Beschreibt eine Azure Table-Ausgabedatenquelle.
BlobOutputDataSource	Beschreibt eine BLOB-Ausgabedatenquelle.
BlobReferenceInputDataSource	Beschreibt eine BLOB-Eingabedatenquelle, die Referenzdaten enthält.
BlobStreamInputDataSource	Beschreibt eine BLOB-Eingabedatenquelle, die Datenstromdaten enthält.
ClusterInfo	Die Eigenschaften, die einem Stream Analytics-Cluster zugeordnet sind.
CompatibilityLevel	Steuert bestimmte Laufzeitverhalten des Streamingauftrags.
Compression	Beschreibt, wie Eingabedaten komprimiert werden
CompressionType	Gibt den Typ der Komprimierung an, die von der Eingabe verwendet wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).
ContentStoragePolicy	Gültige Werte sind JobStorageAccount und SystemAccount. Wenn dieser Wert auf "JobStorageAccount" festgelegt ist, muss der Benutzer auch die Eigenschaft "jobStorageAccount" angeben. .
CsvSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im CSV-Format geschrieben werden.
DiagnosticCondition	Bedingung, die für die Ressource oder für den Auftrag insgesamt gilt, die die Aufmerksamkeit des Kunden garantieren.
Diagnostics	Beschreibt bedingungen, die für die Eingabe, Ausgabe oder den Auftrag insgesamt gelten, die die Aufmerksamkeit der Kunden garantieren.
DocumentDbOutputDataSource	Beschreibt eine DocumentDB-Ausgabedatenquelle.
Encoding	Gibt die Codierung der eingehenden Daten im Falle der Eingabe und die Codierung ausgehender Daten im Falle der Ausgabe an.
Error	Häufige Fehlerdarstellung.
EventHubOutputDataSource	Beschreibt eine Event Hub-Ausgabedatenquelle.
EventHubStreamInputDataSource	Beschreibt eine Event Hub-Eingabedatenquelle, die Datenstromdaten enthält.
EventHubV2OutputDataSource	Beschreibt eine Event Hub-Ausgabedatenquelle.
EventHubV2StreamInputDataSource	Beschreibt eine Event Hub-Eingabedatenquelle, die Datenstromdaten enthält.
EventSerializationType	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).
EventsOutOfOrderPolicy	Gibt die Richtlinie an, die auf Ereignisse angewendet werden soll, die im Eingabeereignisdatenstrom außerhalb der Reihenfolge eingehen.
FileReferenceInputDataSource	Beschreibt eine Dateieingabedatenquelle, die Referenzdaten enthält.
Function	Ein Funktionsobjekt, das alle Informationen enthält, die der benannten Funktion zugeordnet sind. Alle Funktionen sind unter einem Streamingauftrag enthalten.
FunctionInput	Beschreibt einen Eingabeparameter einer Funktion.
FunctionOutput	Beschreibt die Ausgabe einer Funktion.
GatewayMessageBusOutputDataSource	Beschreibt eine Gateway-Nachrichtenbus-Ausgabedatenquelle.
GatewayMessageBusStreamInputDataSource	Beschreibt eine BLOB-Eingabedatenquelle, die Datenstromdaten enthält.
Identity	Beschreibt, wie identität überprüft wird
Input	Ein Eingabeobjekt, das alle Informationen enthält, die der benannten Eingabe zugeordnet sind. Alle Eingaben sind unter einem Streamingauftrag enthalten.
IoTHubStreamInputDataSource	Beschreibt eine IoT Hub-Eingabedatenquelle, die Datenstromdaten enthält.
JavaScriptFunctionBinding	Die Bindung an eine JavaScript-Funktion.
JobStorageAccount	Die Eigenschaften, die einem Azure Storage-Konto mit MSI zugeordnet sind
JobType	Beschreibt den Typ des Auftrags. Gültige Modi sind Cloud und "Edge".
JsonOutputSerializationFormat	Gibt das Format des JSON an, in dem die Ausgabe geschrieben wird. Die derzeit unterstützten Werte sind "lineSeparated", der angibt, dass die Ausgabe formatiert wird, indem jedes JSON-Objekt durch eine neue Zeile getrennt und "Array" angegeben wird, dass die Ausgabe als Array von JSON-Objekten formatiert wird.
JsonSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im JSON-Format geschrieben werden.
Output	Ein Ausgabeobjekt, das alle Informationen enthält, die der benannten Ausgabe zugeordnet sind. Alle Ausgaben sind unter einem Streamingauftrag enthalten.
OutputErrorPolicy	Gibt die Richtlinie an, die auf Ereignisse angewendet werden soll, die an der Ausgabe eingehen und aufgrund falscher Spaltenwerte, spaltenwerte falscher Typ oder Größe nicht in den externen Speicher geschrieben werden können.
OutputStartMode	Der Wert kann JobStartTime, CustomTime oder LastOutputEventTime sein, um anzugeben, ob der Startpunkt des Ausgabeereignisdatenstroms gestartet werden soll, wenn der Auftrag gestartet wird, mit einem benutzerdefinierten Benutzerzeitstempel beginnen, der über die outputStartTime-Eigenschaft angegeben ist, oder von der letzten Ereignisausgabezeit beginnen soll.
ParquetSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im Parkettformat geschrieben werden.
PowerBIOutputDataSource	Beschreibt eine Power BI-Ausgabedatenquelle.
ReferenceInputProperties	Die Eigenschaften, die einer Eingabe zugeordnet sind, die Referenzdaten enthält.
RefreshType	Gibt den Typ der Datenaktualisierungsoption an.
ScalarFunctionProperties	Die Eigenschaften, die einer skalaren Funktion zugeordnet sind.
ServiceBusQueueOutputDataSource	Beschreibt eine Ausgabedatenquelle der Servicebuswarteschlange.
ServiceBusTopicOutputDataSource	Beschreibt eine Ausgabedatenquelle für Service Bus-Themen.
Sku	Die Eigenschaften, die einer SKU zugeordnet sind.
SkuName	Der Name der SKU. Erforderlich für PUT-Anforderungen (CreateOrReplace).
StorageAccount	Die Eigenschaften, die einem Azure Storage-Konto zugeordnet sind
StreamingJob	Ein Streamingauftragsobjekt, das alle Informationen enthält, die dem benannten Streamingauftrag zugeordnet sind.
StreamInputProperties	Die Eigenschaften, die einer Eingabe zugeordnet sind, die Datenstromdaten enthält.
Transformation	Ein Transformationsobjekt, das alle Informationen enthält, die der benannten Transformation zugeordnet sind. Alle Transformationen sind unter einem Streamingauftrag enthalten.

AggregateFunctionProperties

Objekt

Die Eigenschaften, die einer Aggregatfunktion zugeordnet sind.

Name	Typ	Beschreibung
etag	string	Das aktuelle Entitätstag für die Funktion. Dies ist eine undurchsichtige Zeichenfolge. Sie können es verwenden, um zu erkennen, ob sich die Ressource zwischen Anforderungen geändert hat. Sie können sie auch in den If-Match- oder If-None-Match Headern für Schreibvorgänge für optimistische Parallelität verwenden.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Die physische Bindung der Funktion. Beispielsweise beschreibt dies im Fall des Azure Machine Learning-Webdiensts den Endpunkt.
properties.inputs	FunctionInput[]	Beschreibt einen Eingabeparameter einer Funktion.
properties.output	FunctionOutput	Beschreibt die Ausgabe einer Funktion.
type	string: Aggregate	Gibt den Funktionstyp an.

AuthenticationMode

Enumeration

Authentifizierungsmodus. Gültige Modi sind ConnectionString, Msi und "UserToken".

Wert	Beschreibung
ConnectionString
Msi
UserToken

AvroSerialization

Objekt

Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im Avro-Format geschrieben werden.

Name	Typ	Beschreibung
type	string: Avro	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Objekt

Beschreibt eine Azure Data Lake Store-Ausgabedatenquelle.

Name	Typ	Standardwert	Beschreibung
properties.accountName	string		Der Name des Azure Data Lake Store-Kontos. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.dateFormat	string		Das Datumsformat. Unabhängig davon, wo {date} in filePathPrefix angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Datumsformat verwendet.
properties.filePathPrefix	string		Der Speicherort der Datei, in die die Ausgabe geschrieben werden soll. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.refreshToken	string		Ein Aktualisierungstoken, das verwendet werden kann, um ein gültiges Zugriffstoken abzurufen, das dann zur Authentifizierung mit der Datenquelle verwendet werden kann. Ein gültiges Aktualisierungstoken kann derzeit nur über das Azure-Portal abgerufen werden. Es wird empfohlen, beim Erstellen der Datenquelle einen Dummy-Zeichenfolgenwert hier einzufügen und dann zum Azure-Portal zu wechseln, um die Datenquelle zu authentifizieren, die diese Eigenschaft mit einem gültigen Aktualisierungstoken aktualisiert. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.tenantId	string		Die Mandanten-ID des Benutzers, der zum Abrufen des Aktualisierungstokens verwendet wurde. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.timeFormat	string		Das Zeitformat. Unabhängig davon, wo {time} in filePathPrefix angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Zeitformat verwendet.
properties.tokenUserDisplayName	string		Der Anzeigename des Benutzers, der zum Abrufen des Aktualisierungstokens verwendet wurde. Verwenden Sie diese Eigenschaft, um sich zu merken, welcher Benutzer zum Abrufen des Aktualisierungstokens verwendet wurde.
properties.tokenUserPrincipalName	string		Der Benutzerprinzipalname (UPN) des Benutzers, der zum Abrufen des Aktualisierungstokens verwendet wurde. Verwenden Sie diese Eigenschaft, um sich zu merken, welcher Benutzer zum Abrufen des Aktualisierungstokens verwendet wurde.
type	string: Microsoft.DataLake/Accounts		Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

AzureFunctionOutputDataSource

Objekt

Definiert die Metadaten von AzureFunctionOutputDataSource

Name	Typ	Beschreibung
properties.apiKey	string	Wenn Sie eine Azure-Funktion aus einem anderen Abonnement verwenden möchten, können Sie dies tun, indem Sie den Schlüssel für den Zugriff auf Ihre Funktion bereitstellen.
properties.functionAppName	string	Der Name Ihrer Azure Functions-App.
properties.functionName	string	Der Name der Funktion in Ihrer Azure Functions-App.
properties.maxBatchCount	number	Eine Eigenschaft, mit der Sie die maximale Anzahl von Ereignissen in jedem Batch angeben können, der an Azure Functions gesendet wird. Der Standardwert ist 100.
properties.maxBatchSize	number	Eine Eigenschaft, mit der Sie die maximale Größe für jeden Ausgabebatch festlegen können, der an Ihre Azure-Funktion gesendet wird. Die Eingabeeinheit ist in Byte. Dieser Wert beträgt standardmäßig 262.144 Byte (256 KB).
type	string: Microsoft.AzureFunction	Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

Objekt

Die Bindung an einen Azure Machine Learning-Webdienst.

Name	Typ	Beschreibung
properties.apiKey	string	Der ZUM Authentifizieren mit Request-Response Endpunkt verwendete API-Schlüssel.
properties.batchSize	integer (int32)	Zahl zwischen 1 und 10000, die die maximale Anzahl von Zeilen für jede Azure ML RRS-Ausführungsanforderung beschreibt. Der Standardwert ist 1000.
properties.endpoint	string	Der Request-Response Endpunkt des Azure Machine Learning-Webdiensts ausführen. Weitere Informationen finden Sie hier: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
properties.inputs	AzureMachineLearningWebServiceInputs	Die Eingaben für den Azure Machine Learning-Webdienstendpunkt.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Eine Liste der Ausgaben aus der Ausführung des Azure Machine Learning-Webdienstendpunkts.
type	string: Microsoft.MachineLearning/WebService	Gibt den Funktionsbindungstyp an.

AzureMachineLearningWebServiceInputColumn

Objekt

Beschreibt eine Eingabespalte für den Azure Machine Learning-Webdienstendpunkt.

Name	Typ	Beschreibung
dataType	string	Der (von Azure Machine Learning unterstützte) Datentyp der Eingabespalte. Eine Liste gültiger Azure Machine Learning-Datentypen wird unter https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx beschrieben.
mapTo	integer (int32)	Der nullbasierte Index des Funktionsparameters, dem diese Eingabe zugeordnet ist.
name	string	Der Name der Eingabespalte.

AzureMachineLearningWebServiceInputs

Objekt

Die Eingaben für den Azure Machine Learning-Webdienstendpunkt.

Name	Typ	Beschreibung
columnNames	AzureMachineLearningWebServiceInputColumn[]	Eine Liste der Eingabespalten für den Azure Machine Learning-Webdienstendpunkt.
name	string	Der Name der Eingabe. Dies ist der Name, der beim Erstellen des Endpunkts bereitgestellt wird.

AzureMachineLearningWebServiceOutputColumn

Objekt

Beschreibt eine Ausgabespalte für den Azure Machine Learning-Webdienstendpunkt.

Name	Typ	Beschreibung
dataType	string	Der (von Azure Machine Learning unterstützte) Datentyp der Ausgabespalte. Eine Liste gültiger Azure Machine Learning-Datentypen wird unter https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx beschrieben.
name	string	Der Name der Ausgabespalte.

AzureSqlDatabaseOutputDataSource

Objekt

Beschreibt eine Azure SQL-Datenbankausgabedatenquelle.

Name	Typ	Standardwert	Beschreibung
properties.authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.database	string		Der Name der Azure SQL-Datenbank. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.maxBatchCount	number		Max Batch count for write to SQL database, the default value is 10.000. Optional für PUT-Anforderungen.
properties.maxWriterCount	number		Max Writer count, currently only 1(single writer) and 0(based on query partition) are available. Optional für PUT-Anforderungen.
properties.password	string		Das Kennwort, das zum Herstellen einer Verbindung mit der Azure SQL-Datenbank verwendet wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.server	string		Der Name des SQL-Servers, der die Azure SQL-Datenbank enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.table	string		Der Name der Tabelle in der Azure SQL-Datenbank. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.user	string		Der Benutzername, der zum Herstellen einer Verbindung mit der Azure SQL-Datenbank verwendet wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.Sql/Server/Database		Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

AzureSqlReferenceInputDataSource

Objekt

Beschreibt eine Azure SQL-Datenbankreferenz-Eingabedatenquelle.

Name	Typ	Beschreibung
properties.database	string	Dieses Element ist dem Datenquellenelement zugeordnet. Dies ist der Name der Datenbank, in die die Ausgabe geschrieben wird.
properties.deltaSnapshotQuery	string	Dieses Element ist dem Datenquellenelement zugeordnet. Diese Abfrage wird verwendet, um inkrementelle Änderungen aus der SQL-Datenbank abzurufen. Um diese Option zu verwenden, empfehlen wir die Verwendung zeitlicher Tabellen in der Azure SQL-Datenbank.
properties.fullSnapshotQuery	string	Dieses Element ist dem Datenquellenelement zugeordnet. Diese Abfrage wird verwendet, um Daten aus der SQL-Datenbank abzurufen.
properties.password	string	Dieses Element ist dem Datenquellenelement zugeordnet. Dies ist das Kennwort, das zum Herstellen einer Verbindung mit der SQL-Datenbankinstanz verwendet wird.
properties.refreshRate	string	Dieses Element ist dem Datenquellenelement zugeordnet. Dies gibt an, wie häufig die Daten aus der Datenbank abgerufen werden. Es ist das DateTime-Format.
properties.refreshType	RefreshType	Gibt den Typ der Datenaktualisierungsoption an.
properties.server	string	Dieses Element ist dem Datenquellenelement zugeordnet. Dies ist der Name des Servers, der die Datenbank enthält, in die geschrieben wird.
properties.table	string	Dieses Element ist dem Datenquellenelement zugeordnet. Der Name der Tabelle in der Azure SQL-Datenbank.
properties.user	string	Dieses Element ist dem Datenquellenelement zugeordnet. Dies ist der Benutzername, der zum Herstellen einer Verbindung mit der SQL-Datenbankinstanz verwendet wird.
type	string: Microsoft.Sql/Server/Database	Gibt den Typ der Eingabedatenquelle an, die Referenzdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

AzureSynapseOutputDataSource

Objekt

Beschreibt eine Azure Synapse-Ausgabedatenquelle.

Name	Typ	Beschreibung
properties.database	string	Der Name der Azure SQL-Datenbank. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.password	string	Das Kennwort, das zum Herstellen einer Verbindung mit der Azure SQL-Datenbank verwendet wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.server	string	Der Name des SQL-Servers, der die Azure SQL-Datenbank enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.table	string	Der Name der Tabelle in der Azure SQL-Datenbank. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.user	string	Der Benutzername, der zum Herstellen einer Verbindung mit der Azure SQL-Datenbank verwendet wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.Sql/Server/DataWarehouse	Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

AzureTableOutputDataSource

Objekt

Beschreibt eine Azure Table-Ausgabedatenquelle.

Name	Typ	Beschreibung
properties.accountKey	string	Der Kontoschlüssel für das Azure Storage-Konto. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.accountName	string	Der Name des Azure Storage-Kontos. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.batchSize	integer (int32)	Die Anzahl der Zeilen, die gleichzeitig in die Azure-Tabelle geschrieben werden sollen.
properties.columnsToRemove	string[]	Wenn angegeben, ist jedes Element im Array der Name einer Spalte, die (sofern vorhanden) aus Ausgabeereignisentitäten entfernt werden soll.
properties.partitionKey	string	Dieses Element gibt den Namen einer Spalte aus der SELECT-Anweisung in der Abfrage an, die als Partitionsschlüssel für die Azure-Tabelle verwendet wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.rowKey	string	Dieses Element gibt den Namen einer Spalte aus der SELECT-Anweisung in der Abfrage an, die als Zeilenschlüssel für die Azure-Tabelle verwendet wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.table	string	Der Name der Azure-Tabelle. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.Storage/Table	Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

BlobOutputDataSource

Objekt

Beschreibt eine BLOB-Ausgabedatenquelle.

Name	Typ	Standardwert	Beschreibung
properties.authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.blobPathPrefix	string		Blobpfadpräfix.
properties.container	string		Der Name eines Containers innerhalb des zugeordneten Speicherkontos. Dieser Container enthält entweder die Blobs, aus der gelesen oder geschrieben werden soll. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.dateFormat	string		Das Datumsformat. Unabhängig davon, wo {date} in pathPattern angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Datumsformat verwendet.
properties.pathPattern	string		Das Blobpfadmuster. Kein regulärer Ausdruck. Es stellt ein Muster dar, mit dem Blobnamen abgeglichen werden, um festzustellen, ob sie als Eingabe oder Ausgabe in den Auftrag eingeschlossen werden sollen. Eine ausführlichere Erläuterung und ein weiteres Beispiel finden Sie unter https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input oder https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output.
properties.storageAccounts	StorageAccount[]		Eine Liste mit einem oder mehreren Azure Storage-Konten. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.timeFormat	string		Das Zeitformat. Unabhängig davon, wo {time} in pathPattern angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Zeitformat verwendet.
type	string: Microsoft.Storage/Blob		Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

BlobReferenceInputDataSource

Objekt

Beschreibt eine BLOB-Eingabedatenquelle, die Referenzdaten enthält.

Name	Typ	Standardwert	Beschreibung
properties.authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.container	string		Der Name eines Containers innerhalb des zugeordneten Speicherkontos. Dieser Container enthält entweder die Blobs, aus der gelesen oder geschrieben werden soll. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.dateFormat	string		Das Datumsformat. Unabhängig davon, wo {date} in pathPattern angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Datumsformat verwendet.
properties.pathPattern	string		Das Blobpfadmuster. Kein regulärer Ausdruck. Es stellt ein Muster dar, mit dem Blobnamen abgeglichen werden, um festzustellen, ob sie als Eingabe oder Ausgabe in den Auftrag eingeschlossen werden sollen. Eine ausführlichere Erläuterung und ein weiteres Beispiel finden Sie unter https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input oder https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output.
properties.storageAccounts	StorageAccount[]		Eine Liste mit einem oder mehreren Azure Storage-Konten. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.timeFormat	string		Das Zeitformat. Unabhängig davon, wo {time} in pathPattern angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Zeitformat verwendet.
type	string: Microsoft.Storage/Blob		Gibt den Typ der Eingabedatenquelle an, die Referenzdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

BlobStreamInputDataSource

Objekt

Beschreibt eine BLOB-Eingabedatenquelle, die Datenstromdaten enthält.

Name	Typ	Standardwert	Beschreibung
properties.authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.container	string		Der Name eines Containers innerhalb des zugeordneten Speicherkontos. Dieser Container enthält entweder die Blobs, aus der gelesen oder geschrieben werden soll. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.dateFormat	string		Das Datumsformat. Unabhängig davon, wo {date} in pathPattern angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Datumsformat verwendet.
properties.pathPattern	string		Das Blobpfadmuster. Kein regulärer Ausdruck. Es stellt ein Muster dar, mit dem Blobnamen abgeglichen werden, um festzustellen, ob sie als Eingabe oder Ausgabe in den Auftrag eingeschlossen werden sollen. Eine ausführlichere Erläuterung und ein weiteres Beispiel finden Sie unter https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input oder https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output.
properties.sourcePartitionCount	integer (int32)		Die Partitionsanzahl der BLOB-Eingabedatenquelle. Bereich 1 - 1024.
properties.storageAccounts	StorageAccount[]		Eine Liste mit einem oder mehreren Azure Storage-Konten. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.timeFormat	string		Das Zeitformat. Unabhängig davon, wo {time} in pathPattern angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Zeitformat verwendet.
type	string: Microsoft.Storage/Blob		Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

ClusterInfo

Objekt

Die Eigenschaften, die einem Stream Analytics-Cluster zugeordnet sind.

Name	Typ	Beschreibung
id	string	Die Ressourcen-ID des Clusters.

CompatibilityLevel

Enumeration

Steuert bestimmte Laufzeitverhalten des Streamingauftrags.

Wert	Beschreibung
1.0
1.2

Compression

Objekt

Beschreibt, wie Eingabedaten komprimiert werden

Name	Typ	Standardwert	Beschreibung
type	CompressionType	None	Gibt den Typ der Komprimierung an, die von der Eingabe verwendet wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

CompressionType

Enumeration

Gibt den Typ der Komprimierung an, die von der Eingabe verwendet wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Wert	Beschreibung
Deflate
GZip
None

ContentStoragePolicy

Enumeration

Gültige Werte sind JobStorageAccount und SystemAccount. Wenn dieser Wert auf "JobStorageAccount" festgelegt ist, muss der Benutzer auch die Eigenschaft "jobStorageAccount" angeben. .

Wert	Beschreibung
JobStorageAccount
SystemAccount

CsvSerialization

Objekt

Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im CSV-Format geschrieben werden.

Name	Typ	Beschreibung
properties.encoding	Encoding	Gibt die Codierung der eingehenden Daten im Falle der Eingabe und die Codierung ausgehender Daten im Falle der Ausgabe an. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.fieldDelimiter	string	Gibt das Trennzeichen an, das zum Trennen von durch Trennzeichen getrennten Werten (CSV)-Datensätzen verwendet wird. Eine Liste der unterstützten Werte finden Sie unter https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input oder https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Csv	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

DiagnosticCondition

Objekt

Bedingung, die für die Ressource oder für den Auftrag insgesamt gilt, die die Aufmerksamkeit des Kunden garantieren.

Name	Typ	Beschreibung
code	string	Der undurchsichtige Diagnosecode.
message	string	Die lesbare Nachricht, die die Bedingung detailliert beschreibt. Lokalisiert im Accept-Language der Clientanforderung.
since	string	Der UTC-Zeitstempel, zu dem die Bedingung gestartet wurde. Kunden sollten dieses Mal in der Lage sein, ein entsprechendes Ereignis im Ops-Protokoll zu finden.

Diagnostics

Objekt

Beschreibt bedingungen, die für die Eingabe, Ausgabe oder den Auftrag insgesamt gelten, die die Aufmerksamkeit der Kunden garantieren.

Name	Typ	Beschreibung
conditions	DiagnosticCondition[]	Eine Sammlung von null oder mehr Bedingungen, die für die Ressource oder für den Auftrag insgesamt gelten, die die Aufmerksamkeit der Kunden garantieren.

DocumentDbOutputDataSource

Objekt

Beschreibt eine DocumentDB-Ausgabedatenquelle.

Name	Typ	Beschreibung
properties.accountId	string	Der Name oder die ID des DocumentDB-Kontos. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.accountKey	string	Der Kontoschlüssel für das DocumentDB-Konto. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.collectionNamePattern	string	Das Sammlungsnamenmuster für die zu verwendenden Auflistungen. Das Sammlungsnamenformat kann mithilfe des optionalen {partition}-Tokens erstellt werden, wobei Partitionen von 0 beginnen. Weitere Informationen finden Sie im Abschnitt "DocumentDB" von https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.database	string	Der Name der DocumentDB-Datenbank. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.documentId	string	Der Name des Felds in Ausgabeereignissen, mit dem der Primärschlüssel angegeben wird, auf dem Einfüge- oder Aktualisierungsvorgänge basieren.
properties.partitionKey	string	Der Name des Felds in Ausgabeereignissen, mit dem der Schlüssel für die Partitionierung der Ausgabe in Auflistungen angegeben wird. Wenn 'collectionNamePattern' das {partition}-Token enthält, muss diese Eigenschaft angegeben werden.
type	string: Microsoft.Storage/DocumentDB	Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Encoding

Enumeration

Gibt die Codierung der eingehenden Daten im Falle der Eingabe und die Codierung ausgehender Daten im Falle der Ausgabe an.

Wert	Beschreibung
UTF8

Error

Objekt

Häufige Fehlerdarstellung.

Name	Typ	Beschreibung
error	Error	Fehlerdefinitionseigenschaften.

EventHubOutputDataSource

Objekt

Beschreibt eine Event Hub-Ausgabedatenquelle.

Name	Typ	Standardwert	Beschreibung
authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.eventHubName	string		Der Name des Event Hub. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.partitionKey	string		Der Schlüssel/die Spalte, die verwendet wird, um zu bestimmen, auf welche Partition Ereignisdaten gesendet werden sollen.
properties.propertyColumns	string[]		Die Eigenschaften, die dieser Event Hub-Ausgabe zugeordnet sind.
serviceBusNamespace	string		Der Namespace, der dem gewünschten Event Hub, Service Bus Queue, Service Bus Topic usw. zugeordnet ist. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyKey	string		Der Schlüssel für die gemeinsame Zugriffsrichtlinie für die angegebene Richtlinie für den freigegebenen Zugriff. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyName	string		Der Name der Richtlinie für den freigegebenen Zugriff für den Event Hub, service bus queue, Service Bus Topic usw. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

EventHubStreamInputDataSource

Objekt

Beschreibt eine Event Hub-Eingabedatenquelle, die Datenstromdaten enthält.

Name	Typ	Standardwert	Beschreibung
authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.consumerGroupName	string		Der Name einer Event Hub Consumer Group, die zum Lesen von Ereignissen aus dem Event Hub verwendet werden soll. Wenn Sie unterschiedliche Consumergruppennamen für mehrere Eingaben angeben, können diese Eingaben dieselben Ereignisse vom Event Hub empfangen. Wenn nicht angegeben, verwendet die Eingabe die Standard-Consumergruppe des Event Hub.
properties.eventHubName	string		Der Name des Event Hub. Erforderlich für PUT-Anforderungen (CreateOrReplace).
serviceBusNamespace	string		Der Namespace, der dem gewünschten Event Hub, Service Bus Queue, Service Bus Topic usw. zugeordnet ist. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyKey	string		Der Schlüssel für die gemeinsame Zugriffsrichtlinie für die angegebene Richtlinie für den freigegebenen Zugriff. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyName	string		Der Name der Richtlinie für den freigegebenen Zugriff für den Event Hub, service bus queue, Service Bus Topic usw. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

EventHubV2OutputDataSource

Objekt

Beschreibt eine Event Hub-Ausgabedatenquelle.

Name	Typ	Standardwert	Beschreibung
authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.eventHubName	string		Der Name des Event Hub. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.partitionKey	string		Der Schlüssel/die Spalte, die verwendet wird, um zu bestimmen, auf welche Partition Ereignisdaten gesendet werden sollen.
properties.propertyColumns	string[]		Die Eigenschaften, die dieser Event Hub-Ausgabe zugeordnet sind.
serviceBusNamespace	string		Der Namespace, der dem gewünschten Event Hub, Service Bus Queue, Service Bus Topic usw. zugeordnet ist. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyKey	string		Der Schlüssel für die gemeinsame Zugriffsrichtlinie für die angegebene Richtlinie für den freigegebenen Zugriff. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyName	string		Der Name der Richtlinie für den freigegebenen Zugriff für den Event Hub, service bus queue, Service Bus Topic usw. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

EventHubV2StreamInputDataSource

Objekt

Beschreibt eine Event Hub-Eingabedatenquelle, die Datenstromdaten enthält.

Name	Typ	Standardwert	Beschreibung
authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.consumerGroupName	string		Der Name einer Event Hub Consumer Group, die zum Lesen von Ereignissen aus dem Event Hub verwendet werden soll. Wenn Sie unterschiedliche Consumergruppennamen für mehrere Eingaben angeben, können diese Eingaben dieselben Ereignisse vom Event Hub empfangen. Wenn nicht angegeben, verwendet die Eingabe die Standard-Consumergruppe des Event Hub.
properties.eventHubName	string		Der Name des Event Hub. Erforderlich für PUT-Anforderungen (CreateOrReplace).
serviceBusNamespace	string		Der Namespace, der dem gewünschten Event Hub, Service Bus Queue, Service Bus Topic usw. zugeordnet ist. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyKey	string		Der Schlüssel für die gemeinsame Zugriffsrichtlinie für die angegebene Richtlinie für den freigegebenen Zugriff. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyName	string		Der Name der Richtlinie für den freigegebenen Zugriff für den Event Hub, service bus queue, Service Bus Topic usw. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

EventSerializationType

Enumeration

Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Wert	Beschreibung
Avro
Csv
Json
Parquet

EventsOutOfOrderPolicy

Enumeration

Gibt die Richtlinie an, die auf Ereignisse angewendet werden soll, die im Eingabeereignisdatenstrom außerhalb der Reihenfolge eingehen.

Wert	Beschreibung
Adjust
Drop

FileReferenceInputDataSource

Objekt

Beschreibt eine Dateieingabedatenquelle, die Referenzdaten enthält.

Name	Typ	Beschreibung
properties.path	string	Der Pfad der Datei.
type	string: File	Gibt den Typ der Eingabedatenquelle an, die Referenzdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Function

Objekt

Ein Funktionsobjekt, das alle Informationen enthält, die der benannten Funktion zugeordnet sind. Alle Funktionen sind unter einem Streamingauftrag enthalten.

Name	Typ	Beschreibung
id	string	Ressourcen-ID
name	string	Ressourcenname
properties	FunctionProperties: AggregateFunctionProperties ScalarFunctionProperties	Die Eigenschaften, die einer Funktion zugeordnet sind.
type	string	Ressourcentyp

FunctionInput

Objekt

Beschreibt einen Eingabeparameter einer Funktion.

Name	Typ	Beschreibung
dataType	string	Der (von Azure Stream Analytics unterstützte) Datentyp des Funktionseingabeparameters. Eine Liste der gültigen Azure Stream Analytics-Datentypen werden unter https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	Ein Flag, das angibt, ob der Parameter ein Konfigurationsparameter ist. True, wenn dieser Eingabeparameter erwartet wird, dass es sich um eine Konstante handelt. Der Standardwert ist "false".

FunctionOutput

Objekt

Beschreibt die Ausgabe einer Funktion.

Name	Typ	Beschreibung
dataType	string	Der (von Azure Stream Analytics unterstützte) Datentyp der Funktionsausgabe. Eine Liste der gültigen Azure Stream Analytics-Datentypen werden unter https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

Objekt

Beschreibt eine Gateway-Nachrichtenbus-Ausgabedatenquelle.

Name	Typ	Beschreibung
properties.topic	string	Der Name des Themas "ServiceBus".
type	string: GatewayMessageBus	Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Objekt

Beschreibt eine BLOB-Eingabedatenquelle, die Datenstromdaten enthält.

Name	Typ	Beschreibung
properties.topic	string	Der Name des Themas "ServiceBus".
type	string: GatewayMessageBus	Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Identity

Objekt

Beschreibt, wie identität überprüft wird

Name	Typ	Beschreibung
principalId	string	Die Identitätsprinzipal-ID
tenantId	string	Die Identitätsmandanten-ID
type	string	Der Identitätstyp

Input

Objekt

Ein Eingabeobjekt, das alle Informationen enthält, die der benannten Eingabe zugeordnet sind. Alle Eingaben sind unter einem Streamingauftrag enthalten.

Name	Typ	Beschreibung
id	string	Ressourcen-ID
name	string	Ressourcenname
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Die Eigenschaften, die einer Eingabe zugeordnet sind. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string	Ressourcentyp

IoTHubStreamInputDataSource

Objekt

Beschreibt eine IoT Hub-Eingabedatenquelle, die Datenstromdaten enthält.

Name	Typ	Beschreibung
properties.consumerGroupName	string	Der Name einer IoT Hub Consumer Group, die zum Lesen von Ereignissen aus dem IoT Hub verwendet werden soll. Wenn nicht angegeben, verwendet die Eingabe die Standard-Consumergruppe des Iot Hub.
properties.endpoint	string	Der IoT Hub-Endpunkt, mit dem eine Verbindung hergestellt werden soll (z. B. Nachrichten/Ereignisse, Nachrichten/operationsMonitoringEvents usw.).
properties.iotHubNamespace	string	Der Name oder der URI des IoT Hub. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Der Schlüssel für die gemeinsame Zugriffsrichtlinie für die angegebene Richtlinie für den freigegebenen Zugriff. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.sharedAccessPolicyName	string	Der Name der Freigegebenen Zugriffsrichtlinie für den IoT-Hub. Diese Richtlinie muss mindestens die Dienstverbindungsberechtigung enthalten. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

JavaScriptFunctionBinding

Objekt

Die Bindung an eine JavaScript-Funktion.

Name	Typ	Beschreibung
properties.script	string	Der JavaScript-Code, der eine einzelne Funktionsdefinition enthält. Beispiel: "Funktion (x, y) { x + y; }" zurückgeben
type	string: Microsoft.StreamAnalytics/JavascriptUdf	Gibt den Funktionsbindungstyp an.

JobStorageAccount

Objekt

Die Eigenschaften, die einem Azure Storage-Konto mit MSI zugeordnet sind

Name	Typ	Standardwert	Beschreibung
accountKey	string		Der Kontoschlüssel für das Azure Storage-Konto. Erforderlich für PUT-Anforderungen (CreateOrReplace).
accountName	string		Der Name des Azure Storage-Kontos. Erforderlich für PUT-Anforderungen (CreateOrReplace).
authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.

JobType

Enumeration

Beschreibt den Typ des Auftrags. Gültige Modi sind Cloud und "Edge".

Wert	Beschreibung
Cloud
Edge

JsonOutputSerializationFormat

Enumeration

Gibt das Format des JSON an, in dem die Ausgabe geschrieben wird. Die derzeit unterstützten Werte sind "lineSeparated", der angibt, dass die Ausgabe formatiert wird, indem jedes JSON-Objekt durch eine neue Zeile getrennt und "Array" angegeben wird, dass die Ausgabe als Array von JSON-Objekten formatiert wird.

Wert	Beschreibung
Array
LineSeparated

JsonSerialization

Objekt

Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im JSON-Format geschrieben werden.

Name	Typ	Beschreibung
properties.encoding	Encoding	Gibt die Codierung der eingehenden Daten im Falle der Eingabe und die Codierung ausgehender Daten im Falle der Ausgabe an. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Diese Eigenschaft gilt nur für die JSON-Serialisierung von Ausgaben. Es gilt nicht für Eingaben. Diese Eigenschaft gibt das Format des JSON an, in dem die Ausgabe geschrieben wird. Die derzeit unterstützten Werte sind "lineSeparated", der angibt, dass die Ausgabe formatiert wird, indem jedes JSON-Objekt durch eine neue Zeile getrennt und "Array" angegeben wird, dass die Ausgabe als Array von JSON-Objekten formatiert wird. Der Standardwert ist "lineSeparated", wenn links NULL ist.
type	string: Json	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Output

Objekt

Ein Ausgabeobjekt, das alle Informationen enthält, die der benannten Ausgabe zugeordnet sind. Alle Ausgaben sind unter einem Streamingauftrag enthalten.

Name	Typ	Beschreibung
id	string	Ressourcen-ID
name	string	Ressourcenname
properties.datasource	OutputDataSource: AzureDataLakeStoreOutputDataSource AzureFunctionOutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource AzureTableOutputDataSource BlobOutputDataSource DocumentDbOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource GatewayMessageBusOutputDataSource PowerBIOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource	Beschreibt die Datenquelle, in die die Ausgabe geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.diagnostics	Diagnostics	Beschreibt bedingungen, die für die Eingabe, Ausgabe oder den Auftrag insgesamt gelten, die die Aufmerksamkeit der Kunden garantieren.
properties.etag	string	Das aktuelle Entitätstag für die Ausgabe. Dies ist eine undurchsichtige Zeichenfolge. Sie können es verwenden, um zu erkennen, ob sich die Ressource zwischen Anforderungen geändert hat. Sie können sie auch in den If-Match- oder If-None-Match Headern für Schreibvorgänge für optimistische Parallelität verwenden.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe geschrieben werden. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.sizeWindow	integer (int32)	Das Größenfenster, auf das eine Stream Analytics-Ausgabe beschränkt werden soll.
properties.timeWindow	string	Der Zeitrahmen zum Filtern von Stream Analytics-Auftragsausgaben.
type	string	Ressourcentyp

OutputErrorPolicy

Enumeration

Gibt die Richtlinie an, die auf Ereignisse angewendet werden soll, die an der Ausgabe eingehen und aufgrund falscher Spaltenwerte, spaltenwerte falscher Typ oder Größe nicht in den externen Speicher geschrieben werden können.

Wert	Beschreibung
Drop
Stop

OutputStartMode

Enumeration

Der Wert kann JobStartTime, CustomTime oder LastOutputEventTime sein, um anzugeben, ob der Startpunkt des Ausgabeereignisdatenstroms gestartet werden soll, wenn der Auftrag gestartet wird, mit einem benutzerdefinierten Benutzerzeitstempel beginnen, der über die outputStartTime-Eigenschaft angegeben ist, oder von der letzten Ereignisausgabezeit beginnen soll.

Wert	Beschreibung
CustomTime
JobStartTime
LastOutputEventTime

ParquetSerialization

Objekt

Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im Parkettformat geschrieben werden.

Name	Typ	Beschreibung
type	string: Parquet	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

PowerBIOutputDataSource

Objekt

Beschreibt eine Power BI-Ausgabedatenquelle.

Name	Typ	Standardwert	Beschreibung
properties.authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.dataset	string		Der Name des Power BI-Datasets. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.groupId	string		Die ID der Power BI-Gruppe.
properties.groupName	string		Der Name der Power BI-Gruppe. Verwenden Sie diese Eigenschaft, um sich zu merken, welche bestimmte Power BI-Gruppen-ID verwendet wurde.
properties.refreshToken	string		Ein Aktualisierungstoken, das verwendet werden kann, um ein gültiges Zugriffstoken abzurufen, das dann zur Authentifizierung mit der Datenquelle verwendet werden kann. Ein gültiges Aktualisierungstoken kann derzeit nur über das Azure-Portal abgerufen werden. Es wird empfohlen, beim Erstellen der Datenquelle einen Dummy-Zeichenfolgenwert hier einzufügen und dann zum Azure-Portal zu wechseln, um die Datenquelle zu authentifizieren, die diese Eigenschaft mit einem gültigen Aktualisierungstoken aktualisiert. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.table	string		Der Name der Power BI-Tabelle unter dem angegebenen Dataset. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.tokenUserDisplayName	string		Der Anzeigename des Benutzers, der zum Abrufen des Aktualisierungstokens verwendet wurde. Verwenden Sie diese Eigenschaft, um sich zu merken, welcher Benutzer zum Abrufen des Aktualisierungstokens verwendet wurde.
properties.tokenUserPrincipalName	string		Der Benutzerprinzipalname (UPN) des Benutzers, der zum Abrufen des Aktualisierungstokens verwendet wurde. Verwenden Sie diese Eigenschaft, um sich zu merken, welcher Benutzer zum Abrufen des Aktualisierungstokens verwendet wurde.
type	string: PowerBI		Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

ReferenceInputProperties

Objekt

Die Eigenschaften, die einer Eingabe zugeordnet sind, die Referenzdaten enthält.

Name	Typ	Beschreibung
compression	Compression	Beschreibt, wie Eingabedaten komprimiert werden
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Beschreibt eine Eingabedatenquelle, die Referenzdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).
diagnostics	Diagnostics	Beschreibt bedingungen, die für die Eingabe, Ausgabe oder den Auftrag insgesamt gelten, die die Aufmerksamkeit der Kunden garantieren.
etag	string	Das aktuelle Entitätstag für die Eingabe. Dies ist eine undurchsichtige Zeichenfolge. Sie können es verwenden, um zu erkennen, ob sich die Ressource zwischen Anforderungen geändert hat. Sie können sie auch in den If-Match- oder If-None-Match Headern für Schreibvorgänge für optimistische Parallelität verwenden.
partitionKey	string	partitionKey Beschreibt einen Schlüssel in den Eingabedaten, die zum Partitionieren der Eingabedaten verwendet werden
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe geschrieben werden. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Reference	Gibt an, ob es sich bei der Eingabe um eine Quelle von Referenzdaten oder Datenstromdaten handelt. Erforderlich für PUT-Anforderungen (CreateOrReplace).

RefreshType

Enumeration

Gibt den Typ der Datenaktualisierungsoption an.

Wert	Beschreibung
RefreshPeriodicallyWithDelta
RefreshPeriodicallyWithFull
Static

ScalarFunctionProperties

Objekt

Die Eigenschaften, die einer skalaren Funktion zugeordnet sind.

Name	Typ	Beschreibung
etag	string	Das aktuelle Entitätstag für die Funktion. Dies ist eine undurchsichtige Zeichenfolge. Sie können es verwenden, um zu erkennen, ob sich die Ressource zwischen Anforderungen geändert hat. Sie können sie auch in den If-Match- oder If-None-Match Headern für Schreibvorgänge für optimistische Parallelität verwenden.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Die physische Bindung der Funktion. Beispielsweise beschreibt dies im Fall des Azure Machine Learning-Webdiensts den Endpunkt.
properties.inputs	FunctionInput[]	Beschreibt einen Eingabeparameter einer Funktion.
properties.output	FunctionOutput	Beschreibt die Ausgabe einer Funktion.
type	string: Scalar	Gibt den Funktionstyp an.

ServiceBusQueueOutputDataSource

Objekt

Beschreibt eine Ausgabedatenquelle der Servicebuswarteschlange.

Name	Typ	Standardwert	Beschreibung
properties.authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.propertyColumns	string[]		Ein Zeichenfolgenarray der Namen der Ausgabespalten, die als benutzerdefinierte Eigenschaften an Service Bus-Nachrichten angefügt werden sollen.
properties.queueName	string		Der Name der Servicebuswarteschlange. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.serviceBusNamespace	string		Der Namespace, der dem gewünschten Event Hub, Service Bus Queue, Service Bus Topic usw. zugeordnet ist. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Der Schlüssel für die gemeinsame Zugriffsrichtlinie für die angegebene Richtlinie für den freigegebenen Zugriff. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.sharedAccessPolicyName	string		Der Name der Richtlinie für den freigegebenen Zugriff für den Event Hub, service bus queue, Service Bus Topic usw. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.systemPropertyColumns	object		Die Systemeigenschaften, die der Servicebuswarteschlange zugeordnet sind. Die folgenden Systemeigenschaften werden unterstützt: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
type	string: Microsoft.ServiceBus/Queue		Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

ServiceBusTopicOutputDataSource

Objekt

Beschreibt eine Ausgabedatenquelle für Service Bus-Themen.

Name	Typ	Standardwert	Beschreibung
properties.authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.propertyColumns	string[]		Ein Zeichenfolgenarray der Namen der Ausgabespalten, die als benutzerdefinierte Eigenschaften an Service Bus-Nachrichten angefügt werden sollen.
properties.serviceBusNamespace	string		Der Namespace, der dem gewünschten Event Hub, Service Bus Queue, Service Bus Topic usw. zugeordnet ist. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Der Schlüssel für die gemeinsame Zugriffsrichtlinie für die angegebene Richtlinie für den freigegebenen Zugriff. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.sharedAccessPolicyName	string		Der Name der Richtlinie für den freigegebenen Zugriff für den Event Hub, service bus queue, Service Bus Topic usw. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.systemPropertyColumns	object		Die Systemeigenschaften, die der Service Bus Topic Output zugeordnet sind. Die folgenden Systemeigenschaften werden unterstützt: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
properties.topicName	string		Der Name des Servicebusthemas. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.ServiceBus/Topic		Gibt den Typ der Datenquellenausgabe an, in die geschrieben wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Sku

Objekt

Die Eigenschaften, die einer SKU zugeordnet sind.

Name	Typ	Beschreibung
name	SkuName	Der Name der SKU. Erforderlich für PUT-Anforderungen (CreateOrReplace).

SkuName

Enumeration

Der Name der SKU. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Wert	Beschreibung
Standard

StorageAccount

Objekt

Die Eigenschaften, die einem Azure Storage-Konto zugeordnet sind

Name	Typ	Beschreibung
accountKey	string	Der Kontoschlüssel für das Azure Storage-Konto. Erforderlich für PUT-Anforderungen (CreateOrReplace).
accountName	string	Der Name des Azure Storage-Kontos. Erforderlich für PUT-Anforderungen (CreateOrReplace).

StreamingJob

Objekt

Ein Streamingauftragsobjekt, das alle Informationen enthält, die dem benannten Streamingauftrag zugeordnet sind.

Name	Typ	Beschreibung
id	string	Vollqualifizierte Ressourcen-ID für die Ressource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Beschreibt die diesem Auftrag zugewiesene verwaltete Identität, die für die Authentifizierung mit Eingaben und Ausgaben verwendet werden kann.
location	string	Der geografische Standort, an dem sich die Ressource befindet
name	string	Der Name der Ressource
properties.cluster	ClusterInfo	Der Cluster, auf dem Streamingaufträge ausgeführt werden.
properties.compatibilityLevel	CompatibilityLevel	Steuert bestimmte Laufzeitverhalten des Streamingauftrags.
properties.contentStoragePolicy	ContentStoragePolicy	Gültige Werte sind JobStorageAccount und SystemAccount. Wenn dieser Wert auf "JobStorageAccount" festgelegt ist, muss der Benutzer auch die Eigenschaft "jobStorageAccount" angeben. .
properties.createdDate	string (date-time)	Der Wert ist ein ISO-8601-formatierter UTC-Zeitstempel, der angibt, wann der Streamingauftrag erstellt wurde.
properties.dataLocale	string	Das Datengebietsschema des Datenanalyseauftrags. Der Wert sollte der Name einer unterstützten .NET-Kultur aus dem set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspxsein. Wird standardmäßig auf 'en-US' festgelegt, wenn keine angegeben ist.
properties.etag	string	Das aktuelle Entitätstag für den Streamingauftrag. Dies ist eine undurchsichtige Zeichenfolge. Sie können es verwenden, um zu erkennen, ob sich die Ressource zwischen Anforderungen geändert hat. Sie können sie auch in den If-Match- oder If-None-Match Headern für Schreibvorgänge für optimistische Parallelität verwenden.
properties.eventsLateArrivalMaxDelayInSeconds	integer (int32)	Die maximale tolerierbare Verzögerung in Sekunden, bei der Ereignisse, die verspätet eintreffen, enthalten sein könnten. Der unterstützte Bereich wird auf 1814399 (20.23:59:59:59 Tage) -1, und -1 wird verwendet, um die Wartezeit auf unbestimmte Zeit anzugeben. Wenn die Eigenschaft nicht vorhanden ist, wird sie interpretiert, um einen Wert von -1 zu haben.
properties.eventsOutOfOrderMaxDelayInSeconds	integer (int32)	Die maximale tolerierbare Verzögerung in Sekunden, bei der Out-of-Order-Ereignisse angepasst werden können, um in der Reihenfolge wieder zu sein.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Gibt die Richtlinie an, die auf Ereignisse angewendet werden soll, die im Eingabeereignisdatenstrom außerhalb der Reihenfolge eingehen.
properties.functions	Function[]	Eine Liste mit einer oder mehreren Funktionen für den Streamingauftrag. Die Name-Eigenschaft für jede Funktion ist erforderlich, wenn Sie diese Eigenschaft in einer PUT-Anforderung angeben. Diese Eigenschaft kann nicht über einen PATCH-Vorgang geändert werden. Sie müssen die PATCH-API verwenden, die für die einzelne Transformation verfügbar ist.
properties.inputs	Input[]	Eine Liste mit mindestens einer Eingabe für den Streamingauftrag. Die Name-Eigenschaft für jede Eingabe ist erforderlich, wenn Sie diese Eigenschaft in einer PUT-Anforderung angeben. Diese Eigenschaft kann nicht über einen PATCH-Vorgang geändert werden. Sie müssen die PATCH-API verwenden, die für die einzelnen Eingaben verfügbar ist.
properties.jobId	string	Eine GUID, die den Streamingauftrag eindeutig identifiziert. Diese GUID wird beim Erstellen des Streamingauftrags generiert.
properties.jobState	string	Beschreibt den Status des Streamingauftrags.
properties.jobStorageAccount	JobStorageAccount	Die Eigenschaften, die einem Azure Storage-Konto mit MSI zugeordnet sind
properties.jobType	JobType	Beschreibt den Typ des Auftrags. Gültige Modi sind Cloud und "Edge".
properties.lastOutputEventTime	string (date-time)	Der Wert ist entweder ein ISO-8601-formatierter Zeitstempel, der die letzte Ausgabeereigniszeit des Streamingauftrags angibt, oder null, der angibt, dass die Ausgabe noch nicht erstellt wurde. Bei mehreren Ausgaben oder mehreren Datenströmen zeigt dies den neuesten Wert in diesem Satz an.
properties.outputErrorPolicy	OutputErrorPolicy	Gibt die Richtlinie an, die auf Ereignisse angewendet werden soll, die an der Ausgabe eingehen und aufgrund falscher Spaltenwerte, spaltenwerte falscher Typ oder Größe nicht in den externen Speicher geschrieben werden können.
properties.outputStartMode	OutputStartMode	Diese Eigenschaft sollte nur verwendet werden, wenn gewünscht wird, dass der Auftrag sofort beim Erstellen gestartet wird. Der Wert kann JobStartTime, CustomTime oder LastOutputEventTime sein, um anzugeben, ob der Startpunkt des Ausgabeereignisdatenstroms gestartet werden soll, wenn der Auftrag gestartet wird, mit einem benutzerdefinierten Benutzerzeitstempel beginnen, der über die outputStartTime-Eigenschaft angegeben ist, oder von der letzten Ereignisausgabezeit beginnen soll.
properties.outputStartTime	string (date-time)	Der Wert ist entweder ein formatierter ISO-8601-Zeitstempel, der den Startpunkt des Ausgabeereignisdatenstroms angibt, oder NULL, um anzugeben, dass der Ausgabeereignisdatenstrom bei jedem Start des Streamingauftrags gestartet wird. Diese Eigenschaft muss einen Wert aufweisen, wenn outputStartMode auf CustomTime festgelegt ist.
properties.outputs	Output[]	Eine Liste mit einer oder mehreren Ausgaben für den Streamingauftrag. Die Name-Eigenschaft für jede Ausgabe ist erforderlich, wenn Sie diese Eigenschaft in einer PUT-Anforderung angeben. Diese Eigenschaft kann nicht über einen PATCH-Vorgang geändert werden. Sie müssen die PATCH-API verwenden, die für die einzelne Ausgabe verfügbar ist.
properties.provisioningState	string	Beschreibt den Bereitstellungsstatus des Streamingauftrags.
properties.sku	Sku	Beschreibt die SKU des Streamingauftrags. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.transformation	Transformation	Gibt die Abfrage und die Anzahl der Streamingeinheiten an, die für den Streamingauftrag verwendet werden sollen. Die Namenseigenschaft der Transformation ist erforderlich, wenn Sie diese Eigenschaft in einer PUT-Anforderung angeben. Diese Eigenschaft kann nicht über einen PATCH-Vorgang geändert werden. Sie müssen die PATCH-API verwenden, die für die einzelne Transformation verfügbar ist.
tags	object	Ressourcentags.
type	string	Der Typ der Ressource. Ex- Microsoft.Compute/virtualMachines oder Microsoft.Storage/storageAccounts.

StreamInputProperties

Objekt

Die Eigenschaften, die einer Eingabe zugeordnet sind, die Datenstromdaten enthält.

Name	Typ	Beschreibung
compression	Compression	Beschreibt, wie Eingabedaten komprimiert werden
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Beschreibt eine Eingabedatenquelle, die Datenstrom enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).
diagnostics	Diagnostics	Beschreibt bedingungen, die für die Eingabe, Ausgabe oder den Auftrag insgesamt gelten, die die Aufmerksamkeit der Kunden garantieren.
etag	string	Das aktuelle Entitätstag für die Eingabe. Dies ist eine undurchsichtige Zeichenfolge. Sie können es verwenden, um zu erkennen, ob sich die Ressource zwischen Anforderungen geändert hat. Sie können sie auch in den If-Match- oder If-None-Match Headern für Schreibvorgänge für optimistische Parallelität verwenden.
partitionKey	string	partitionKey Beschreibt einen Schlüssel in den Eingabedaten, die zum Partitionieren der Eingabedaten verwendet werden
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe geschrieben werden. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Stream	Gibt an, ob es sich bei der Eingabe um eine Quelle von Referenzdaten oder Datenstromdaten handelt. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Transformation

Objekt

Ein Transformationsobjekt, das alle Informationen enthält, die der benannten Transformation zugeordnet sind. Alle Transformationen sind unter einem Streamingauftrag enthalten.

Name	Typ	Standardwert	Beschreibung
id	string		Ressourcen-ID
name	string		Ressourcenname
properties.etag	string		Das aktuelle Entitätstag für die Transformation. Dies ist eine undurchsichtige Zeichenfolge. Sie können es verwenden, um zu erkennen, ob sich die Ressource zwischen Anforderungen geändert hat. Sie können sie auch in den If-Match- oder If-None-Match Headern für Schreibvorgänge für optimistische Parallelität verwenden.
properties.query	string		Gibt die Abfrage an, die im Streamingauftrag ausgeführt wird. Weitere Informationen zur Stream Analytics Query Language (SAQL) finden Sie hier: https://msdn.microsoft.com/library/azure/dn834998 . Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.streamingUnits	integer (int32)	3	Gibt die Anzahl der Streamingeinheiten an, die der Streamingauftrag verwendet.
properties.validStreamingUnits	integer[] (int32)		Gibt die gültigen Streamingeinheiten an, auf die ein Streamingauftrag skaliert werden kann.
type	string		Ressourcentyp