Streaming Jobs - Create Or Replace

Služba:

Stream Analytics

Verze rozhraní API:

2020-03-01

Vytvoří úlohu streamování nebo nahradí existující úlohu streamování.

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

Parametry identifikátoru URI

Name	V	Vyžadováno	Typ	Description
jobName	path	True	string	Název úlohy streamování.
resourceGroupName	path	True	string	Název skupiny prostředků. V názvu se rozlišují malá a velká písmena. Vzor regulárního výrazu: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	ID cílového předplatného.
api-version	query	True	string	Verze rozhraní API, která se má použít pro tuto operaci.

Hlavička požadavku

Name	Vyžadováno	Typ	Description
If-Match		string	Značka ETag úlohy streamování Vynechat tuto hodnotu, aby se vždy přepsala aktuální sada záznamů. Zadejte naposledy zobrazenou hodnotu značky ETag, abyste zabránili náhodnému přepsání souběžných změn.
If-None-Match		string	Nastavením na *povolíte vytvoření nové úlohy streamování, ale zabráníte aktualizaci existující sady záznamů. Jiné hodnoty budou mít za následek odpověď 412 Před podmínkou selhala.

Text požadavku

Name	Typ	Description
identity	Identity	Popisuje spravovanou identitu přiřazenou systémem přiřazenou k této úloze, kterou lze použít k ověření se vstupy a výstupy.
location	string	Geografické umístění, kde se prostředek nachází
properties.cluster	ClusterInfo	Cluster, ve kterém se budou spouštět úlohy streamování.
properties.compatibilityLevel	CompatibilityLevel	Řídí určité chování úlohy streamování za běhu.
properties.contentStoragePolicy	ContentStoragePolicy	Platné hodnoty jsou JobStorageAccount a SystemAccount. Pokud je nastavená hodnota JobStorageAccount, vyžaduje to, aby uživatel zadal také vlastnost jobStorageAccount. .
properties.dataLocale	string	Národní prostředí dat úlohy Stream Analytics. Hodnota by měla být název podporované jazykové verze .NET ze sady https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Výchozí hodnota je en-US, pokud není zadána žádná hodnota.
properties.eventsLateArrivalMaxDelayInSeconds	integer	Může být zahrnuta maximální přípustná prodleva v sekundách, kdy se události dorazí pozdě. Podporovaný rozsah je -1 až 1814399 (20,23:59:59 dne) a -1 se používá k určení čekání na dobu neurčitou. Pokud vlastnost chybí, je interpretována tak, aby měla hodnotu -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	Maximální přípustné zpoždění v sekundách, kdy je možné události mimo pořadí upravit tak, aby byly v pořádku.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Určuje zásadu, která se má použít u událostí, které přicházejí ve vstupním streamu událostí v pořadí.
properties.functions	Function[]	Seznam jedné nebo více funkcí pro úlohu streamování. Vlastnost name pro každou funkci se vyžaduje při zadávání této vlastnosti v požadavku PUT. Tuto vlastnost nelze upravit prostřednictvím operace PATCH. Musíte použít rozhraní PATCH API, které je k dispozici pro jednotlivé transformace.
properties.inputs	Input[]	Seznam jednoho nebo více vstupů pro úlohu streamování. Vlastnost name pro každý vstup se vyžaduje při zadávání této vlastnosti v požadavku PUT. Tuto vlastnost nelze upravit prostřednictvím operace PATCH. Musíte použít rozhraní PATCH API, které je k dispozici pro jednotlivé vstupy.
properties.jobStorageAccount	JobStorageAccount	Vlastnosti přidružené k účtu služby Azure Storage s MSI
properties.jobType	JobType	Popisuje typ úlohy. Platnými režimy jsou Cloud a Edge.
properties.outputErrorPolicy	OutputErrorPolicy	Označuje zásadu, která se má použít u událostí, které přicházejí do výstupu a kvůli poškození se nedají zapsat do externího úložiště (chybějící hodnoty sloupců, hodnoty sloupců s nesprávným typem nebo velikostí).
properties.outputStartMode	OutputStartMode	Tato vlastnost by měla být využita pouze v případě, že je žádoucí, aby úloha byla spuštěna okamžitě po vytvoření. Hodnota může být JobStartTime, CustomTime nebo LastOutputEventTime označující, jestli se má počáteční bod výstupního datového proudu událostí spouštět při každém spuštění úlohy, s vlastním časovým razítkem uživatele zadaným prostřednictvím vlastnosti outputStartTime nebo od posledního výstupního času události.
properties.outputStartTime	string	Hodnota je buď časové razítko ve formátu ISO-8601, které označuje počáteční bod výstupního datového proudu událostí, nebo null, což znamená, že výstupní datový proud událostí se spustí při každém spuštění úlohy streamování. Tato vlastnost musí mít hodnotu, pokud je outputStartMode nastavený na CustomTime.
properties.outputs	Output[]	Seznam jednoho nebo více výstupů pro úlohu streamování Vlastnost name pro každý výstup se vyžaduje při zadávání této vlastnosti v požadavku PUT. Tuto vlastnost nelze upravit prostřednictvím operace PATCH. Musíte použít rozhraní PATCH API, které je k dispozici pro jednotlivé výstupy.
properties.sku	Sku	Popisuje skladovou položku úlohy streamování. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.transformation	Transformation	Určuje dotaz a počet jednotek streamování, které se mají použít pro úlohu streamování. Vlastnost name transformace se vyžaduje při zadávání této vlastnosti v požadavku PUT. Tuto vlastnost nelze upravit prostřednictvím operace PATCH. Musíte použít rozhraní PATCH API, které je k dispozici pro jednotlivé transformace.
tags	object	Značky prostředků.

Odpovědi

Name	Typ	Description
200 OK	StreamingJob	Úloha streamování se úspěšně vytvořila nebo nahradila. Hlavičky ETag: string
201 Created	StreamingJob	Úloha streamování se úspěšně vytvořila nebo nahradila. Hlavičky ETag: string
Other Status Codes	Error	Chyba

Zabezpečení

azure_auth

Tok Azure Active Directory OAuth2

Typ: oauth2
Tok: implicit
URL autorizace: https://login.microsoftonline.com/common/oauth2/authorize

Rozsahy

Name	Description
user_impersonation	zosobnění uživatelského účtu

Příklady

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)

Ukázkový požadavek

HTTP

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

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

Java

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

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

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

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

JavaScript

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

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

createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output().catch(
  console.error
);

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

Ukázková odpověď

Stavový kód:

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

Stavový kód:

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)

Ukázkový požadavek

HTTP

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

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

Java

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

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

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

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

JavaScript

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

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

createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions().catch(
  console.error
);

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

Ukázková odpověď

Stavový kód:

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

Stavový kód:

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

Definice

