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 minLength: 1 maxLength: 90 pattern: ^[-\w\._]+$	Nazwa grupy zasobów. Nazwa jest niewrażliwa na wielkość liter.
subscriptionId	path	True	string minLength: 1	Identyfikator subskrypcji docelowej.
api-version	query	True	string minLength: 1	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ępować 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 aby zapobiec aktualizowaniu 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, 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.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 (int32)	Maksymalne tolerowane opóźnienie w sekundach, w których mogą być uwzględniane zdarzenia przychodzące późno. Obsługiwany zakres jest -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 (int32)	Maksymalne tolerowane 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ą poza kolejność 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ściowego 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. 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 być uruchamiany za każdym razem, gdy zadanie zostanie uruchomione, rozpocznij od niestandardowej sygnatury czasowej użytkownika określonej za pośrednictwem właściwości outputStartTime lub rozpocznij od ostatniego czasu wyjściowego zdarzenia.
properties.outputStartTime	string (date-time)	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 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.

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 protokołu 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

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

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


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

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

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

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

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

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

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

createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output().catch(
  console.error
);

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

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

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

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


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

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

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

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

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

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

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

createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions().catch(
  console.error
);

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

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 serializowanych danych podczas zapisywania danych wyjściowych w formacie Avro.
AzureDataLakeStoreOutputDataSource	Opisuje źródło danych wyjściowych 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ą 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 Database.
AzureSqlReferenceInputDataSource	Opisuje źródło danych wejściowych w bazie danych Azure SQL Database.
AzureSynapseOutputDataSource	Opisuje źródło danych wyjściowych usługi Azure Synapse.
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 obiektu blob, które zawiera dane referencyjne.
BlobStreamInputDataSource	Opisuje źródło danych wejściowych obiektu 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, jak dane wejściowe są serializowane lub jak dane są serializowane podczas zapisywania 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 kodowanie danych wychodzących w przypadku danych wyjściowych.
Error	Typowa reprezentacja błędu.
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ą poza kolejność w strumieniu zdarzeń wejściowych.
FileReferenceInputDataSource	Opisuje źródło danych wejściowych pliku, które zawiera 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 obiektu 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 są zawarte w zadaniu przesyłania strumieniowego.
IoTHubStreamInputDataSource	Opisuje źródło danych wejściowych usługi IoT Hub, które zawiera dane strumienia.
JavaScriptFunctionBinding	Powiązanie z funkcją Języka JavaScript.
JobStorageAccount	Właściwości skojarzone z kontem usługi Azure Storage z tożsamością usługi zarządzanej
JobType	Opisuje typ zadania. Prawidłowe tryby to `Cloud` i "Edge".
JsonOutputSerializationFormat	Określa format 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ę wskazującą, że dane wyjściowe będą formatowane 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, 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).
OutputStartMode	Wartością może być JobStartTime, CustomTime lub LastOutputEventTime, aby wskazać, czy punkt początkowy strumienia zdarzeń wyjściowych powinien być uruchamiany za każdym razem, gdy zadanie zostanie uruchomione, rozpocznij od niestandardowej sygnatury czasowej użytkownika określonej za pośrednictwem właściwości outputStartTime lub rozpocznij od ostatniego czasu wyjściowego zdarzenia.
ParquetSerialization	Opisuje sposób serializacji danych wejściowych lub serializowanych 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łcenia zawierający wszystkie informacje skojarzone z nazwanym przekształceniem. Wszystkie przekształcenia są zawarte w zadaniu przesyłania strumieniowego.

AggregateFunctionProperties

Objekt

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

Nazwa	Typ	Opis
etag	string	Bieżący tag jednostki dla funkcji. Jest to nieprzezroczystym ciągiem. 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 uzyskania 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 opisuje to 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

Wyliczanie

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

Wartość	Opis
Msi
UserToken
ConnectionString

AvroSerialization

Objekt

Opisuje sposób serializacji danych wejściowych lub serializowanych danych podczas zapisywania 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

Objekt

Opisuje źródło danych wyjściowych 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 plikuPathPrefix, 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óry następnie może służyć do uwierzytelniania za pomocą źródła danych. Prawidłowy token odświeżania można obecnie uzyskać tylko za pośrednictwem witryny Azure Portal. Zaleca się umieszczenie tutaj 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żyty do uzyskania tokenu odświeżania. Wymagane w żądaniach PUT (CreateOrReplace).
properties.timeFormat	string		Format godziny. Wszędzie tam, gdzie {time} pojawia się w plikuPathPrefix, 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, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

AzureFunctionOutputDataSource

Objekt

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 dostępu do funkcji.
properties.functionAppName	string	Nazwa aplikacji usługi Azure Functions.
properties.functionName	string	Nazwa funkcji w aplikacji usługi Azure Functions.
properties.maxBatchCount	number	Właściwość umożliwiająca określenie maksymalnej liczby zdarzeń w każdej partii wysyłanej do usługi 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 wyrażona 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

