Streaming Jobs - Create Or Replace

Usługa:

Stream Analytics

Wersja interfejsu API:

2020-03-01

Tworzy zadanie przesyłania strumieniowego lub zastępuje już istniejące zadanie przesyłania strumieniowego.

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

Parametry identyfikatora URI

Nazwa	W	Wymagane	Typ	Opis
jobName	path	True	string	Nazwa zadania przesyłania strumieniowego.
resourceGroupName	path	True	string	Nazwa grupy zasobów. W nazwie jest uwzględniana wielkość liter. Wzorzec wyrażenia regularnego: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	Identyfikator subskrypcji docelowej.
api-version	query	True	string	Wersja interfejsu API do użycia dla tej operacji.

Nagłówek żądania

Nazwa	Wymagane	Typ	Opis
If-Match		string	Element ETag zadania przesyłania strumieniowego. Pomiń tę wartość, aby zawsze zastąpić bieżący zestaw rekordów. Określ ostatnio widzianą wartość elementu ETag, aby zapobiec przypadkowemu zastępowaniu współbieżnych zmian.
If-None-Match		string	Ustaw wartość "*", aby zezwolić na utworzenie nowego zadania przesyłania strumieniowego, ale uniemożliwić aktualizowanie istniejącego zestawu rekordów. Inne wartości spowodują odpowiedź 412 Warunek wstępny Niepowodzenie.

Treść żądania

Nazwa	Typ	Opis
identity	Identity	Opisuje tożsamość zarządzaną przypisaną przez system przypisaną do tego zadania, która może służyć do uwierzytelniania przy użyciu danych wejściowych i wyjściowych.
location	string	Lokalizacja geograficzna, w której znajduje się zasób
properties.cluster	ClusterInfo	Klaster, na którym będą uruchamiane zadania przesyłania strumieniowego.
properties.compatibilityLevel	CompatibilityLevel	Steruje pewnymi zachowaniami środowiska uruchomieniowego zadania przesyłania strumieniowego.
properties.contentStoragePolicy	ContentStoragePolicy	Prawidłowe wartości to JobStorageAccount i SystemAccount. Jeśli jest ustawiona wartość JobStorageAccount, wymaga to również od użytkownika określenia właściwości jobStorageAccount. .
properties.dataLocale	string	Ustawienia regionalne danych zadania usługi Stream Analytics. Wartość powinna być nazwą obsługiwanej kultury .NET z zestawu https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Wartość domyślna to "en-US", jeśli nie określono żadnego.
properties.eventsLateArrivalMaxDelayInSeconds	integer	Maksymalne dopuszczalne opóźnienie w sekundach, w których mogą być uwzględniane zdarzenia przychodzące późno. Obsługiwany zakres to -1 do 1814399 (20.23:59:59 dni) i -1 służy do określania oczekiwania na czas nieokreślony. Jeśli właściwość jest nieobecna, jest interpretowana jako wartość -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	Maksymalne dopuszczalne opóźnienie w sekundach, w których zdarzenia poza kolejnością można dostosować, aby wrócić do kolejności.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Wskazuje zasady, które mają być stosowane do zdarzeń, które docierają z kolejności w strumieniu zdarzeń wejściowych.
properties.functions	Function[]	Lista co najmniej jednej funkcji zadania przesyłania strumieniowego. Właściwość name dla każdej funkcji jest wymagana podczas określania tej właściwości w żądaniu PUT. Tej właściwości nie można modyfikować za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych przekształceń.
properties.inputs	Input[]	Lista co najmniej jednego wejścia zadania przesyłania strumieniowego. Właściwość name dla każdego wejścia jest wymagana podczas określania tej właściwości w żądaniu PUT. Tej właściwości nie można modyfikować za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych danych wejściowych.
properties.jobStorageAccount	JobStorageAccount	Właściwości skojarzone z kontem usługi Azure Storage z tożsamością usługi zarządzanej
properties.jobType	JobType	Opisuje typ zadania. Prawidłowe tryby to Cloud i "Edge".
properties.outputErrorPolicy	OutputErrorPolicy	Wskazuje zasady, które mają być stosowane do zdarzeń, które docierają do danych wyjściowych i nie mogą być zapisywane w magazynie zewnętrznym z powodu nieprawidłowego utworzenia (brakujące wartości kolumn, wartości kolumn niewłaściwego typu lub rozmiaru).
properties.outputStartMode	OutputStartMode	Ta właściwość powinna być używana tylko wtedy, gdy jest to wymagane, aby zadanie zostało uruchomione natychmiast po utworzeniu. Wartością może być JobStartTime, CustomTime lub LastOutputEventTime, aby wskazać, czy punkt początkowy strumienia zdarzeń wyjściowych powinien rozpoczynać się za każdym razem, gdy zadanie jest uruchamiane, uruchamiać się przy użyciu niestandardowej sygnatury czasowej użytkownika określonej za pośrednictwem właściwości outputStartTime lub rozpoczynać się od ostatniego czasu wyjściowego zdarzenia.
properties.outputStartTime	string	Wartość to sformatowana sygnatura czasowa ISO-8601 wskazująca punkt początkowy strumienia zdarzeń wyjściowych lub wartość null wskazująca, że strumień zdarzeń wyjściowych zostanie uruchomiony przy każdym uruchomieniu zadania przesyłania strumieniowego. Ta właściwość musi mieć wartość, jeśli właściwość outputStartMode jest ustawiona na Wartość CustomTime.
properties.outputs	Output[]	Lista co najmniej jednego wyjścia zadania przesyłania strumieniowego. Właściwość name dla każdego danych wyjściowych jest wymagana podczas określania tej właściwości w żądaniu PUT. Tej właściwości nie można modyfikować za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych danych wyjściowych.
properties.sku	Sku	Opisuje jednostkę SKU zadania przesyłania strumieniowego. Wymagane w żądaniach PUT (CreateOrReplace).
properties.transformation	Transformation	Wskazuje zapytanie i liczbę jednostek przesyłania strumieniowego do użycia dla zadania przesyłania strumieniowego. Właściwość name przekształcenia jest wymagana podczas określania tej właściwości w żądaniu PUT. Tej właściwości nie można modyfikować za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych przekształceń.
tags	object	Tagi zasobów.

Odpowiedzi

Nazwa	Typ	Opis
200 OK	StreamingJob	Zadanie przesyłania strumieniowego zostało pomyślnie utworzone lub zastąpione. Nagłówki ETag: string
201 Created	StreamingJob	Zadanie przesyłania strumieniowego zostało pomyślnie utworzone lub zastąpione. Nagłówki ETag: string
Other Status Codes	Error	Błąd.

Zabezpieczenia

azure_auth

Przepływ OAuth2 usługi Azure Active Directory

Typ: oauth2
Flow: implicit
Adres URL autoryzacji: https://login.microsoftonline.com/common/oauth2/authorize

Zakresy

Nazwa	Opis
user_impersonation	personifikacja konta użytkownika

Przykłady

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)

Przykładowe żądanie

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

Przykładowa odpowiedź

Kod stanu:

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

Kod stanu:

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)

Przykładowe żądanie

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

Przykładowa odpowiedź

Kod stanu:

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

Kod stanu:

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

Definicje