Name	Description
AggregateFunctionProperties	Vlastnosti, které jsou přidruženy k agregační funkci.
AuthenticationMode	Režim ověřování. Platné režimy jsou ConnectionString, Msi a 'UserToken'.
AvroSerialization	Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu Avro.
AzureDataLakeStoreOutputDataSource	Popisuje výstupní zdroj dat Azure Data Lake Store.
AzureFunctionOutputDataSource	Definuje metadata azureFunctionOutputDataSource.
AzureMachineLearningWebServiceFunctionBinding	Vazba na webovou službu Azure Machine Learning.
AzureMachineLearningWebServiceInputColumn	Popisuje vstupní sloupec pro koncový bod webové služby Azure Machine Learning.
AzureMachineLearningWebServiceInputs	Vstupy pro koncový bod webové služby Azure Machine Learning.
AzureMachineLearningWebServiceOutputColumn	Popisuje výstupní sloupec pro koncový bod webové služby Azure Machine Learning.
AzureSqlDatabaseOutputDataSource	Popisuje výstupní zdroj dat Azure SQL databáze.
AzureSqlReferenceInputDataSource	Popisuje referenční vstupní zdroj dat Azure SQL databáze.
AzureSynapseOutputDataSource	Popisuje Azure Synapse výstupní zdroj dat.
AzureTableOutputDataSource	Popisuje výstupní zdroj dat Tabulky Azure.
BlobOutputDataSource	Popisuje výstupní zdroj dat objektu blob.
BlobReferenceInputDataSource	Popisuje vstupní zdroj dat objektu blob, který obsahuje referenční data.
BlobStreamInputDataSource	Popisuje vstupní zdroj dat objektu blob, který obsahuje streamová data.
ClusterInfo	Vlastnosti přidružené ke clusteru Stream Analytics.
CompatibilityLevel	Řídí určité chování úlohy streamování za běhu.
Compression	Popisuje, jak se komprimují vstupní data.
CompressionType	Určuje typ komprese, kterou vstup používá. Vyžaduje se u požadavků PUT (CreateOrReplace).
ContentStoragePolicy	Platné hodnoty jsou JobStorageAccount a SystemAccount. Pokud je nastavená hodnota JobStorageAccount, vyžaduje, aby uživatel zadal také vlastnost jobStorageAccount. .
CsvSerialization	Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu CSV.
DiagnosticCondition	Podmínka vztahující se na prostředek nebo celkovou úlohu, která vyžaduje pozornost zákazníka.
Diagnostics	Popisuje podmínky vztahující se na vstup, výstup nebo celkovou úlohu, které vyžadují pozornost zákazníka.
DocumentDbOutputDataSource	Popisuje výstupní zdroj dat DocumentDB.
Encoding	Určuje kódování příchozích dat v případě vstupu a kódování odchozích dat v případě výstupu.
Error	Běžná reprezentace chyb
EventHubOutputDataSource	Popisuje výstupní zdroj dat centra událostí.
EventHubStreamInputDataSource	Popisuje vstupní zdroj dat centra událostí, který obsahuje streamová data.
EventHubV2OutputDataSource	Popisuje výstupní zdroj dat centra událostí.
EventHubV2StreamInputDataSource	Popisuje vstupní zdroj dat centra událostí, který obsahuje streamová data.
EventSerializationType	Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).
EventsOutOfOrderPolicy	Označuje zásadu, která se má použít pro události, které přicházejí mimo pořadí ve vstupním streamu událostí.
FileReferenceInputDataSource	Popisuje vstupní zdroj dat souboru, který obsahuje referenční data.
Function	Objekt funkce obsahující všechny informace přidružené k pojmenované funkci. Všechny funkce jsou obsažené v úloze streamování.
FunctionInput	Popisuje jeden vstupní parametr funkce.
FunctionOutput	Popisuje výstup funkce.
GatewayMessageBusOutputDataSource	Popisuje výstupní zdroj dat sběrnice zpráv brány.
GatewayMessageBusStreamInputDataSource	Popisuje vstupní zdroj dat objektu blob, který obsahuje streamová data.
Identity	Popisuje, jak se identita ověřuje.
Input	Vstupní objekt obsahující všechny informace spojené s pojmenovaným vstupem. Všechny vstupy jsou obsažené v úloze streamování.
IoTHubStreamInputDataSource	Popisuje IoT Hub vstupní zdroj dat, který obsahuje streamová data.
JavaScriptFunctionBinding	Vazba na funkci JavaScriptu.
JobStorageAccount	Vlastnosti přidružené k účtu služby Azure Storage s MSI
JobType	Popisuje typ úlohy. Platnými režimy jsou Cloud a Edge.
JsonOutputSerializationFormat	Určuje formát JSON, ve kterém se bude výstup zapisovat. Aktuálně podporované hodnoty jsou lineSeparated, což znamená, že výstup bude formátován tak, že každý objekt JSON bude oddělený novým řádkem a pole, které označuje, že výstup bude formátován jako pole objektů JSON.
JsonSerialization	Popisuje, jak jsou data ze vstupu serializována nebo jak se data serializují při zápisu do výstupu ve formátu JSON.
Output	Výstupní objekt obsahující všechny informace spojené s pojmenovaným výstupem. Všechny výstupy jsou obsaženy v rámci úlohy streamování.
OutputErrorPolicy	Označuje zásadu, která se má použít pro události, které přicházejí do výstupu a nelze je zapsat do externího úložiště kvůli poškození (chybějící hodnoty sloupců, hodnoty sloupců nesprávného typu nebo velikosti).
OutputStartMode	Hodnota může být JobStartTime, CustomTime nebo LastOutputEventTime, která označuje, jestli se má počáteční bod výstupního datového proudu událostí spouštět při každém spuštění úlohy, jestli se má spustit s vlastním časovým razítkem uživatele zadaným prostřednictvím vlastnosti outputStartTime nebo jestli má začít od posledního výstupního času události.
ParquetSerialization	Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu Parquet.
PowerBIOutputDataSource	Popisuje výstupní zdroj dat Power BI.
ReferenceInputProperties	Vlastnosti, které jsou přidruženy ke vstupu obsahujícího referenční data.
RefreshType	Označuje typ možnosti aktualizace dat.
ScalarFunctionProperties	Vlastnosti, které jsou přidruženy ke skalární funkci.
ServiceBusQueueOutputDataSource	Popisuje výstupní zdroj dat fronty služby Service Bus.
ServiceBusTopicOutputDataSource	Popisuje výstupní zdroj dat tématu služby Service Bus.
Sku	Vlastnosti, které jsou přidruženy k SKU.
SkuName	Název skladové položky. Vyžaduje se u požadavků PUT (CreateOrReplace).
StorageAccount	Vlastnosti přidružené k účtu služby Azure Storage
StreamingJob	Objekt úlohy streamování obsahující všechny informace přidružené k pojmenované úloze streamování.
StreamInputProperties	Vlastnosti, které jsou přidruženy ke vstupu obsahujícímu data datového proudu.
Transformation	Objekt transformace obsahující všechny informace přidružené k pojmenované transformaci. Všechny transformace jsou obsaženy v rámci úlohy streamování.

AggregateFunctionProperties

Vlastnosti, které jsou přidruženy k agregační funkci.