Objekt

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 (int32)	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

Objekt

Opisuje kolumnę wejś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 wejściowej. Lista prawidłowych typów danych usługi Azure Machine Learning jest opisana w https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
mapTo	integer (int32)	Zerowy indeks parametru funkcji, do których jest mapowanie danych wejściowych.
name	string	Nazwa kolumny wejściowej.

AzureMachineLearningWebServiceInputs

Objekt

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

Objekt

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 https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
name	string	Nazwa kolumny wyjściowej.

AzureSqlDatabaseOutputDataSource

Objekt

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

Nazwa	Typ	Domyślna wartość	Opis
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.database	string		Nazwa bazy danych Azure SQL Database. Wymagane w żądaniach PUT (CreateOrReplace).
properties.maxBatchCount	number		Maksymalna liczba partii dla 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 zapis) 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 Database. Wymagane w żądaniach PUT (CreateOrReplace).
properties.server	string		Nazwa serwera SQL zawierającego bazę danych Azure SQL Database. Wymagane w żądaniach PUT (CreateOrReplace).
properties.table	string		Nazwa tabeli w bazie danych Azure SQL Database. 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 Database. 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

Objekt

Opisuje źródło danych wejściowych w bazie danych Azure SQL Database.

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 usługi 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órych zostanie zapisana.
properties.table	string	Ten element jest skojarzony z elementem źródła danych. Nazwa tabeli w bazie danych Azure SQL Database.
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 usługi 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

Objekt

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

Nazwa	Typ	Opis
properties.database	string	Nazwa bazy danych Azure SQL Database. 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 Database. Wymagane w żądaniach PUT (CreateOrReplace).
properties.server	string	Nazwa serwera SQL zawierającego bazę danych Azure SQL Database. Wymagane w żądaniach PUT (CreateOrReplace).
properties.table	string	Nazwa tabeli w bazie danych Azure SQL Database. 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 Database. 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

Objekt

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 (int32)	Liczba wierszy do zapisu w tabeli platformy Azure jednocześnie.
properties.columnsToRemove	string[]	Jeśli zostanie określony, każdy element w tablicy jest nazwą kolumny do usunięcia (jeśli istnieje) z wyjściowych jednostek zdarzeń.
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

Objekt

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 na 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 wzorzec, względem którego nazwy obiektów blob będą dopasowywane w celu określenia, czy powinny one być uwzględniane jako dane wejściowe lub wyjściowe zadania. Aby uzyskać bardziej szczegółowe wyjaśnienie i przykład, 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.
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 danych wyjściowych źródła danych, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

BlobReferenceInputDataSource

Objekt

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

Nazwa	Typ	Domyślna wartość	Opis
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.container	string		Nazwa kontenera na 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 wzorzec, względem którego nazwy obiektów blob będą dopasowywane w celu określenia, czy powinny one być uwzględniane jako dane wejściowe lub wyjściowe zadania. Aby uzyskać bardziej szczegółowe wyjaśnienie i przykład, 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.
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

Objekt

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

Nazwa	Typ	Domyślna wartość	Opis
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.container	string		Nazwa kontenera na 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 wzorzec, względem którego nazwy obiektów blob będą dopasowywane w celu określenia, czy powinny one być uwzględniane jako dane wejściowe lub wyjściowe zadania. Aby uzyskać bardziej szczegółowe wyjaśnienie i przykład, 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.
properties.sourcePartitionCount	integer (int32)		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 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 strumienia. Wymagane w żądaniach PUT (CreateOrReplace).

ClusterInfo

Objekt

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

Nazwa	Typ	Opis
id	string	Identyfikator zasobu klastra.

CompatibilityLevel

Wyliczanie

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

Wartość	Opis
1.0
1.2

Compression

Objekt

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

Wyliczanie

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

Wartość	Opis
None
GZip
Deflate

ContentStoragePolicy

Wyliczanie

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. .

Wartość	Opis
SystemAccount
JobStorageAccount

CsvSerialization

Objekt

Opisuje, jak dane wejściowe są serializowane lub jak dane są serializowane podczas zapisywania 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). Aby uzyskać listę obsługiwanych wartości, 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. 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

Objekt

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 czasu rozpoczęcia warunku. Klienci powinni mieć możliwość znalezienia odpowiedniego zdarzenia w dzienniku operacji w tym czasie.

Diagnostics

Objekt

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 ogólnego zadania, które uzasadniają uwagę klienta.

DocumentDbOutputDataSource