Nazwa	Opis
AggregateFunctionProperties	Właściwości skojarzone z funkcją agregacji.
AuthenticationMode	Tryb uwierzytelniania. Prawidłowe tryby to ConnectionString, Msi i "UserToken".
AvroSerialization	Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie Avro.
AzureDataLakeStoreOutputDataSource	Opisuje wyjściowe źródło danych usługi Azure Data Lake Store.
AzureFunctionOutputDataSource	Definiuje metadane elementu AzureFunctionOutputDataSource
AzureMachineLearningWebServiceFunctionBinding	Powiązanie z usługą internetową Azure Machine Learning.
AzureMachineLearningWebServiceInputColumn	Opisuje kolumnę wejściową dla punktu końcowego usługi internetowej Azure Machine Learning.
AzureMachineLearningWebServiceInputs	Dane wejściowe punktu końcowego usługi internetowej Azure Machine Learning.
AzureMachineLearningWebServiceOutputColumn	Opisuje kolumnę wyjściową punktu końcowego usługi internetowej Azure Machine Learning.
AzureSqlDatabaseOutputDataSource	Opisuje źródło danych wyjściowych bazy danych Azure SQL.
AzureSqlReferenceInputDataSource	Opisuje Azure SQL źródło danych wejściowych referencyjnych bazy danych.
AzureSynapseOutputDataSource	Opisuje Azure Synapse wyjściowe źródło danych.
AzureTableOutputDataSource	Opisuje źródło danych wyjściowych tabeli platformy Azure.
BlobOutputDataSource	Opisuje źródło danych wyjściowych obiektu blob.
BlobReferenceInputDataSource	Opisuje źródło danych wejściowych obiektów blob, które zawiera dane referencyjne.
BlobStreamInputDataSource	Opisuje źródło danych wejściowych obiektów blob, które zawiera dane strumienia.
ClusterInfo	Właściwości skojarzone z klastrem usługi Stream Analytics.
CompatibilityLevel	Steruje pewnymi zachowaniami środowiska uruchomieniowego zadania przesyłania strumieniowego.
Compression	Opisuje sposób kompresji danych wejściowych
CompressionType	Wskazuje typ kompresji używanej przez dane wejściowe. Wymagane w żądaniach PUT (CreateOrReplace).
ContentStoragePolicy	Prawidłowe wartości to JobStorageAccount i SystemAccount. Jeśli ustawiono wartość JobStorageAccount, wymaga to również od użytkownika określenia właściwości jobStorageAccount. .
CsvSerialization	Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie CSV.
DiagnosticCondition	Warunek mający zastosowanie do zasobu lub ogólnego zadania, który gwarantuje uwagę klienta.
Diagnostics	Opisuje warunki dotyczące danych wejściowych, wyjściowych lub ogólnego zadania, które uzasadniają uwagę klienta.
DocumentDbOutputDataSource	Opisuje źródło danych wyjściowych usługi DocumentDB.
Encoding	Określa kodowanie danych przychodzących w przypadku danych wejściowych i kodowania danych wychodzących w przypadku danych wyjściowych.
Error	Typowa reprezentacja błędów.
EventHubOutputDataSource	Opisuje źródło danych wyjściowych centrum zdarzeń.
EventHubStreamInputDataSource	Opisuje źródło danych wejściowych centrum zdarzeń, które zawiera dane strumienia.
EventHubV2OutputDataSource	Opisuje źródło danych wyjściowych centrum zdarzeń.
EventHubV2StreamInputDataSource	Opisuje źródło danych wejściowych centrum zdarzeń, które zawiera dane strumienia.
EventSerializationType	Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
EventsOutOfOrderPolicy	Wskazuje zasady, które mają być stosowane do zdarzeń, które docierają z kolejności w strumieniu zdarzeń wejściowych.
FileReferenceInputDataSource	Opisuje wejściowe źródło danych pliku zawierające dane referencyjne.
Function	Obiekt funkcji zawierający wszystkie informacje skojarzone z nazwaną funkcją. Wszystkie funkcje są zawarte w zadaniu przesyłania strumieniowego.
FunctionInput	Opisuje jeden parametr wejściowy funkcji.
FunctionOutput	Opisuje dane wyjściowe funkcji.
GatewayMessageBusOutputDataSource	Opisuje źródło danych wyjściowych magistrali komunikatów bramy.
GatewayMessageBusStreamInputDataSource	Opisuje źródło danych wejściowych obiektów blob, które zawiera dane strumienia.
Identity	Opisuje sposób weryfikowania tożsamości
Input	Obiekt wejściowy zawierający wszystkie informacje skojarzone z nazwanymi danymi wejściowymi. Wszystkie dane wejściowe znajdują się w zadaniu przesyłania strumieniowego.
IoTHubStreamInputDataSource	Opisuje IoT Hub wejściowe źródło danych zawierające dane strumienia.
JavaScriptFunctionBinding	Powiązanie z funkcją Języka JavaScript.
JobStorageAccount	Właściwości skojarzone z kontem usługi Azure Storage z usługą MSI
JobType	Opisuje typ zadania. Prawidłowe tryby to Cloud i "Edge".
JsonOutputSerializationFormat	Określa format kodu JSON, w który będą zapisywane dane wyjściowe. Obecnie obsługiwane wartości to "lineSeparated", co wskazuje, że dane wyjściowe będą formatowane przez każdy obiekt JSON oddzielony przez nowy wiersz i "tablicę", co wskazuje, że dane wyjściowe zostaną sformatowane jako tablica obiektów JSON.
JsonSerialization	Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie JSON.
Output	Obiekt wyjściowy zawierający wszystkie informacje skojarzone z nazwanymi danymi wyjściowymi. Wszystkie dane wyjściowe są zawarte w zadaniu przesyłania strumieniowego.
OutputErrorPolicy	Wskazuje zasady dotyczące stosowania do zdarzeń, które docierają do danych wyjściowych i nie mogą być zapisywane w magazynie zewnętrznym z powodu niewłaściwego utworzenia (brakujące wartości kolumn, wartości kolumn niewłaściwego typu lub rozmiaru).
OutputStartMode	Wartość może być JobStartTime, CustomTime lub LastOutputEventTime, aby wskazać, czy punkt początkowy strumienia zdarzeń wyjściowych powinien rozpoczynać się za każdym razem, gdy zadanie jest uruchamiane, rozpoczynać się od niestandardowego sygnatury czasowej użytkownika określonej za pośrednictwem właściwości outputStartTime lub rozpoczynać się od ostatniego czasu wyjściowego zdarzenia.
ParquetSerialization	Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie Parquet.
PowerBIOutputDataSource	Opisuje źródło danych wyjściowych usługi Power BI.
ReferenceInputProperties	Właściwości skojarzone z danymi wejściowymi zawierającymi dane referencyjne.
RefreshType	Wskazuje typ opcji odświeżania danych.
ScalarFunctionProperties	Właściwości skojarzone z funkcją skalarną.
ServiceBusQueueOutputDataSource	Opisuje źródło danych wyjściowych kolejki usługi Service Bus.
ServiceBusTopicOutputDataSource	Opisuje źródło danych wyjściowych tematu usługi Service Bus.
Sku	Właściwości skojarzone z jednostkami SKU.
SkuName	Nazwa jednostki SKU. Wymagane w żądaniach PUT (CreateOrReplace).
StorageAccount	Właściwości skojarzone z kontem usługi Azure Storage
StreamingJob	Obiekt zadania przesyłania strumieniowego zawierający wszystkie informacje skojarzone z nazwanym zadaniem przesyłania strumieniowego.
StreamInputProperties	Właściwości skojarzone z danymi wejściowymi zawierającymi dane strumienia.
Transformation	Obiekt przekształcania zawierający wszystkie informacje skojarzone z nazwaną transformacją. Wszystkie przekształcenia są zawarte w zadaniu przesyłania strumieniowego.

AggregateFunctionProperties

Właściwości skojarzone z funkcją agregacji.

Nazwa	Typ	Opis
etag	string	Bieżący tag jednostki dla funkcji. Jest to nieprzezroczystych ciągów. Można go użyć do wykrywania, czy zasób zmienił się między żądaniami. Można go również używać w nagłówkach If-Match lub If-None-Match na potrzeby operacji zapisu w celu optymistycznej współbieżności.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Fizyczne powiązanie funkcji. Na przykład w przypadku usługi internetowej Azure Machine Learning opisano punkt końcowy.
properties.inputs	FunctionInput[]	Opisuje jeden parametr wejściowy funkcji.
properties.output	FunctionOutput	Opisuje dane wyjściowe funkcji.
type	string: Aggregate	Wskazuje typ funkcji.