Name	Typ	Description
etag	string	Aktuální značka entity pro funkci. Jedná se o neprůsvný řetězec. Můžete ho použít ke zjištění, jestli se prostředek mezi požadavky změnil. Můžete ho také použít v hlavičce If-Match nebo If-None-Match pro operace zápisu pro zajištění optimistické souběžnosti.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Fyzická vazba funkce. Například v případě webové služby Azure Machine Learning to popisuje koncový bod.
properties.inputs	FunctionInput[]	Popisuje jeden vstupní parametr funkce.
properties.output	FunctionOutput	Popisuje výstup funkce.
type	string: Aggregate	Označuje typ funkce.

AuthenticationMode

Režim ověřování. Platné režimy jsou ConnectionString, Msi a 'UserToken'.

Name	Typ	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu Avro.

Name	Typ	Description
type	string: Avro	Označuje typ serializace, který vstup nebo výstup používá. Vyžaduje se u požadavků PUT (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Popisuje výstupní zdroj dat Azure Data Lake Store.

Name	Typ	Default value	Description
properties.accountName	string		Název účtu Azure Data Lake Store. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.dateFormat	string		Formát data. Kdykoli se {date} zobrazí v souboru filePathPrefix, hodnota této vlastnosti se místo toho použije jako formát data.
properties.filePathPrefix	string		Umístění souboru, do kterého má být výstup zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.refreshToken	string		Obnovovací token, který lze použít k získání platného přístupového tokenu, který se pak dá použít k ověření se zdrojem dat. Platný obnovovací token je v současné době možné získat pouze prostřednictvím webu Azure Portal. Při vytváření zdroje dat se doporučuje sem vložit fiktivní hodnotu řetězce a pak přejít na web Azure Portal k ověření zdroje dat, čímž se tato vlastnost aktualizuje platným obnovovacím tokenem. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.tenantId	string		ID tenanta uživatele použitého k získání obnovovacího tokenu Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.timeFormat	string		Formát času. Kdykoli se {time} zobrazí v souboru filePathPrefix, použije se jako formát času hodnota této vlastnosti.
properties.tokenUserDisplayName	string		Zobrazované jméno uživatele, který byl použit k získání obnovovacího tokenu. Tato vlastnost vám pomůže zapamatovat si, který uživatel byl použit k získání obnovovacího tokenu.
properties.tokenUserPrincipalName	string		Hlavní název uživatele (UPN) uživatele, který byl použit k získání obnovovacího tokenu. Tato vlastnost vám pomůže zapamatovat si, který uživatel byl použit k získání obnovovacího tokenu.
type	string: Microsoft.DataLake/Accounts		Označuje typ výstupu zdroje dat, do které bude zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).

AzureFunctionOutputDataSource

Definuje metadata azureFunctionOutputDataSource.

Name	Typ	Description
properties.apiKey	string	Pokud chcete použít funkci Azure Functions z jiného předplatného, můžete to udělat tak, že zadáte klíč pro přístup k funkci.
properties.functionAppName	string	Název aplikace Azure Functions.
properties.functionName	string	Název funkce v aplikaci Azure Functions.
properties.maxBatchCount	number	Vlastnost, která umožňuje zadat maximální počet událostí v každé dávce odesílané do Azure Functions. Výchozí hodnota je 100.
properties.maxBatchSize	number	Vlastnost, která umožňuje nastavit maximální velikost pro každou výstupní dávku odesílanou do funkce Azure. Vstupní jednotka je v bajtech. Ve výchozím nastavení je tato hodnota 262 144 bajtů (256 kB).
type	string: Microsoft.AzureFunction	Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

Vazba na webovou službu Azure Machine Learning.

Name	Typ	Description
properties.apiKey	string	Klíč rozhraní API použitý k ověření pomocí koncového bodu Request-Response.
properties.batchSize	integer	Číslo mezi 1 a 10 000 popisující maximální počet řádků pro každou žádost o spuštění azure ML RRS. Výchozí hodnota je 1000.
properties.endpoint	string	Request-Response spustit koncový bod webové služby Azure Machine Learning. Další informace najdete tady: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
properties.inputs	AzureMachineLearningWebServiceInputs	Vstupy pro koncový bod webové služby Azure Machine Learning.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Seznam výstupů ze spuštění koncového bodu webové služby Azure Machine Learning
type	string: Microsoft.MachineLearning/WebService	Označuje typ vazby funkce.

AzureMachineLearningWebServiceInputColumn

Popisuje vstupní sloupec pro koncový bod webové služby Azure Machine Learning.

Name	Typ	Description
dataType	string	Datový typ vstupního sloupce (podporuje Se službou Azure Machine Learning). Seznam platných datových typů služby Azure Machine Learning najdete v tématu https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
mapTo	integer	Nulový index parametru funkce, na který se tento vstup mapuje.
name	string	Název vstupního sloupce.

AzureMachineLearningWebServiceInputs

Vstupy pro koncový bod webové služby Azure Machine Learning.

Name	Typ	Description
columnNames	AzureMachineLearningWebServiceInputColumn[]	Seznam vstupních sloupců pro koncový bod webové služby Azure Machine Learning
name	string	Název vstupu. Jedná se o název zadaný při vytváření koncového bodu.

AzureMachineLearningWebServiceOutputColumn

Popisuje výstupní sloupec pro koncový bod webové služby Azure Machine Learning.

Name	Typ	Description
dataType	string	Datový typ výstupního sloupce (podporuje Se službou Azure Machine Learning). Seznam platných datových typů služby Azure Machine Learning najdete v tématu https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
name	string	Název výstupního sloupce.

AzureSqlDatabaseOutputDataSource

Popisuje výstupní zdroj dat Azure SQL databáze.

Name	Typ	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.database	string		Název databáze Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.maxBatchCount	number		Maximální počet dávek pro zápis do databáze SQL, výchozí hodnota je 10 000. Volitelné u požadavků PUT.
properties.maxWriterCount	number		K dispozici je maximální počet zapisovačů, aktuálně je k dispozici pouze 1 (jeden zapisovač) a 0 (na základě oddílu dotazu). Volitelné u požadavků PUT.
properties.password	string		Heslo, které se použije pro připojení k databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.server	string		Název serveru SQL obsahujícího databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.table	string		Název tabulky v databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.user	string		Uživatelské jméno, které se použije pro připojení k databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/Database		Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Popisuje referenční vstupní zdroj dat Azure SQL databáze.