Objekt

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 utworzyć przy użyciu opcjonalnego tokenu {partition}, w którym partycje zaczynają się od 0. Aby uzyskać więcej informacji, zobacz sekcję usługi DocumentDB https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output. 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ślania klucza podstawowego, na którym opierają się operacje wstawiania lub aktualizacji.
properties.partitionKey	string	Nazwa pola w zdarzeniach wyjściowych używanych do określania klucza do partycjonowania danych wyjściowych w kolekcjach. Jeśli właściwość "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

Wyliczanie

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

Wartość	Opis
UTF8

Error

Objekt

Typowa reprezentacja błędu.

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

EventHubOutputDataSource

Objekt

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 używana do określania partycji do wysyłania danych zdarzenia.
properties.propertyColumns	string[]		Właściwości skojarzone z tym danymi wyjściowymi 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

Objekt

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 unikatowych 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ślony, 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

Objekt

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 używana do określania partycji do wysyłania danych zdarzenia.
properties.propertyColumns	string[]		Właściwości skojarzone z tym danymi wyjściowymi 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

Objekt

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 unikatowych 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ślony, 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

Wyliczanie

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

Wartość	Opis
Csv
Avro
Json
Parquet

EventsOutOfOrderPolicy

Wyliczanie

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

Wartość	Opis
Adjust
Drop

FileReferenceInputDataSource

Objekt

Opisuje źródło danych wejściowych pliku, które zawiera 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

Objekt

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

Objekt

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 w https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	Flaga wskazująca, czy parametr jest parametrem konfiguracji. Wartość True, jeśli ten parametr wejściowy ma być stałą. Wartość domyślna to false.

FunctionOutput

Objekt

Opisuje dane wyjściowe funkcji.

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

GatewayMessageBusOutputDataSource

Objekt

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, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Objekt

Opisuje źródło danych wejściowych obiektu 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

Objekt

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

Objekt

Obiekt wejściowy zawierający wszystkie informacje skojarzone z nazwanymi danymi wejściowymi. Wszystkie dane wejściowe są zawarte 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

Objekt

Opisuje źródło danych wejściowych usługi IoT Hub, które zawiera dane strumienia.

Nazwa	Typ	Opis
properties.consumerGroupName	string	Nazwa grupy odbiorców usługi IoT Hub, która powinna służyć do odczytywania zdarzeń z usługi IoT Hub. Jeśli nie zostanie określony, dane wejściowe używają domyślnej grupy odbiorców usługi Iot Hub.
properties.endpoint	string	Punkt końcowy usługi IoT Hub do nawiązania połączenia (tj. komunikaty/zdarzenia, komunikaty/operacjeMonitorowanieEvents itp.).
properties.iotHubNamespace	string	Nazwa lub identyfikator URI usługi 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 usługi 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

Objekt

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

Objekt

Właściwości skojarzone z kontem usługi Azure Storage z tożsamością usługi zarządzanej

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

Wyliczanie

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

Wartość	Opis
Cloud
Edge

JsonOutputSerializationFormat

Wyliczanie

Określa format 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ę wskazującą, że dane wyjściowe będą formatowane jako tablica obiektów JSON.

Wartość	Opis
LineSeparated
Array

JsonSerialization

Objekt

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 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ę 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

Objekt

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 nieprzezroczystym ciągiem. 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 uzyskania optymistycznej współbieżności.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Opisuje sposób serializacji danych wejściowych lub serializowanych danych podczas zapisywania w danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
properties.sizeWindow	integer (int32)	Okno rozmiaru ograniczające dane wyjściowe usługi Stream Analytics.
properties.timeWindow	string	Przedział czasu filtrowania danych wyjściowych zadania usługi Stream Analytics.
type	string	Typ zasobu

OutputErrorPolicy

Wyliczanie

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).

Wartość	Opis
Stop
Drop

OutputStartMode

Wyliczanie

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

Wartość	Opis
JobStartTime
CustomTime
LastOutputEventTime

ParquetSerialization

Objekt

Opisuje sposób serializacji danych wejściowych lub serializowanych 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

Objekt

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óry następnie może służyć do uwierzytelniania za pomocą źródła danych. Prawidłowy token odświeżania można obecnie uzyskać tylko za pośrednictwem witryny Azure Portal. Zaleca się umieszczenie tutaj 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, do których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

ReferenceInputProperties

Objekt

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 nieprzezroczystym ciągiem. 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 uzyskania 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 serializowanych 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 strumienia danych. Wymagane w żądaniach PUT (CreateOrReplace).

RefreshType

Wyliczanie

Wskazuje typ opcji odświeżania danych.

Wartość	Opis
Static
RefreshPeriodicallyWithFull
RefreshPeriodicallyWithDelta

ScalarFunctionProperties

Objekt

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

Nazwa	Typ	Opis
etag	string	Bieżący tag jednostki dla funkcji. Jest to nieprzezroczystym ciągiem. 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 uzyskania 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 opisuje to 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