AuthenticationMode

Tryb uwierzytelniania. Prawidłowe tryby to ConnectionString, Msi i "UserToken".

Nazwa	Typ	Opis
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie Avro.

Nazwa	Typ	Opis
type	string: Avro	Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Opisuje wyjściowe źródło danych usługi Azure Data Lake Store.

Nazwa	Typ	Domyślna wartość	Opis
properties.accountName	string		Nazwa konta usługi Azure Data Lake Store. Wymagane w żądaniach PUT (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.dateFormat	string		Format daty. Gdziekolwiek {date} pojawia się w filePathPrefix, wartość tej właściwości jest używana jako format daty.
properties.filePathPrefix	string		Lokalizacja pliku, do którego powinny zostać zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
properties.refreshToken	string		Token odświeżania, którego można użyć do uzyskania prawidłowego tokenu dostępu, którego następnie można użyć do uwierzytelniania w źródle danych. Prawidłowy token odświeżania można obecnie uzyskać tylko za pośrednictwem witryny Azure Portal. Zaleca się umieszczenie w tym miejscu fikcyjnej wartości ciągu podczas tworzenia źródła danych, a następnie przejście do witryny Azure Portal w celu uwierzytelnienia źródła danych, które zaktualizuje tę właściwość przy użyciu prawidłowego tokenu odświeżania. Wymagane w żądaniach PUT (CreateOrReplace).
properties.tenantId	string		Identyfikator dzierżawy użytkownika używany do uzyskiwania tokenu odświeżania. Wymagane w żądaniach PUT (CreateOrReplace).
properties.timeFormat	string		Format godziny. Gdziekolwiek {time} pojawia się w filePathPrefix, wartość tej właściwości jest używana jako format czasu.
properties.tokenUserDisplayName	string		Nazwa wyświetlana użytkownika, który został użyty do uzyskania tokenu odświeżania. Użyj tej właściwości, aby zapamiętać, którego użytkownika użyto do uzyskania tokenu odświeżania.
properties.tokenUserPrincipalName	string		Główna nazwa użytkownika (UPN) użytkownika, który został użyty do uzyskania tokenu odświeżania. Użyj tej właściwości, aby zapamiętać, którego użytkownika użyto do uzyskania tokenu odświeżania.
type	string: Microsoft.DataLake/Accounts		Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

AzureFunctionOutputDataSource

Definiuje metadane elementu AzureFunctionOutputDataSource

Nazwa	Typ	Opis
properties.apiKey	string	Jeśli chcesz użyć funkcji platformy Azure z innej subskrypcji, możesz to zrobić, podając klucz umożliwiający dostęp do funkcji.
properties.functionAppName	string	Nazwa aplikacji Azure Functions.
properties.functionName	string	Nazwa funkcji w aplikacji Azure Functions.
properties.maxBatchCount	number	Właściwość, która umożliwia określenie maksymalnej liczby zdarzeń w każdej partii wysyłanej do Azure Functions. Wartość domyślna to 100.
properties.maxBatchSize	number	Właściwość, która umożliwia ustawienie maksymalnego rozmiaru dla każdej partii wyjściowej wysyłanej do funkcji platformy Azure. Jednostka wejściowa jest w bajtach. Domyślnie ta wartość to 262 144 bajtów (256 KB).
type	string: Microsoft.AzureFunction	Wskazuje typ danych wyjściowych źródła danych, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

Powiązanie z usługą internetową Azure Machine Learning.

Nazwa	Typ	Opis
properties.apiKey	string	Klucz interfejsu API używany do uwierzytelniania za pomocą punktu końcowego Request-Response.
properties.batchSize	integer	Liczba z zakresu od 1 do 10000 opisujących maksymalną liczbę wierszy dla każdego żądania wykonania usługi Azure ML RRS. Wartość domyślna to 1000.
properties.endpoint	string	Request-Response wykonać punkt końcowy usługi internetowej Azure Machine Learning. Dowiedz się więcej tutaj: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
properties.inputs	AzureMachineLearningWebServiceInputs	Dane wejściowe punktu końcowego usługi internetowej Azure Machine Learning.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Lista danych wyjściowych z wykonywania punktu końcowego usługi internetowej Azure Machine Learning.
type	string: Microsoft.MachineLearning/WebService	Wskazuje typ powiązania funkcji.

AzureMachineLearningWebServiceInputColumn

Opisuje kolumnę wejściową dla punktu końcowego usługi internetowej Azure Machine Learning.

Nazwa	Typ	Opis
dataType	string	Typ danych (obsługiwany przez usługę Azure Machine Learning) kolumny wejściowej. Lista prawidłowych typów danych usługi Azure Machine Learning jest opisana w temacie https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
mapTo	integer	Zerowy indeks parametru funkcji, do których jest mapowane dane wejściowe.
name	string	Nazwa kolumny wejściowej.

AzureMachineLearningWebServiceInputs

Dane wejściowe punktu końcowego usługi internetowej Azure Machine Learning.

Nazwa	Typ	Opis
columnNames	AzureMachineLearningWebServiceInputColumn[]	Lista kolumn wejściowych dla punktu końcowego usługi internetowej Azure Machine Learning.
name	string	Nazwa danych wejściowych. Jest to nazwa podana podczas tworzenia punktu końcowego.

AzureMachineLearningWebServiceOutputColumn

Opisuje kolumnę wyjściową punktu końcowego usługi internetowej Azure Machine Learning.

Nazwa	Typ	Opis
dataType	string	Typ danych (obsługiwany przez usługę Azure Machine Learning) kolumny wyjściowej. Lista prawidłowych typów danych usługi Azure Machine Learning jest opisana w temacie https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
name	string	Nazwa kolumny wyjściowej.

AzureSqlDatabaseOutputDataSource

Opisuje źródło danych wyjściowych bazy danych Azure SQL.

Nazwa	Typ	Domyślna wartość	Opis
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.database	string		Nazwa bazy danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
properties.maxBatchCount	number		Maksymalna liczba partii zapisu w bazie danych Sql, wartość domyślna to 10 000. Opcjonalnie w żądaniach PUT.
properties.maxWriterCount	number		Maksymalna liczba składników zapisywania, obecnie dostępne są tylko 1(pojedynczy moduł zapisywania) i 0 (na podstawie partycji zapytania). Opcjonalnie w żądaniach PUT.
properties.password	string		Hasło, które będzie używane do nawiązywania połączenia z bazą danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
properties.server	string		Nazwa serwera SQL zawierającego bazę danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
properties.table	string		Nazwa tabeli w bazie danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
properties.user	string		Nazwa użytkownika, która będzie używana do nawiązywania połączenia z bazą danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/Database		Wskazuje typ danych wyjściowych źródła danych, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Opisuje Azure SQL źródło danych wejściowych referencyjnych bazy danych.

Nazwa	Typ	Opis
properties.database	string	Ten element jest skojarzony z elementem źródła danych. Jest to nazwa bazy danych, do których zostaną zapisane dane wyjściowe.
properties.deltaSnapshotQuery	string	Ten element jest skojarzony z elementem źródła danych. To zapytanie służy do pobierania przyrostowych zmian z bazy danych SQL. Aby użyć tej opcji, zalecamy używanie tabel czasowych w usłudze Azure SQL Database.
properties.fullSnapshotQuery	string	Ten element jest skojarzony z elementem źródła danych. To zapytanie służy do pobierania danych z bazy danych SQL.
properties.password	string	Ten element jest skojarzony z elementem źródła danych. Jest to hasło, które będzie używane do nawiązywania połączenia z wystąpieniem SQL Database.
properties.refreshRate	string	Ten element jest skojarzony z elementem źródła danych. Wskazuje to, jak często dane będą pobierane z bazy danych. Jest to format DateTime.
properties.refreshType	RefreshType	Wskazuje typ opcji odświeżania danych.
properties.server	string	Ten element jest skojarzony z elementem źródła danych. Jest to nazwa serwera, który zawiera bazę danych, do którego zostanie zapisana.
properties.table	string	Ten element jest skojarzony z elementem źródła danych. Nazwa tabeli w bazie danych Azure SQL.
properties.user	string	Ten element jest skojarzony z elementem źródła danych. Jest to nazwa użytkownika, która będzie używana do nawiązywania połączenia z wystąpieniem SQL Database.
type	string: Microsoft.Sql/Server/Database	Wskazuje typ wejściowego źródła danych zawierającego dane referencyjne. Wymagane w żądaniach PUT (CreateOrReplace).

AzureSynapseOutputDataSource

Opisuje Azure Synapse wyjściowe źródło danych.

Nazwa	Typ	Opis
properties.database	string	Nazwa bazy danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
properties.password	string	Hasło, które będzie używane do nawiązywania połączenia z bazą danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
properties.server	string	Nazwa serwera SQL zawierającego bazę danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
properties.table	string	Nazwa tabeli w bazie danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
properties.user	string	Nazwa użytkownika, która będzie używana do nawiązywania połączenia z bazą danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/DataWarehouse	Wskazuje typ danych wyjściowych źródła danych, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

AzureTableOutputDataSource

Opisuje źródło danych wyjściowych tabeli platformy Azure.

Nazwa	Typ	Opis
properties.accountKey	string	Klucz konta dla konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
properties.accountName	string	Nazwa konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
properties.batchSize	integer	Liczba wierszy do zapisu w tabeli platformy Azure naraz.
properties.columnsToRemove	string[]	Jeśli zostanie określony, każdy element w tablicy jest nazwą kolumny do usunięcia (jeśli istnieje) z jednostek zdarzeń wyjściowych.
properties.partitionKey	string	Ten element wskazuje nazwę kolumny z instrukcji SELECT w zapytaniu, które będzie używane jako klucz partycji dla tabeli platformy Azure. Wymagane w żądaniach PUT (CreateOrReplace).
properties.rowKey	string	Ten element wskazuje nazwę kolumny z instrukcji SELECT w zapytaniu, które będzie używane jako klucz wiersza dla tabeli platformy Azure. Wymagane w żądaniach PUT (CreateOrReplace).
properties.table	string	Nazwa tabeli platformy Azure. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Microsoft.Storage/Table	Wskazuje typ danych wyjściowych źródła danych, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

BlobOutputDataSource

Opisuje źródło danych wyjściowych obiektu blob.

Nazwa	Typ	Domyślna wartość	Opis
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.blobPathPrefix	string		Prefiks ścieżki obiektu blob.
properties.container	string		Nazwa kontenera w skojarzonym koncie magazynu. Ten kontener zawiera obiekty blob do odczytu lub zapisu. Wymagane w żądaniach PUT (CreateOrReplace).
properties.dateFormat	string		Format daty. Gdziekolwiek {date} pojawia się w ścieżcePattern, wartość tej właściwości jest używana jako format daty.
properties.pathPattern	string		Wzorzec ścieżki obiektu blob. Nie jest wyrażeniem regularnym. Reprezentuje on wzorzec, dla którego nazwy obiektów blob będą dopasowywane w celu określenia, czy powinny być uwzględniane jako dane wejściowe lub wyjściowe zadania. Zobacz https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input lub https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output , aby uzyskać bardziej szczegółowe wyjaśnienie i przykład.
properties.storageAccounts	StorageAccount[]		Lista co najmniej jednego konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
properties.timeFormat	string		Format czasu. Gdziekolwiek {time} pojawia się w ścieżcePattern, wartość tej właściwości jest używana jako format czasu.
type	string: Microsoft.Storage/Blob		Wskazuje typ danych wyjściowych źródła danych, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

BlobReferenceInputDataSource

Opisuje źródło danych wejściowych obiektów blob, które zawiera dane referencyjne.

Nazwa	Typ	Domyślna wartość	Opis
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.container	string		Nazwa kontenera w skojarzonym koncie magazynu. Ten kontener zawiera obiekty blob do odczytu lub zapisu. Wymagane w żądaniach PUT (CreateOrReplace).
properties.dateFormat	string		Format daty. Gdziekolwiek {date} pojawia się w pathPattern, wartość tej właściwości jest używana jako format daty.
properties.pathPattern	string		Wzorzec ścieżki obiektu blob. Nie jest wyrażeniem regularnym. Reprezentuje on wzorzec, dla którego nazwy obiektów blob będą dopasowywane w celu określenia, czy powinny być uwzględniane jako dane wejściowe lub wyjściowe zadania. Zobacz https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input lub https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output , aby uzyskać bardziej szczegółowe wyjaśnienie i przykład.
properties.storageAccounts	StorageAccount[]		Lista co najmniej jednego konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
properties.timeFormat	string		Format godziny. Gdziekolwiek {time} pojawia się w pathPattern, wartość tej właściwości jest używana jako format czasu.
type	string: Microsoft.Storage/Blob		Wskazuje typ wejściowego źródła danych zawierającego dane referencyjne. Wymagane w żądaniach PUT (CreateOrReplace).

BlobStreamInputDataSource

Opisuje źródło danych wejściowych obiektów blob, które zawiera dane strumienia.

Nazwa	Typ	Domyślna wartość	Opis
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.container	string		Nazwa kontenera w skojarzonym koncie magazynu. Ten kontener zawiera obiekty blob do odczytu lub zapisu. Wymagane w żądaniach PUT (CreateOrReplace).
properties.dateFormat	string		Format daty. Gdziekolwiek {date} pojawia się w ścieżcePattern, wartość tej właściwości jest używana jako format daty.
properties.pathPattern	string		Wzorzec ścieżki obiektu blob. Nie jest wyrażeniem regularnym. Reprezentuje on wzorzec, dla którego nazwy obiektów blob będą dopasowywane w celu określenia, czy powinny być uwzględniane jako dane wejściowe lub wyjściowe zadania. Zobacz https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input lub https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output , aby uzyskać bardziej szczegółowe wyjaśnienie i przykład.
properties.sourcePartitionCount	integer		Liczba partycji źródła danych wejściowych obiektu blob. Zakres 1 – 1024.
properties.storageAccounts	StorageAccount[]		Lista co najmniej jednego konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
properties.timeFormat	string		Format czasu. Gdziekolwiek {time} pojawia się w ścieżcePattern, wartość tej właściwości jest używana jako format czasu.
type	string: Microsoft.Storage/Blob		Wskazuje typ wejściowego źródła danych zawierającego dane strumienia. Wymagane w żądaniach PUT (CreateOrReplace).

ClusterInfo

Właściwości skojarzone z klastrem usługi Stream Analytics.

Nazwa	Typ	Opis
id	string	Identyfikator zasobu klastra.

CompatibilityLevel

Steruje pewnymi zachowaniami środowiska uruchomieniowego zadania przesyłania strumieniowego.

Nazwa	Typ	Opis
1.0	string
1.2	string

Compression

Opisuje sposób kompresji danych wejściowych

Nazwa	Typ	Domyślna wartość	Opis
type	CompressionType	None	Wskazuje typ kompresji używanej przez dane wejściowe. Wymagane w żądaniach PUT (CreateOrReplace).

CompressionType

Wskazuje typ kompresji używanej przez dane wejściowe. Wymagane w żądaniach PUT (CreateOrReplace).

Nazwa	Typ	Opis
Deflate	string
GZip	string
None	string

ContentStoragePolicy

Prawidłowe wartości to JobStorageAccount i SystemAccount. Jeśli ustawiono wartość JobStorageAccount, wymaga to również od użytkownika określenia właściwości jobStorageAccount. .

Nazwa	Typ	Opis
JobStorageAccount	string
SystemAccount	string

CsvSerialization

Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie CSV.

Nazwa	Typ	Opis
properties.encoding	Encoding	Określa kodowanie danych przychodzących w przypadku danych wejściowych i kodowanie danych wychodzących w przypadku danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
properties.fieldDelimiter	string	Określa ogranicznik, który będzie używany do oddzielania rekordów wartości rozdzielanych przecinkami (CSV). Zobacz https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input lub https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output , aby uzyskać listę obsługiwanych wartości. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Csv	Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

DiagnosticCondition

Warunek mający zastosowanie do zasobu lub ogólnego zadania, który gwarantuje uwagę klienta.

Nazwa	Typ	Opis
code	string	Nieprzezroczysty kod diagnostyczny.
message	string	Czytelny dla człowieka komunikat opisujący szczegółowo warunek. Zlokalizowane w Accept-Language żądania klienta.
since	string	Sygnatura czasowa UTC rozpoczęcia warunku. Klienci powinni mieć możliwość znalezienia odpowiedniego zdarzenia w dzienniku operacji w tym czasie.

Diagnostics

Opisuje warunki dotyczące danych wejściowych, wyjściowych lub ogólnego zadania, które uzasadniają uwagę klienta.

Nazwa	Typ	Opis
conditions	DiagnosticCondition[]	Kolekcja zera lub większej liczby warunków mających zastosowanie do zasobu lub zadania ogólnego, które uzasadniają uwagę klienta.

DocumentDbOutputDataSource

Opisuje źródło danych wyjściowych usługi DocumentDB.

Nazwa	Typ	Opis
properties.accountId	string	Nazwa lub identyfikator konta usługi DocumentDB. Wymagane w żądaniach PUT (CreateOrReplace).
properties.accountKey	string	Klucz konta dla konta usługi DocumentDB. Wymagane w żądaniach PUT (CreateOrReplace).
properties.collectionNamePattern	string	Wzorzec nazwy kolekcji do użycia. Format nazwy kolekcji można skonstruować przy użyciu opcjonalnego tokenu {partition}, w którym partycje zaczynają się od 0. Aby uzyskać więcej informacji, zobacz sekcję https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output usługi DocumentDB. Wymagane w żądaniach PUT (CreateOrReplace).
properties.database	string	Nazwa bazy danych DocumentDB. Wymagane w żądaniach PUT (CreateOrReplace).
properties.documentId	string	Nazwa pola w zdarzeniach wyjściowych używanych do określenia klucza podstawowego, na którym opierają się operacje wstawiania lub aktualizowania.
properties.partitionKey	string	Nazwa pola w zdarzeniach wyjściowych używanych do określania klucza do partycjonowania danych wyjściowych w kolekcjach. Jeśli element "collectionNamePattern" zawiera token {partition}, ta właściwość jest wymagana do określenia.
type	string: Microsoft.Storage/DocumentDB	Wskazuje typ danych wyjściowych źródła danych, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

Encoding

Określa kodowanie danych przychodzących w przypadku danych wejściowych i kodowania danych wychodzących w przypadku danych wyjściowych.

Nazwa	Typ	Opis
UTF8	string

Error

Typowa reprezentacja błędów.

Nazwa	Typ	Opis
error	Error	Właściwości definicji błędu.

EventHubOutputDataSource

Opisuje źródło danych wyjściowych centrum zdarzeń.

Nazwa	Typ	Domyślna wartość	Opis
authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.eventHubName	string		Nazwa centrum zdarzeń. Wymagane w żądaniach PUT (CreateOrReplace).
properties.partitionKey	string		Klucz/kolumna, która służy do określania, która partycja ma wysyłać dane zdarzenia.
properties.propertyColumns	string[]		Właściwości skojarzone z danymi wyjściowymi tego centrum zdarzeń.
serviceBusNamespace	string		Przestrzeń nazw skojarzona z żądanym centrum zdarzeń, kolejką usługi Service Bus, tematem usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nazwa zasad dostępu współdzielonego dla centrum zdarzeń, kolejki usługi Service Bus, tematu usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Wskazuje typ danych wyjściowych źródła danych, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

EventHubStreamInputDataSource

Opisuje źródło danych wejściowych centrum zdarzeń, które zawiera dane strumienia.

Nazwa	Typ	Domyślna wartość	Opis
authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.consumerGroupName	string		Nazwa grupy odbiorców centrum zdarzeń, która powinna służyć do odczytywania zdarzeń z centrum zdarzeń. Określanie odrębnych nazw grup odbiorców dla wielu danych wejściowych umożliwia każdemu z tych danych wejściowych odbieranie tych samych zdarzeń z centrum zdarzeń. Jeśli nie zostanie określona, dane wejściowe używają domyślnej grupy odbiorców centrum zdarzeń.
properties.eventHubName	string		Nazwa centrum zdarzeń. Wymagane w żądaniach PUT (CreateOrReplace).
serviceBusNamespace	string		Przestrzeń nazw skojarzona z żądanym centrum zdarzeń, kolejką usługi Service Bus, tematem usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nazwa zasad dostępu współdzielonego dla centrum zdarzeń, kolejki usługi Service Bus, tematu usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Wskazuje typ wejściowego źródła danych zawierającego dane strumienia. Wymagane w żądaniach PUT (CreateOrReplace).

EventHubV2OutputDataSource

Opisuje źródło danych wyjściowych centrum zdarzeń.

Nazwa	Typ	Domyślna wartość	Opis
authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.eventHubName	string		Nazwa centrum zdarzeń. Wymagane w żądaniach PUT (CreateOrReplace).
properties.partitionKey	string		Klucz/kolumna, która służy do określania, która partycja ma wysyłać dane zdarzenia.
properties.propertyColumns	string[]		Właściwości skojarzone z danymi wyjściowymi tego centrum zdarzeń.
serviceBusNamespace	string		Przestrzeń nazw skojarzona z żądanym centrum zdarzeń, kolejką usługi Service Bus, tematem usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nazwa zasad dostępu współdzielonego dla centrum zdarzeń, kolejki usługi Service Bus, tematu usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Wskazuje typ danych wyjściowych źródła danych, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Opisuje źródło danych wejściowych centrum zdarzeń, które zawiera dane strumienia.

Nazwa	Typ	Domyślna wartość	Opis
authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.consumerGroupName	string		Nazwa grupy odbiorców centrum zdarzeń, która powinna służyć do odczytywania zdarzeń z centrum zdarzeń. Określanie odrębnych nazw grup odbiorców dla wielu danych wejściowych umożliwia każdemu z tych danych wejściowych odbieranie tych samych zdarzeń z centrum zdarzeń. Jeśli nie zostanie określona, dane wejściowe używają domyślnej grupy odbiorców centrum zdarzeń.
properties.eventHubName	string		Nazwa centrum zdarzeń. Wymagane w żądaniach PUT (CreateOrReplace).
serviceBusNamespace	string		Przestrzeń nazw skojarzona z żądanym centrum zdarzeń, kolejką usługi Service Bus, tematem usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nazwa zasad dostępu współdzielonego dla centrum zdarzeń, kolejki usługi Service Bus, tematu usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Wskazuje typ wejściowego źródła danych zawierającego dane strumienia. Wymagane w żądaniach PUT (CreateOrReplace).

EventSerializationType

Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

Nazwa	Typ	Opis
Avro	string
Csv	string
Json	string
Parquet	string

EventsOutOfOrderPolicy

Wskazuje zasady, które mają być stosowane do zdarzeń, które docierają z kolejności w strumieniu zdarzeń wejściowych.

Nazwa	Typ	Opis
Adjust	string
Drop	string

FileReferenceInputDataSource

Opisuje wejściowe źródło danych pliku zawierające dane referencyjne.

Nazwa	Typ	Opis
properties.path	string	Ścieżka pliku.
type	string: File	Wskazuje typ wejściowego źródła danych zawierającego dane referencyjne. Wymagane w żądaniach PUT (CreateOrReplace).

Function

Obiekt funkcji zawierający wszystkie informacje skojarzone z nazwaną funkcją. Wszystkie funkcje są zawarte w zadaniu przesyłania strumieniowego.

Nazwa	Typ	Opis
id	string	Identyfikator zasobu
name	string	Nazwa zasobu
properties	FunctionProperties: AggregateFunctionProperties ScalarFunctionProperties	Właściwości skojarzone z funkcją.
type	string	Typ zasobu

FunctionInput

Opisuje jeden parametr wejściowy funkcji.

Nazwa	Typ	Opis
dataType	string	Typ danych (obsługiwany przez usługę Azure Stream Analytics) parametru wejściowego funkcji. Lista prawidłowych typów danych usługi Azure Stream Analytics jest opisana na stronie https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	Flaga wskazująca, czy parametr jest parametrem konfiguracji. Prawda, jeśli ten parametr wejściowy ma być stałą. Wartość domyślna to false.

FunctionOutput

Opisuje dane wyjściowe funkcji.

Nazwa	Typ	Opis
dataType	string	Typ danych (obsługiwany przez usługę Azure Stream Analytics) danych wyjściowych funkcji. Lista prawidłowych typów danych usługi Azure Stream Analytics jest opisana na stronie https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

Opisuje źródło danych wyjściowych magistrali komunikatów bramy.

Nazwa	Typ	Opis
properties.topic	string	Nazwa tematu usługi Service Bus.
type	string: GatewayMessageBus	Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Opisuje źródło danych wejściowych obiektów blob, które zawiera dane strumienia.

Nazwa	Typ	Opis
properties.topic	string	Nazwa tematu usługi Service Bus.
type	string: GatewayMessageBus	Wskazuje typ wejściowego źródła danych zawierającego dane strumienia. Wymagane w żądaniach PUT (CreateOrReplace).

Identity

Opisuje sposób weryfikowania tożsamości

Nazwa	Typ	Opis
principalId	string	Identyfikator podmiotu zabezpieczeń tożsamości
tenantId	string	Identyfikator dzierżawy tożsamości
type	string	Typ tożsamości

Input

Obiekt wejściowy zawierający wszystkie informacje skojarzone z nazwanymi danymi wejściowymi. Wszystkie dane wejściowe znajdują się w zadaniu przesyłania strumieniowego.

Nazwa	Typ	Opis
id	string	Identyfikator zasobu
name	string	Nazwa zasobu
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Właściwości skojarzone z danymi wejściowymi. Wymagane w żądaniach PUT (CreateOrReplace).
type	string	Typ zasobu

IoTHubStreamInputDataSource

Opisuje IoT Hub wejściowe źródło danych zawierające dane strumienia.

Nazwa	Typ	Opis
properties.consumerGroupName	string	Nazwa grupy odbiorców IoT Hub, która powinna służyć do odczytywania zdarzeń z IoT Hub. Jeśli nie zostanie określona, dane wejściowe używają domyślnej grupy odbiorców usługi Iot Hub.
properties.endpoint	string	Punkt końcowy IoT Hub do nawiązania połączenia (tj. komunikaty/zdarzenia, komunikaty/operacjeMonitorowanieEvents itp.).
properties.iotHubNamespace	string	Nazwa lub identyfikator URI IoT Hub. Wymagane w żądaniach PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Nazwa zasad dostępu współdzielonego dla IoT Hub. Te zasady muszą zawierać co najmniej uprawnienie service connect. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Wskazuje typ wejściowego źródła danych zawierającego dane strumienia. Wymagane w żądaniach PUT (CreateOrReplace).

JavaScriptFunctionBinding

Powiązanie z funkcją Języka JavaScript.

Nazwa	Typ	Opis
properties.script	string	Kod JavaScript zawierający pojedynczą definicję funkcji. Na przykład: "function (x, y) { return x + y; }"
type	string: Microsoft.StreamAnalytics/JavascriptUdf	Wskazuje typ powiązania funkcji.

JobStorageAccount

Właściwości skojarzone z kontem usługi Azure Storage z usługą MSI

Nazwa	Typ	Domyślna wartość	Opis
accountKey	string		Klucz konta dla konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
accountName	string		Nazwa konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.

JobType

Opisuje typ zadania. Prawidłowe tryby to Cloud i "Edge".

Nazwa	Typ	Opis
Cloud	string
Edge	string

JsonOutputSerializationFormat

Określa format kodu JSON, w który będą zapisywane dane wyjściowe. Obecnie obsługiwane wartości to "lineSeparated", co wskazuje, że dane wyjściowe będą formatowane przez każdy obiekt JSON oddzielony przez nowy wiersz i "tablicę", co wskazuje, że dane wyjściowe zostaną sformatowane jako tablica obiektów JSON.

Nazwa	Typ	Opis
Array	string
LineSeparated	string

JsonSerialization

Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie JSON.

Nazwa	Typ	Opis
properties.encoding	Encoding	Określa kodowanie danych przychodzących w przypadku danych wejściowych i kodowanie danych wychodzących w przypadku danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Ta właściwość dotyczy tylko serializacji danych wyjściowych w formacie JSON. Nie ma zastosowania do danych wejściowych. Ta właściwość określa format JSON, w ramach których zostaną zapisane dane wyjściowe. Obecnie obsługiwane wartości to "lineSeparated", co wskazuje, że dane wyjściowe będą formatowane przez każdy obiekt JSON oddzielony przez nowy wiersz i tablicę wskazującą, że dane wyjściowe będą formatowane jako tablica obiektów JSON. Wartość domyślna to "lineSeparated", jeśli pozostawiono wartość null.
type	string: Json	Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

Output

Obiekt wyjściowy zawierający wszystkie informacje skojarzone z nazwanymi danymi wyjściowymi. Wszystkie dane wyjściowe są zawarte w zadaniu przesyłania strumieniowego.

Nazwa	Typ	Opis
id	string	Identyfikator zasobu
name	string	Nazwa zasobu
properties.datasource	OutputDataSource: AzureDataLakeStoreOutputDataSource AzureFunctionOutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource AzureTableOutputDataSource BlobOutputDataSource DocumentDbOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource GatewayMessageBusOutputDataSource PowerBIOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource	Opisuje źródło danych, do którego zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
properties.diagnostics	Diagnostics	Opisuje warunki dotyczące danych wejściowych, wyjściowych lub ogólnego zadania, które uzasadniają uwagę klienta.
properties.etag	string	Bieżący tag jednostki dla danych wyjściowych. Jest to nieprzezroczystych ciągów. Można go użyć do wykrywania, czy zasób zmienił się między żądaniami. Można go również użyć w nagłówkach If-Match lub If-None-Match na potrzeby operacji zapisu na potrzeby optymistycznej współbieżności.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania w danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
properties.sizeWindow	integer	Okno rozmiaru umożliwiające ograniczenie danych wyjściowych usługi Stream Analytics do.
properties.timeWindow	string	Przedział czasu filtrowania danych wyjściowych zadania usługi Stream Analytics.
type	string	Typ zasobu

OutputErrorPolicy

Wskazuje zasady dotyczące stosowania do zdarzeń, które docierają do danych wyjściowych i nie mogą być zapisywane w magazynie zewnętrznym z powodu niewłaściwego utworzenia (brakujące wartości kolumn, wartości kolumn niewłaściwego typu lub rozmiaru).

Nazwa	Typ	Opis
Drop	string
Stop	string

OutputStartMode

Wartość może być JobStartTime, CustomTime lub LastOutputEventTime, aby wskazać, czy punkt początkowy strumienia zdarzeń wyjściowych powinien rozpoczynać się za każdym razem, gdy zadanie jest uruchamiane, rozpoczynać się od niestandardowego sygnatury czasowej użytkownika określonej za pośrednictwem właściwości outputStartTime lub rozpoczynać się od ostatniego czasu wyjściowego zdarzenia.

Nazwa	Typ	Opis
CustomTime	string
JobStartTime	string
LastOutputEventTime	string

ParquetSerialization

Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie Parquet.

Nazwa	Typ	Opis
type	string: Parquet	Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

PowerBIOutputDataSource

Opisuje źródło danych wyjściowych usługi Power BI.

Nazwa	Typ	Domyślna wartość	Opis
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.dataset	string		Nazwa zestawu danych usługi Power BI. Wymagane w żądaniach PUT (CreateOrReplace).
properties.groupId	string		Identyfikator grupy usługi Power BI.
properties.groupName	string		Nazwa grupy usługi Power BI. Użyj tej właściwości, aby zapamiętać, który identyfikator grupy usługi Power BI został użyty.
properties.refreshToken	string		Token odświeżania, którego można użyć do uzyskania prawidłowego tokenu dostępu, którego następnie można użyć do uwierzytelniania w źródle danych. Prawidłowy token odświeżania można obecnie uzyskać tylko za pośrednictwem witryny Azure Portal. Zaleca się umieszczenie w tym miejscu fikcyjnej wartości ciągu podczas tworzenia źródła danych, a następnie przejście do witryny Azure Portal w celu uwierzytelnienia źródła danych, które zaktualizuje tę właściwość przy użyciu prawidłowego tokenu odświeżania. Wymagane w żądaniach PUT (CreateOrReplace).
properties.table	string		Nazwa tabeli usługi Power BI w określonym zestawie danych. Wymagane w żądaniach PUT (CreateOrReplace).
properties.tokenUserDisplayName	string		Nazwa wyświetlana użytkownika, który został użyty do uzyskania tokenu odświeżania. Użyj tej właściwości, aby zapamiętać, którego użytkownika użyto do uzyskania tokenu odświeżania.
properties.tokenUserPrincipalName	string		Główna nazwa użytkownika (UPN) użytkownika, który został użyty do uzyskania tokenu odświeżania. Użyj tej właściwości, aby zapamiętać, którego użytkownika użyto do uzyskania tokenu odświeżania.
type	string: PowerBI		Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

ReferenceInputProperties

Właściwości skojarzone z danymi wejściowymi zawierającymi dane referencyjne.

Nazwa	Typ	Opis
compression	Compression	Opisuje sposób kompresji danych wejściowych
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Opisuje wejściowe źródło danych zawierające dane referencyjne. Wymagane w żądaniach PUT (CreateOrReplace).
diagnostics	Diagnostics	Opisuje warunki dotyczące danych wejściowych, wyjściowych lub ogólnego zadania, które uzasadniają uwagę klienta.
etag	string	Bieżący tag jednostki dla danych wejściowych. Jest to nieprzezroczystych ciągów. Można go użyć do wykrywania, czy zasób zmienił się między żądaniami. Można go również użyć w nagłówkach If-Match lub If-None-Match na potrzeby operacji zapisu na potrzeby optymistycznej współbieżności.
partitionKey	string	partitionKey opisuje klucz w danych wejściowych, które są używane do partycjonowania danych wejściowych
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania w danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Reference	Wskazuje, czy dane wejściowe są źródłem danych referencyjnych, czy strumieniowymi. Wymagane w żądaniach PUT (CreateOrReplace).

RefreshType

Wskazuje typ opcji odświeżania danych.

Nazwa	Typ	Opis
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

ScalarFunctionProperties

Właściwości skojarzone z funkcją skalarną.

Nazwa	Typ	Opis
etag	string	Bieżący tag jednostki dla funkcji. Jest to nieprzezroczystych ciągów. Można go użyć do wykrywania, czy zasób zmienił się między żądaniami. Można go również używać w nagłówkach If-Match lub If-None-Match na potrzeby operacji zapisu w celu optymistycznej współbieżności.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Fizyczne powiązanie funkcji. Na przykład w przypadku usługi internetowej Azure Machine Learning opisano punkt końcowy.
properties.inputs	FunctionInput[]	Opisuje jeden parametr wejściowy funkcji.
properties.output	FunctionOutput	Opisuje dane wyjściowe funkcji.
type	string: Scalar	Wskazuje typ funkcji.

ServiceBusQueueOutputDataSource

Opisuje źródło danych wyjściowych kolejki usługi Service Bus.

Nazwa	Typ	Domyślna wartość	Opis
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.propertyColumns	string[]		Tablica ciągów nazw kolumn wyjściowych, które mają być dołączone do komunikatów usługi Service Bus jako właściwości niestandardowych.
properties.queueName	string		Nazwa kolejki usługi Service Bus. Wymagane w żądaniach PUT (CreateOrReplace).
properties.serviceBusNamespace	string		Przestrzeń nazw skojarzona z żądanym centrum zdarzeń, kolejką usługi Service Bus, tematem usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		Nazwa zasad dostępu współdzielonego dla centrum zdarzeń, kolejki usługi Service Bus, tematu usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
properties.systemPropertyColumns	object		Właściwości systemu skojarzone z kolejką usługi Service Bus. Obsługiwane są następujące właściwości systemowe: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
type	string: Microsoft.ServiceBus/Queue		Wskazuje typ danych wyjściowych źródła danych, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

ServiceBusTopicOutputDataSource

Opisuje źródło danych wyjściowych tematu usługi Service Bus.

Nazwa	Typ	Domyślna wartość	Opis
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.propertyColumns	string[]		Tablica ciągów nazw kolumn wyjściowych, które mają być dołączone do komunikatów usługi Service Bus jako właściwości niestandardowych.
properties.serviceBusNamespace	string		Przestrzeń nazw skojarzona z żądanym centrum zdarzeń, kolejką usługi Service Bus, tematem usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		Nazwa zasad dostępu współdzielonego dla centrum zdarzeń, kolejki usługi Service Bus, tematu usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
properties.systemPropertyColumns	object		Właściwości systemu skojarzone z danymi wyjściowymi tematu usługi Service Bus. Obsługiwane są następujące właściwości systemowe: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
properties.topicName	string		Nazwa tematu usługi Service Bus. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/Topic		Wskazuje typ danych wyjściowych źródła danych, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

Sku

Właściwości skojarzone z jednostkami SKU.

Nazwa	Typ	Opis
name	SkuName	Nazwa jednostki SKU. Wymagane w żądaniach PUT (CreateOrReplace).

SkuName

Nazwa jednostki SKU. Wymagane w żądaniach PUT (CreateOrReplace).

Nazwa	Typ	Opis
Standard	string

StorageAccount

Właściwości skojarzone z kontem usługi Azure Storage

Nazwa	Typ	Opis
accountKey	string	Klucz konta dla konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
accountName	string	Nazwa konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).