Name	Typ	Description
properties.database	string	Tento prvek je přidružen k elementu zdroje dat. Toto je název databáze, do které se zapíše výstup.
properties.deltaSnapshotQuery	string	Tento prvek je přidružen k elementu zdroje dat. Tento dotaz se používá k načtení přírůstkových změn z databáze SQL. Pokud chcete použít tuto možnost, doporučujeme ve službě Azure SQL Database používat dočasné tabulky.
properties.fullSnapshotQuery	string	Tento prvek je přidružen k elementu zdroje dat. Tento dotaz se používá k načtení dat z databáze SQL.
properties.password	string	Tento prvek je přidružen k elementu zdroje dat. Toto je heslo, které se použije pro připojení k instanci SQL Database.
properties.refreshRate	string	Tento prvek je přidružen k elementu zdroje dat. To určuje, jak často se budou data načítat z databáze. Má formát DateTime.
properties.refreshType	RefreshType	Označuje typ možnosti aktualizace dat.
properties.server	string	Tento prvek je přidružen k elementu zdroje dat. Toto je název serveru, který obsahuje databázi, na kterou se bude zapisovat.
properties.table	string	Tento prvek je přidružen k elementu zdroje dat. Název tabulky v databázi Azure SQL.
properties.user	string	Tento prvek je přidružen k elementu zdroje dat. Toto je uživatelské jméno, které se použije pro připojení k instanci SQL Database.
type	string: Microsoft.Sql/Server/Database	Určuje typ vstupního zdroje dat obsahujícího referenční data. Vyžaduje se u požadavků PUT (CreateOrReplace).

AzureSynapseOutputDataSource

Popisuje Azure Synapse výstupní zdroj dat.

Name	Typ	Description
properties.database	string	Název databáze Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.password	string	Heslo, které se použije pro připojení k databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.server	string	Název serveru SQL obsahujícího databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.table	string	Název tabulky v databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.user	string	Uživatelské jméno, které se použije pro připojení k databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/DataWarehouse	Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).

AzureTableOutputDataSource

Popisuje výstupní zdroj dat Tabulky Azure.

Name	Typ	Description
properties.accountKey	string	Klíč účtu pro účet Služby Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.accountName	string	Název účtu služby Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.batchSize	integer	Počet řádků, které se mají zapisovat do tabulky Azure najednou.
properties.columnsToRemove	string[]	Pokud je tato položka zadána, každá položka v poli je názvem sloupce, který se má z výstupních entit událostí odebrat (pokud je k dispozici).
properties.partitionKey	string	Tento element označuje název sloupce z příkazu SELECT v dotazu, který se použije jako klíč oddílu pro tabulku Azure. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.rowKey	string	Tento element označuje název sloupce z příkazu SELECT v dotazu, který se použije jako klíč řádku pro tabulku Azure. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.table	string	Název tabulky Azure. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Microsoft.Storage/Table	Označuje typ výstupu zdroje dat, do které bude zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).

BlobOutputDataSource

Popisuje výstupní zdroj dat objektu blob.

Name	Typ	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.blobPathPrefix	string		Předpona cesty k objektu blob.
properties.container	string		Název kontejneru v rámci přidruženého účtu úložiště. Tento kontejner obsahuje objekty blob, ze které se mají číst, nebo do které se zapisuje. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.dateFormat	string		Formát data. Kdykoli se {date} zobrazí v pathPattern, použije se jako formát data hodnota této vlastnosti.
properties.pathPattern	string		Vzor cesty k objektu blob. Nejedná se o regulární výraz. Představuje vzor, podle kterého se názvy objektů blob budou shodovat, aby bylo možné určit, jestli se mají zahrnout jako vstup nebo výstup do úlohy. Podrobnější vysvětlení a příklad najdete https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input v tématu nebo https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output .
properties.storageAccounts	StorageAccount[]		Seznam jednoho nebo více účtů Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.timeFormat	string		Formát času. Kdykoli se {time} zobrazí v pathPattern, použije se jako formát času hodnota této vlastnosti.
type	string: Microsoft.Storage/Blob		Označuje typ výstupu zdroje dat, do které bude zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).

BlobReferenceInputDataSource

Popisuje vstupní zdroj dat objektu blob, který obsahuje referenční data.

Name	Typ	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.container	string		Název kontejneru v rámci přidruženého účtu úložiště. Tento kontejner obsahuje buď objekty blob, ze které se mají číst, nebo do které se mají zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.dateFormat	string		Formát data. Kdykoli se {date} zobrazí v pathPattern, použije se jako formát data hodnota této vlastnosti.
properties.pathPattern	string		Vzor cesty k objektu blob Nejedná se o regulární výraz. Představuje vzor, podle kterého se budou názvy objektů blob shodovat, aby bylo možné určit, jestli se mají zahrnout jako vstup nebo výstup do úlohy. Podrobnější vysvětlení a příklad najdete v tématu https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input nebo https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output .
properties.storageAccounts	StorageAccount[]		Seznam jednoho nebo více účtů Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.timeFormat	string		Formát času. Kdykoli se {time} zobrazí v pathPattern, použije se jako formát času hodnota této vlastnosti.
type	string: Microsoft.Storage/Blob		Určuje typ vstupního zdroje dat obsahujícího referenční data. Vyžaduje se u požadavků PUT (CreateOrReplace).

BlobStreamInputDataSource

Popisuje vstupní zdroj dat objektu blob, který obsahuje streamová data.

Name	Typ	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.container	string		Název kontejneru v rámci přidruženého účtu úložiště. Tento kontejner obsahuje buď objekty blob, ze které se mají číst, nebo do které se mají zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.dateFormat	string		Formát data. Kdykoli se {date} zobrazí v pathPattern, použije se jako formát data hodnota této vlastnosti.
properties.pathPattern	string		Vzor cesty k objektu blob Nejedná se o regulární výraz. Představuje vzor, podle kterého se budou názvy objektů blob shodovat, aby bylo možné určit, jestli se mají zahrnout jako vstup nebo výstup do úlohy. Podrobnější vysvětlení a příklad najdete v tématu https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input nebo https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output .
properties.sourcePartitionCount	integer		Počet oddílů vstupního zdroje dat objektu blob. Rozsah 1 až 1024.
properties.storageAccounts	StorageAccount[]		Seznam jednoho nebo více účtů Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.timeFormat	string		Formát času. Kdykoli se {time} zobrazí v pathPattern, použije se jako formát času hodnota této vlastnosti.
type	string: Microsoft.Storage/Blob		Označuje typ vstupního zdroje dat, který obsahuje streamová data. Vyžaduje se u požadavků PUT (CreateOrReplace).

ClusterInfo

Vlastnosti přidružené ke clusteru Stream Analytics.

Name	Typ	Description
id	string	ID prostředku clusteru.

CompatibilityLevel

Řídí určité chování úlohy streamování za běhu.

Name	Typ	Description
1.0	string
1.2	string

Compression

Popisuje, jak se komprimují vstupní data.

Name	Typ	Default value	Description
type	CompressionType	None	Označuje typ komprese, kterou vstup používá. Vyžaduje se u požadavků PUT (CreateOrReplace).

CompressionType

Určuje typ komprese, kterou vstup používá. Vyžaduje se u požadavků PUT (CreateOrReplace).

Name	Typ	Description
Deflate	string
GZip	string
None	string

ContentStoragePolicy

Platné hodnoty jsou JobStorageAccount a SystemAccount. Pokud je nastavená hodnota JobStorageAccount, vyžaduje, aby uživatel zadal také vlastnost jobStorageAccount. .