Objekt

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

Objekt

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 systemowe 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

Objekt

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

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

SkuName

Wyliczanie

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

Wartość	Opis
Standard

StorageAccount

Objekt

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

Objekt

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. Przykład - /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 (date-time)	Wartość to sformatowany znacznik czasu UTC ISO-8601 wskazujący czas utworzenia zadania przesyłania strumieniowego.
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 nieprzezroczystym ciągiem. 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 uzyskania optymistycznej współbieżności.
properties.eventsLateArrivalMaxDelayInSeconds	integer (int32)	Maksymalne tolerowane opóźnienie w sekundach, w których mogą być uwzględniane zdarzenia przychodzące późno. Obsługiwany zakres jest -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 (int32)	Maksymalne tolerowane 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ą poza kolejność 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ściowego 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. 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.jobId	string	Unikatowy identyfikator GUID 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 tożsamością usługi zarządzanej
properties.jobType	JobType	Opisuje typ zadania. Prawidłowe tryby to `Cloud` i "Edge".
properties.lastOutputEventTime	string (date-time)	Wartość to sformatowany znacznik czasu ISO-8601 wskazujący czas ostatniego zdarzenia wyjściowego zadania przesyłania strumieniowego lub wartość null wskazującą, ż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, 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 być uruchamiany za każdym razem, gdy zadanie zostanie uruchomione, rozpocznij od niestandardowej sygnatury czasowej użytkownika określonej za pośrednictwem właściwości outputStartTime lub rozpocznij od ostatniego czasu wyjściowego zdarzenia.
properties.outputStartTime	string (date-time)	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 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.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. 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.
type	string	Typ zasobu. Ex- Microsoft.Compute/virtualMachines lub Microsoft.Storage/storageAccounts.

StreamInputProperties

Objekt

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, które zawiera 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 nieprzezroczystym ciągiem. 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 uzyskania 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 serializowanych 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 strumienia danych. Wymagane w żądaniach PUT (CreateOrReplace).

Transformation

Objekt

Obiekt przekształcenia zawierający wszystkie informacje skojarzone z nazwanym przekształceniem. 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 nieprzezroczystym ciągiem. 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 uzyskania optymistycznej współbieżności.
properties.query	string		Określa zapytanie, które będzie uruchamiane 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 (int32)	3	Określa liczbę jednostek przesyłania strumieniowego używanych przez zadanie przesyłania strumieniowego.
properties.validStreamingUnits	integer[] (int32)		Określa prawidłowe jednostki przesyłania strumieniowego, do których można skalować zadanie przesyłania strumieniowego.
type	string		Typ zasobu

Udostępnij przez

Streaming Jobs - Create Or Replace

Parametry identyfikatora URI

Nagłówek żądania

Treść żądania

Odpowiedzi

Zabezpieczenia

azure_auth

Zakresy

Przykłady

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

Przykładowe żądanie

Przykładowa odpowiedź

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

Przykładowe żądanie

Przykładowa odpowiedź

Definicje

AggregateFunctionProperties

AuthenticationMode

AvroSerialization

AzureDataLakeStoreOutputDataSource

AzureFunctionOutputDataSource

AzureMachineLearningWebServiceFunctionBinding

AzureMachineLearningWebServiceInputColumn

AzureMachineLearningWebServiceInputs

AzureMachineLearningWebServiceOutputColumn

AzureSqlDatabaseOutputDataSource

AzureSqlReferenceInputDataSource

AzureSynapseOutputDataSource

AzureTableOutputDataSource

BlobOutputDataSource

BlobReferenceInputDataSource

BlobStreamInputDataSource

ClusterInfo

CompatibilityLevel

Compression

CompressionType

ContentStoragePolicy

CsvSerialization

DiagnosticCondition

Diagnostics

DocumentDbOutputDataSource

Encoding

Error

EventHubOutputDataSource

EventHubStreamInputDataSource

EventHubV2OutputDataSource

EventHubV2StreamInputDataSource

EventSerializationType

EventsOutOfOrderPolicy

FileReferenceInputDataSource

Function

FunctionInput

FunctionOutput

GatewayMessageBusOutputDataSource

GatewayMessageBusStreamInputDataSource

Identity

Input

IoTHubStreamInputDataSource

JavaScriptFunctionBinding

JobStorageAccount

JobType

JsonOutputSerializationFormat

JsonSerialization

Output

OutputErrorPolicy

OutputStartMode

ParquetSerialization

PowerBIOutputDataSource

ReferenceInputProperties

RefreshType

ScalarFunctionProperties

ServiceBusQueueOutputDataSource

ServiceBusTopicOutputDataSource

Sku

SkuName

StorageAccount

StreamingJob

StreamInputProperties

Transformation