StreamingJob

Obiekt zadania przesyłania strumieniowego zawierający wszystkie informacje skojarzone z nazwanym zadaniem przesyłania strumieniowego.

Nazwa	Typ	Opis
id	string	W pełni kwalifikowany identyfikator zasobu dla zasobu. Ex — /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Opisuje tożsamość zarządzaną przypisaną przez system przypisaną do tego zadania, która może służyć do uwierzytelniania przy użyciu danych wejściowych i wyjściowych.
location	string	Lokalizacja geograficzna, w której znajduje się zasób
name	string	Nazwa zasobu
properties.cluster	ClusterInfo	Klaster, w którym będą uruchamiane zadania przesyłania strumieniowego.
properties.compatibilityLevel	CompatibilityLevel	Steruje pewnymi zachowaniami środowiska uruchomieniowego zadania przesyłania strumieniowego.
properties.contentStoragePolicy	ContentStoragePolicy	Prawidłowe wartości to JobStorageAccount i SystemAccount. Jeśli ustawiono wartość JobStorageAccount, wymaga to również od użytkownika określenia właściwości jobStorageAccount. .
properties.createdDate	string	Wartość to sygnatura czasowa UTC sformatowana w formacie ISO-8601 wskazująca, kiedy zadanie przesyłania strumieniowego zostało utworzone.
properties.dataLocale	string	Ustawienia regionalne danych zadania usługi Stream Analytics. Wartość powinna być nazwą obsługiwanej kultury .NET z zestawu https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Wartość domyślna to "en-US", jeśli nie określono żadnego.
properties.etag	string	Bieżący tag jednostki dla zadania przesyłania strumieniowego. Jest to nieprzezroczystych ciągów. Można go użyć do wykrywania, czy zasób zmienił się między żądaniami. Można go również użyć w nagłówkach If-Match lub If-None-Match na potrzeby operacji zapisu na potrzeby optymistycznej współbieżności.
properties.eventsLateArrivalMaxDelayInSeconds	integer	Maksymalne tolerowane opóźnienie w sekundach, w których zdarzenia przybywające późno mogą zostać uwzględnione. Obsługiwany zakres to -1 do 1814399 (20.23:59:59 dni) i -1 służy do określania oczekiwania na czas nieokreślony. Jeśli właściwość jest nieobecna, interpretowana jest wartość -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	Maksymalne dopuszczalne opóźnienie w sekundach, w których zdarzenia poza kolejnością można dostosować, aby wrócić do kolejności.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Wskazuje zasady, które mają być stosowane do zdarzeń, które docierają z kolejności w strumieniu zdarzeń wejściowych.
properties.functions	Function[]	Lista co najmniej jednej funkcji zadania przesyłania strumieniowego. Właściwość name dla każdej funkcji jest wymagana podczas określania tej właściwości w żądaniu PUT. Nie można zmodyfikować tej właściwości za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla pojedynczej transformacji.
properties.inputs	Input[]	Lista co najmniej jednego danych wejściowych zadania przesyłania strumieniowego. Właściwość name dla każdego danych wejściowych jest wymagana podczas określania tej właściwości w żądaniu PUT. Nie można zmodyfikować tej właściwości za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych danych wejściowych.
properties.jobId	string	Identyfikator GUID jednoznacznie identyfikujący zadanie przesyłania strumieniowego. Ten identyfikator GUID jest generowany podczas tworzenia zadania przesyłania strumieniowego.
properties.jobState	string	Opisuje stan zadania przesyłania strumieniowego.
properties.jobStorageAccount	JobStorageAccount	Właściwości skojarzone z kontem usługi Azure Storage z usługą MSI
properties.jobType	JobType	Opisuje typ zadania. Prawidłowe tryby to Cloud i "Edge".
properties.lastOutputEventTime	string	Wartość to sformatowana sygnatura czasowa ISO-8601 wskazująca czas ostatniego zdarzenia wyjściowego zadania przesyłania strumieniowego lub wartość null wskazująca, że dane wyjściowe nie zostały jeszcze wygenerowane. W przypadku wielu danych wyjściowych lub wielu strumieni pokazuje najnowszą wartość w tym zestawie.
properties.outputErrorPolicy	OutputErrorPolicy	Wskazuje zasady dotyczące stosowania do zdarzeń, które docierają do danych wyjściowych i nie mogą być zapisywane w magazynie zewnętrznym z powodu niewłaściwego utworzenia (brakujące wartości kolumn, wartości kolumn niewłaściwego typu lub rozmiaru).
properties.outputStartMode	OutputStartMode	Ta właściwość powinna być używana tylko wtedy, gdy jest to wymagane, aby zadanie zostało uruchomione natychmiast po utworzeniu. Wartość może być JobStartTime, CustomTime lub LastOutputEventTime, aby wskazać, czy punkt początkowy strumienia zdarzeń wyjściowych powinien rozpoczynać się za każdym razem, gdy zadanie jest uruchamiane, rozpoczynać się od niestandardowego sygnatury czasowej użytkownika określonej za pośrednictwem właściwości outputStartTime lub rozpoczynać się od ostatniego czasu wyjściowego zdarzenia.
properties.outputStartTime	string	Wartość to sygnatura czasowa w formacie ISO-8601 wskazująca punkt początkowy strumienia zdarzeń wyjściowych lub wartość null wskazująca, że strumień zdarzeń wyjściowych zostanie uruchomiony przy każdym uruchomieniu zadania przesyłania strumieniowego. Ta właściwość musi mieć wartość, jeśli parametr outputStartMode jest ustawiony na Wartość CustomTime.
properties.outputs	Output[]	Lista co najmniej jednego danych wyjściowych zadania przesyłania strumieniowego. Właściwość name dla każdego danych wyjściowych jest wymagana podczas określania tej właściwości w żądaniu PUT. Nie można zmodyfikować tej właściwości za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych danych wyjściowych.
properties.provisioningState	string	Opisuje stan aprowizacji zadania przesyłania strumieniowego.
properties.sku	Sku	Opisuje jednostkę SKU zadania przesyłania strumieniowego. Wymagane w żądaniach PUT (CreateOrReplace).
properties.transformation	Transformation	Wskazuje zapytanie i liczbę jednostek przesyłania strumieniowego do użycia dla zadania przesyłania strumieniowego. Właściwość name przekształcenia jest wymagana podczas określania tej właściwości w żądaniu PUT. Nie można zmodyfikować tej właściwości za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla pojedynczej transformacji.
tags	object	Tagi zasobów.
type	string	Typ zasobu. Ex- Microsoft.Compute/virtualMachines lub Microsoft.Storage/storageAccounts.