Name	Typ	Description
JobStorageAccount	string
SystemAccount	string

CsvSerialization

Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu CSV.

Name	Typ	Description
properties.encoding	Encoding	Určuje kódování příchozích dat v případě vstupu a kódování odchozích dat v případě výstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.fieldDelimiter	string	Určuje oddělovač, který se použije k oddělení záznamů hodnot oddělených čárkami (CSV). https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output Podívejte https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input se na nebo seznam podporovaných hodnot. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Csv	Označuje typ serializace, který vstup nebo výstup používá. Vyžaduje se u požadavků PUT (CreateOrReplace).

DiagnosticCondition

Podmínka vztahující se na prostředek nebo celkovou úlohu, která vyžaduje pozornost zákazníka.

Name	Typ	Description
code	string	Neprůsvný diagnostický kód.
message	string	Zpráva čtivá pro člověka, která podrobně popisuje podmínku. Lokalizované v Accept-Language požadavku klienta.
since	string	Časové razítko UTC, kdy se podmínka spustila. Zákazníci by měli být schopni najít odpovídající událost v protokolu operace přibližně v tomto čase.

Diagnostics

Popisuje podmínky vztahující se na vstup, výstup nebo celkovou úlohu, které vyžadují pozornost zákazníka.

Name	Typ	Description
conditions	DiagnosticCondition[]	Kolekce nulových nebo více podmínek vztahujících se na prostředek nebo na celkovou úlohu, které vyžadují pozornost zákazníka.

DocumentDbOutputDataSource

Popisuje výstupní zdroj dat DocumentDB.

Name	Typ	Description
properties.accountId	string	Název nebo ID účtu DocumentDB. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.accountKey	string	Klíč účtu DocumentDB. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.collectionNamePattern	string	Vzor názvu kolekce pro kolekce, které se mají použít. Formát názvu kolekce je možné vytvořit pomocí volitelného tokenu {partition}, kde oddíly začínají hodnotou 0. Další informace najdete v části DocumentDB v souboru https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output . Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.database	string	Název databáze DocumentDB. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.documentId	string	Název pole ve výstupních událostech, které slouží k určení primárního klíče, na kterém jsou založeny operace vložení nebo aktualizace.
properties.partitionKey	string	Název pole ve výstupních událostech, které slouží k určení klíče pro dělení výstupu mezi kolekcemi. Pokud collectionNamePattern obsahuje token {partition}, je nutné zadat tuto vlastnost.
type	string: Microsoft.Storage/DocumentDB	Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).

Encoding

Určuje kódování příchozích dat v případě vstupu a kódování odchozích dat v případě výstupu.

Name	Typ	Description
UTF8	string

Error

Běžná reprezentace chyb

Name	Typ	Description
error	Error	Vlastnosti definice chyby.

EventHubOutputDataSource

Popisuje výstupní zdroj dat centra událostí.

Name	Typ	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.eventHubName	string		Název centra událostí. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.partitionKey	string		Klíč/sloupec, který se používá k určení oddílu, do kterého se mají odesílat data událostí.
properties.propertyColumns	string[]		Vlastnosti přidružené k tomuto výstupu centra událostí.
serviceBusNamespace	string		Obor názvů přidružený k požadovanému centru událostí, frontě služby Service Bus, tématu služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Klíč zásad sdíleného přístupu pro zadanou zásadu sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
sharedAccessPolicyName	string		Název zásady sdíleného přístupu pro centrum událostí, frontu služby Service Bus, téma služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Označuje typ výstupu zdroje dat, do které bude zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).

EventHubStreamInputDataSource

Popisuje vstupní zdroj dat centra událostí, který obsahuje streamová data.

Name	Typ	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.consumerGroupName	string		Název skupiny uživatelů centra událostí, který by se měl použít ke čtení událostí z centra událostí. Zadáním jedinečných názvů skupin příjemců pro více vstupů umožníte každému z těchto vstupů přijímat stejné události z centra událostí. Pokud není zadaný, vstup použije výchozí skupinu příjemců centra událostí.
properties.eventHubName	string		Název centra událostí. Vyžaduje se u požadavků PUT (CreateOrReplace).
serviceBusNamespace	string		Obor názvů přidružený k požadovanému centru událostí, frontě služby Service Bus, tématu služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Klíč zásad sdíleného přístupu pro zadanou zásadu sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
sharedAccessPolicyName	string		Název zásady sdíleného přístupu pro centrum událostí, frontu služby Service Bus, téma služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Označuje typ vstupního zdroje dat, který obsahuje streamová data. Vyžaduje se u požadavků PUT (CreateOrReplace).

EventHubV2OutputDataSource

Popisuje výstupní zdroj dat centra událostí.

Name	Typ	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.eventHubName	string		Název centra událostí. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.partitionKey	string		Klíč/sloupec, který se používá k určení oddílu, do kterého se mají odesílat data událostí.
properties.propertyColumns	string[]		Vlastnosti přidružené k tomuto výstupu centra událostí
serviceBusNamespace	string		Obor názvů přidružený k požadovanému centru událostí, frontě služby Service Bus, tématu služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Klíč zásad sdíleného přístupu pro zadanou zásadu sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
sharedAccessPolicyName	string		Název zásady sdíleného přístupu pro centrum událostí, frontu služby Service Bus, téma služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Popisuje vstupní zdroj dat centra událostí, který obsahuje streamová data.

Name	Typ	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.consumerGroupName	string		Název skupiny uživatelů centra událostí, který by se měl použít ke čtení událostí z centra událostí. Zadáním jedinečných názvů skupin příjemců pro více vstupů umožníte každému z těchto vstupů přijímat stejné události z centra událostí. Pokud není zadaný, vstup použije výchozí skupinu příjemců centra událostí.
properties.eventHubName	string		Název centra událostí. Vyžaduje se u požadavků PUT (CreateOrReplace).
serviceBusNamespace	string		Obor názvů přidružený k požadovanému centru událostí, frontě služby Service Bus, tématu služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Klíč zásad sdíleného přístupu pro zadanou zásadu sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
sharedAccessPolicyName	string		Název zásady sdíleného přístupu pro centrum událostí, frontu služby Service Bus, téma služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Označuje typ vstupního zdroje dat, který obsahuje streamová data. Vyžaduje se u požadavků PUT (CreateOrReplace).

EventSerializationType

Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).

Name	Typ	Description
Avro	string
Csv	string
Json	string
Parquet	string

EventsOutOfOrderPolicy

Označuje zásadu, která se má použít pro události, které přicházejí mimo pořadí ve vstupním streamu událostí.

Name	Typ	Description
Adjust	string
Drop	string

FileReferenceInputDataSource

Popisuje vstupní zdroj dat souboru, který obsahuje referenční data.

Name	Typ	Description
properties.path	string	Cesta k souboru.
type	string: File	Určuje typ vstupního zdroje dat obsahujícího referenční data. Vyžaduje se u požadavků PUT (CreateOrReplace).

Function

Objekt funkce obsahující všechny informace přidružené k pojmenované funkci. Všechny funkce jsou obsažené v úloze streamování.

Name	Typ	Description
id	string	ID prostředku
name	string	Název prostředku
properties	FunctionProperties: AggregateFunctionProperties ScalarFunctionProperties	Vlastnosti, které jsou přidruženy k funkci.
type	string	Typ prostředku

FunctionInput

Popisuje jeden vstupní parametr funkce.

Name	Typ	Description
dataType	string	Datový typ vstupního parametru funkce (podporuje Se službou Azure Stream Analytics). Seznam platných datových typů Azure Stream Analytics je popsaný v tématu https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	Příznak označující, jestli je parametr parametrem konfigurace. True, pokud se očekává, že tento vstupní parametr bude konstantou. Výchozí hodnota je false.

FunctionOutput

Popisuje výstup funkce.

Name	Typ	Description
dataType	string	Datový typ výstupu funkce (podporuje Se službou Azure Stream Analytics). Seznam platných datových typů Azure Stream Analytics je popsaný v tématu https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

Popisuje výstupní zdroj dat sběrnice zpráv brány.

Name	Typ	Description
properties.topic	string	Název tématu služby Service Bus.
type	string: GatewayMessageBus	Označuje typ výstupu zdroje dat, do které bude zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Popisuje vstupní zdroj dat objektu blob, který obsahuje streamová data.

Name	Typ	Description
properties.topic	string	Název tématu služby Service Bus.
type	string: GatewayMessageBus	Označuje typ vstupního zdroje dat, který obsahuje streamová data. Vyžaduje se u požadavků PUT (CreateOrReplace).

Identity

Popisuje, jak se identita ověřuje.

Name	Typ	Description
principalId	string	ID objektu zabezpečení identity
tenantId	string	Id tenanta identity
type	string	Typ identity

Input

Vstupní objekt obsahující všechny informace spojené s pojmenovaným vstupem. Všechny vstupy jsou obsažené v úloze streamování.

Name	Typ	Description
id	string	ID prostředku
name	string	Název prostředku
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Vlastnosti, které jsou přidruženy ke vstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string	Typ prostředku

IoTHubStreamInputDataSource

Popisuje IoT Hub vstupní zdroj dat, který obsahuje streamová data.

Name	Typ	Description
properties.consumerGroupName	string	Název skupiny uživatelů IoT Hub, který se má použít ke čtení událostí z IoT Hub. Pokud není zadaný, vstup použije výchozí skupinu příjemců iot Hubu.
properties.endpoint	string	IoT Hub koncový bod, ke kterému se chcete připojit (tj. messages/events, messages/operationsMonitoringEvents atd.).
properties.iotHubNamespace	string	Název nebo identifikátor URI IoT Hub. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Klíč zásad sdíleného přístupu pro zadanou zásadu sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Název zásady sdíleného přístupu pro IoT Hub. Tato zásada musí obsahovat alespoň oprávnění připojení ke službě. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Označuje typ vstupního zdroje dat, který obsahuje streamová data. Vyžaduje se u požadavků PUT (CreateOrReplace).

JavaScriptFunctionBinding

Vazba na funkci JavaScriptu.

Name	Typ	Description
properties.script	string	Kód JavaScriptu obsahující jednu definici funkce. Příklad: 'function (x, y) { return x + y; }'
type	string: Microsoft.StreamAnalytics/JavascriptUdf	Označuje typ vazby funkce.

JobStorageAccount

Vlastnosti přidružené k účtu služby Azure Storage s MSI

Name	Typ	Default value	Description
accountKey	string		Klíč účtu pro účet Služby Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
accountName	string		Název účtu služby Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.

JobType

Popisuje typ úlohy. Platnými režimy jsou Cloud a Edge.

Name	Typ	Description
Cloud	string
Edge	string

JsonOutputSerializationFormat

Určuje formát JSON, ve kterém se bude výstup zapisovat. Aktuálně podporované hodnoty jsou lineSeparated, což znamená, že výstup bude formátován tak, že každý objekt JSON bude oddělený novým řádkem a pole, které označuje, že výstup bude formátován jako pole objektů JSON.

Name	Typ	Description
Array	string
LineSeparated	string

JsonSerialization

Popisuje, jak jsou data ze vstupu serializována nebo jak se data serializují při zápisu do výstupu ve formátu JSON.

Name	Typ	Description
properties.encoding	Encoding	Určuje kódování příchozích dat v případě vstupu a kódování odchozích dat v případě výstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Tato vlastnost se vztahuje pouze na serializaci výstupů JSON. Nevztahuje se na vstupy. Tato vlastnost určuje formát JSON, ve kterém bude výstup zapsán. Aktuálně podporované hodnoty jsou "lineSeparated", což znamená, že výstup bude formátován tak, že každý objekt JSON bude oddělený novým řádkem a pole označující, že výstup bude formátován jako pole objektů JSON. Výchozí hodnota je "lineSeparated", pokud je vlevo null.
type	string: Json	Označuje typ serializace, který vstup nebo výstup používá. Vyžaduje se u požadavků PUT (CreateOrReplace).

Output

Výstupní objekt obsahující všechny informace spojené s pojmenovaným výstupem. Všechny výstupy jsou obsaženy v rámci úlohy streamování.

Name	Typ	Description
id	string	ID prostředku
name	string	Název prostředku
properties.datasource	OutputDataSource: AzureDataLakeStoreOutputDataSource AzureFunctionOutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource AzureTableOutputDataSource BlobOutputDataSource DocumentDbOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource GatewayMessageBusOutputDataSource PowerBIOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource	Popisuje zdroj dat, do kterého bude výstup zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.diagnostics	Diagnostics	Popisuje podmínky vztahující se na vstup, výstup nebo celkovou úlohu, které vyžadují pozornost zákazníka.
properties.etag	string	Aktuální značka entity pro výstup. Jedná se o neprůsvný řetězec. Můžete ho použít ke zjištění, jestli se prostředek mezi požadavky změnil. Můžete ho také použít v hlavičce If-Match nebo If-None-Match pro operace zápisu pro zajištění optimistické souběžnosti.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.sizeWindow	integer	Okno velikosti, na které se má výstup Stream Analytics omezit.
properties.timeWindow	string	Časový rámec pro filtrování výstupů úloh Stream Analytics
type	string	Typ prostředku

OutputErrorPolicy

Označuje zásadu, která se má použít pro události, které přicházejí do výstupu a nelze je zapsat do externího úložiště kvůli poškození (chybějící hodnoty sloupců, hodnoty sloupců nesprávného typu nebo velikosti).

Name	Typ	Description
Drop	string
Stop	string

OutputStartMode

Hodnota může být JobStartTime, CustomTime nebo LastOutputEventTime, která označuje, jestli se má počáteční bod výstupního datového proudu událostí spouštět při každém spuštění úlohy, jestli se má spustit s vlastním časovým razítkem uživatele zadaným prostřednictvím vlastnosti outputStartTime nebo jestli má začít od posledního výstupního času události.