StreamInputProperties

Właściwości skojarzone z danymi wejściowymi zawierającymi dane strumienia.

Nazwa	Typ	Opis
compression	Compression	Opisuje sposób kompresji danych wejściowych
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Opisuje wejściowe źródło danych zawierające dane strumienia. Wymagane w żądaniach PUT (CreateOrReplace).
diagnostics	Diagnostics	Opisuje warunki dotyczące danych wejściowych, wyjściowych lub ogólnego zadania, które uzasadniają uwagę klienta.
etag	string	Bieżący tag jednostki dla danych wejściowych. Jest to nieprzezroczystych ciągów. Można go użyć do wykrywania, czy zasób zmienił się między żądaniami. Można go również użyć w nagłówkach If-Match lub If-None-Match na potrzeby operacji zapisu na potrzeby optymistycznej współbieżności.
partitionKey	string	partitionKey opisuje klucz w danych wejściowych, które są używane do partycjonowania danych wejściowych
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania w danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Stream	Wskazuje, czy dane wejściowe są źródłem danych referencyjnych, czy strumieniowymi. Wymagane w żądaniach PUT (CreateOrReplace).

Transformation

Obiekt przekształcania zawierający wszystkie informacje skojarzone z nazwaną transformacją. Wszystkie przekształcenia są zawarte w zadaniu przesyłania strumieniowego.

Nazwa	Typ	Domyślna wartość	Opis
id	string		Identyfikator zasobu
name	string		Nazwa zasobu
properties.etag	string		Bieżący tag jednostki dla przekształcenia. Jest to nieprzezroczystych ciągów. Można go użyć do wykrywania, czy zasób zmienił się między żądaniami. Można go również użyć w nagłówkach If-Match lub If-None-Match na potrzeby operacji zapisu na potrzeby optymistycznej współbieżności.
properties.query	string		Określa zapytanie, które zostanie uruchomione w zadaniu przesyłania strumieniowego. Więcej informacji na temat języka zapytań usługi Stream Analytics (SAQL) można znaleźć tutaj: https://msdn.microsoft.com/library/azure/dn834998 . Wymagane w żądaniach PUT (CreateOrReplace).
properties.streamingUnits	integer	3	Określa liczbę jednostek przesyłania strumieniowego używanych przez zadanie przesyłania strumieniowego.
properties.validStreamingUnits	integer[]		Określa prawidłowe jednostki przesyłania strumieniowego, do których można skalować zadanie przesyłania strumieniowego.
type	string		Typ zasobu