Name	Typ	Description
CustomTime	string
JobStartTime	string
LastOutputEventTime	string

ParquetSerialization

Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu Parquet.

Name	Typ	Description
type	string: Parquet	Označuje typ serializace, který vstup nebo výstup používá. Vyžaduje se u požadavků PUT (CreateOrReplace).

PowerBIOutputDataSource

Popisuje výstupní zdroj dat Power BI.

Name	Typ	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.dataset	string		Název datové sady Power BI. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.groupId	string		ID skupiny Power BI.
properties.groupName	string		Název skupiny Power BI. Tato vlastnost vám pomůže zapamatovat si, jaké konkrétní ID skupiny Power BI se použilo.
properties.refreshToken	string		Obnovovací token, který lze použít k získání platného přístupového tokenu, který se pak dá použít k ověření se zdrojem dat. Platný obnovovací token je v současné době možné získat pouze prostřednictvím webu Azure Portal. Při vytváření zdroje dat se doporučuje sem vložit fiktivní hodnotu řetězce a pak přejít na web Azure Portal k ověření zdroje dat, čímž se tato vlastnost aktualizuje platným obnovovacím tokenem. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.table	string		Název tabulky Power BI v zadané datové sadě Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.tokenUserDisplayName	string		Zobrazované jméno uživatele, který byl použit k získání obnovovacího tokenu. Tato vlastnost vám pomůže zapamatovat si, který uživatel byl použit k získání obnovovacího tokenu.
properties.tokenUserPrincipalName	string		Hlavní název uživatele (UPN) uživatele, který byl použit k získání obnovovacího tokenu. Tato vlastnost vám pomůže zapamatovat si, který uživatel byl použit k získání obnovovacího tokenu.
type	string: PowerBI		Označuje typ výstupu zdroje dat, do které bude zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).

ReferenceInputProperties

Vlastnosti, které jsou přidruženy ke vstupu obsahujícího referenční data.

Name	Typ	Description
compression	Compression	Popisuje, jak se komprimují vstupní data.
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Popisuje vstupní zdroj dat, který obsahuje referenční data. Vyžaduje se u požadavků PUT (CreateOrReplace).
diagnostics	Diagnostics	Popisuje podmínky vztahující se na vstup, výstup nebo celkovou úlohu, které vyžadují pozornost zákazníka.
etag	string	Aktuální značka entity pro vstup. Jedná se o neprůsvný řetězec. Můžete ho použít ke zjištění, jestli se prostředek mezi požadavky změnil. Můžete ho také použít v hlavičce If-Match nebo If-None-Match pro operace zápisu pro zajištění optimistické souběžnosti.
partitionKey	string	partitionKey Popisuje klíč ve vstupních datech, který se používá k dělení vstupních dat.
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Reference	Určuje, jestli je vstup zdrojem referenčních dat nebo datových proudů. Vyžaduje se u požadavků PUT (CreateOrReplace).

RefreshType

Označuje typ možnosti aktualizace dat.

Name	Typ	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

ScalarFunctionProperties

Vlastnosti, které jsou přidruženy ke skalární funkci.

Name	Typ	Description
etag	string	Aktuální značka entity pro funkci. Jedná se o neprůsvný řetězec. Můžete ho použít ke zjištění, jestli se prostředek mezi požadavky změnil. Můžete ho také použít v hlavičce If-Match nebo If-None-Match pro operace zápisu pro zajištění optimistické souběžnosti.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Fyzická vazba funkce. Například v případě webové služby Azure Machine Learning to popisuje koncový bod.
properties.inputs	FunctionInput[]	Popisuje jeden vstupní parametr funkce.
properties.output	FunctionOutput	Popisuje výstup funkce.
type	string: Scalar	Označuje typ funkce.

ServiceBusQueueOutputDataSource

Popisuje výstupní zdroj dat fronty služby Service Bus.

Name	Typ	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.propertyColumns	string[]		Pole řetězců názvů výstupních sloupců, které mají být připojeny ke zprávě služby Service Bus jako vlastní vlastnosti.
properties.queueName	string		Název fronty služby Service Bus. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.serviceBusNamespace	string		Obor názvů přidružený k požadovanému centru událostí, frontě služby Service Bus, tématu služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Klíč zásad sdíleného přístupu pro zadanou zásadu sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		Název zásady sdíleného přístupu pro centrum událostí, frontu služby Service Bus, téma služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.systemPropertyColumns	object		Systémové vlastnosti přidružené k frontě služby Service Bus. Podporují se následující systémové vlastnosti: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
type	string: Microsoft.ServiceBus/Queue		Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).

ServiceBusTopicOutputDataSource

Popisuje výstupní zdroj dat tématu služby Service Bus.

Name	Typ	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.propertyColumns	string[]		Pole řetězců názvů výstupních sloupců, které mají být připojeny ke zprávě služby Service Bus jako vlastní vlastnosti.
properties.serviceBusNamespace	string		Obor názvů přidružený k požadovanému centru událostí, frontě služby Service Bus, tématu služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Klíč zásad sdíleného přístupu pro zadanou zásadu sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		Název zásady sdíleného přístupu pro centrum událostí, frontu služby Service Bus, téma služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.systemPropertyColumns	object		Systémové vlastnosti přidružené k výstupu tématu služby Service Bus. Podporují se následující systémové vlastnosti: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
properties.topicName	string		Název tématu služby Service Bus. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/Topic		Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).

Sku

Vlastnosti, které jsou přidruženy k SKU.

Name	Typ	Description
name	SkuName	Název skladové položky. Vyžaduje se u požadavků PUT (CreateOrReplace).

SkuName

Název skladové položky. Vyžaduje se u požadavků PUT (CreateOrReplace).

Name	Typ	Description
Standard	string

StorageAccount

Vlastnosti přidružené k účtu služby Azure Storage

Name	Typ	Description
accountKey	string	Klíč účtu pro účet služby Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
accountName	string	Název účtu služby Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).

StreamingJob

Objekt úlohy streamování obsahující všechny informace přidružené k pojmenované úloze streamování.

Name	Typ	Description
id	string	Plně kvalifikované ID prostředku. Příklad – /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Popisuje spravovanou identitu přiřazenou systémem přiřazenou k této úloze, která se dá použít k ověřování se vstupy a výstupy.
location	string	Geografické umístění, ve kterém se nachází prostředek
name	string	Název prostředku
properties.cluster	ClusterInfo	Cluster, ve kterém se budou spouštět úlohy streamování.
properties.compatibilityLevel	CompatibilityLevel	Řídí určité chování úlohy streamování za běhu.
properties.contentStoragePolicy	ContentStoragePolicy	Platné hodnoty jsou JobStorageAccount a SystemAccount. Pokud je nastavená hodnota JobStorageAccount, vyžaduje, aby uživatel zadal také vlastnost jobStorageAccount. .
properties.createdDate	string	Hodnota je časové razítko UTC ve formátu ISO-8601, které označuje, kdy byla úloha streamování vytvořena.
properties.dataLocale	string	Národní prostředí dat úlohy stream analytics. Hodnota by měla být název podporované jazykové verze .NET ze sady https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Výchozí hodnota je en-US, pokud není zadána žádná.
properties.etag	string	Aktuální značka entity pro úlohu streamování Jedná se o neprůsvný řetězec. Můžete ho použít ke zjištění, jestli se prostředek mezi požadavky změnil. Můžete ho také použít v hlavičce If-Match nebo If-None-Match pro operace zápisu pro zajištění optimistické souběžnosti.
properties.eventsLateArrivalMaxDelayInSeconds	integer	Maximální tolerovatelné zpoždění v sekundách, kdy je možné zahrnout události přicházející pozdě. Podporovaný rozsah je -1 až 1814399 (20.23:59:59 dní) a -1 se používá k určení čekání na dobu neurčitou. Pokud vlastnost chybí, je interpretována tak, aby měla hodnotu -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	Maximální přípustné zpoždění v sekundách, kdy se události mimo pořadí dají upravit tak, aby se vrátily v pořadí.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Označuje zásadu, která se má použít pro události, které přicházejí mimo pořadí ve vstupním streamu událostí.
properties.functions	Function[]	Seznam jedné nebo více funkcí pro úlohu streamování. Vlastnost name pro každou funkci se vyžaduje při zadávání této vlastnosti v požadavku PUT. Tuto vlastnost nelze upravit pomocí operace PATCH. Pro jednotlivé transformace musíte použít rozhraní PATCH API, které je k dispozici.
properties.inputs	Input[]	Seznam jednoho nebo více vstupů pro úlohu streamování. Vlastnost name pro každý vstup se vyžaduje při zadávání této vlastnosti v požadavku PUT. Tuto vlastnost nelze upravit pomocí operace PATCH. Pro jednotlivé vstupy musíte použít rozhraní PATCH API, které je k dispozici.
properties.jobId	string	Identifikátor GUID, který jednoznačně identifikuje úlohu streamování. Tento identifikátor GUID se vygeneruje při vytvoření úlohy streamování.
properties.jobState	string	Popisuje stav úlohy streamování.
properties.jobStorageAccount	JobStorageAccount	Vlastnosti přidružené k účtu služby Azure Storage s MSI
properties.jobType	JobType	Popisuje typ úlohy. Platnými režimy jsou Cloud a Edge.
properties.lastOutputEventTime	string	Hodnota je buď ve formátu ISO-8601 formátované časové razítko označující čas poslední výstupní události úlohy streamování, nebo hodnota null označující, že výstup ještě nebyl vytvořen. V případě více výstupů nebo více datových proudů se zobrazí nejnovější hodnota v dané sadě.
properties.outputErrorPolicy	OutputErrorPolicy	Označuje zásadu, která se má použít pro události, které přicházejí do výstupu a nelze je zapsat do externího úložiště kvůli poškození (chybějící hodnoty sloupců, hodnoty sloupců nesprávného typu nebo velikosti).
properties.outputStartMode	OutputStartMode	Tato vlastnost by měla být použita pouze v případě, že je žádoucí, aby úloha byla spuštěna okamžitě po vytvoření. Hodnota může být JobStartTime, CustomTime nebo LastOutputEventTime, která označuje, jestli se má počáteční bod výstupního datového proudu událostí spouštět při každém spuštění úlohy, jestli se má spustit s vlastním časovým razítkem uživatele zadaným prostřednictvím vlastnosti outputStartTime nebo jestli má začít od posledního výstupního času události.
properties.outputStartTime	string	Hodnota je buď časové razítko ve formátu ISO-8601, které označuje počáteční bod výstupního datového proudu událostí, nebo hodnota null, která označuje, že výstupní datový proud událostí se spustí při každém spuštění úlohy streamování. Tato vlastnost musí mít hodnotu, pokud je outputStartMode nastavený na CustomTime.
properties.outputs	Output[]	Seznam jednoho nebo více výstupů pro úlohu streamování Vlastnost name pro každý výstup se vyžaduje při zadávání této vlastnosti v požadavku PUT. Tuto vlastnost nelze upravit pomocí operace PATCH. Pro jednotlivé výstupy musíte použít rozhraní PATCH API, které je k dispozici.
properties.provisioningState	string	Popisuje stav zřizování úlohy streamování.
properties.sku	Sku	Popisuje skladovou položku úlohy streamování. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.transformation	Transformation	Označuje dotaz a počet jednotek streamování, které se mají použít pro úlohu streamování. Vlastnost name transformace se vyžaduje při zadávání této vlastnosti v požadavku PUT. Tuto vlastnost nelze upravit pomocí operace PATCH. Pro jednotlivé transformace musíte použít rozhraní PATCH API, které je k dispozici.
tags	object	Značky prostředků.
type	string	Typ prostředku. Například Microsoft.Compute/virtualMachines nebo Microsoft.Storage/storageAccounts.

StreamInputProperties

Vlastnosti, které jsou přidruženy ke vstupu obsahujícímu data datového proudu.

Name	Typ	Description
compression	Compression	Popisuje, jak se komprimují vstupní data.
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Popisuje vstupní zdroj dat, který obsahuje streamová data. Vyžaduje se u požadavků PUT (CreateOrReplace).
diagnostics	Diagnostics	Popisuje podmínky vztahující se na vstup, výstup nebo celkovou úlohu, které vyžadují pozornost zákazníka.
etag	string	Aktuální značka entity pro vstup. Jedná se o neprůsvný řetězec. Můžete ho použít ke zjištění, jestli se prostředek mezi požadavky změnil. Můžete ho také použít v hlavičce If-Match nebo If-None-Match pro operace zápisu pro zajištění optimistické souběžnosti.
partitionKey	string	partitionKey Popisuje klíč ve vstupních datech, který se používá k dělení vstupních dat.
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Stream	Určuje, jestli je vstup zdrojem referenčních dat nebo datových proudů. Vyžaduje se u požadavků PUT (CreateOrReplace).

Transformation

Objekt transformace obsahující všechny informace přidružené k pojmenované transformaci. Všechny transformace jsou obsaženy v rámci úlohy streamování.

Name	Typ	Default value	Description
id	string		ID prostředku
name	string		Název prostředku
properties.etag	string		Aktuální značka entity pro transformaci. Jedná se o neprůsvný řetězec. Můžete ho použít ke zjištění, jestli se prostředek mezi požadavky změnil. Můžete ho také použít v hlavičce If-Match nebo If-None-Match pro operace zápisu pro zajištění optimistické souběžnosti.
properties.query	string		Určuje dotaz, který se spustí v úloze streamování. Další informace o jazyku Stream Analytics Query Language (SAQL) najdete tady: https://msdn.microsoft.com/library/azure/dn834998 . Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.streamingUnits	integer	3	Určuje počet jednotek streamování, které úloha streamování používá.
properties.validStreamingUnits	integer[]		Určuje platné jednotky streamování, na které může úloha streamování provádět škálování.
type	string		Typ prostředku