Streaming Jobs - Create Or Replace

Serviço:

Stream Analytics

Versão da API:

2020-03-01

Cria um trabalho de streaming ou substitui um trabalho de streaming já existente.

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

Parâmetros de URI

Nome	Em	Obrigatório	Tipo	Description
jobName	path	True	string	O nome do trabalho de streaming.
resourceGroupName	path	True	string	O nome do grupo de recursos. O nome diferencia maiúsculas de minúsculas. Padrão Regex: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	A ID da assinatura de destino.
api-version	query	True	string	A versão da API a ser usada para esta operação.

Cabeçalho da solicitação

Nome	Obrigatório	Tipo	Description
If-Match		string	A ETag do trabalho de streaming. Omita esse valor para sempre substituir o conjunto de registros atual. Especifique o valor de ETag visto pela última vez para evitar a substituição acidental de alterações simultâneas.
If-None-Match		string	Defina como '*' para permitir que um novo trabalho de streaming seja criado, mas para evitar a atualização de um conjunto de registros existente. Outros valores resultarão em uma resposta com falha de pré-condição 412.

Corpo da solicitação

Nome	Tipo	Description
identity	Identity	Descreve a identidade gerenciada atribuída pelo sistema atribuída a esse trabalho que pode ser usada para autenticar com entradas e saídas.
location	string	A localização geográfica em que o recurso reside
properties.cluster	ClusterInfo	O cluster no qual os trabalhos de streaming serão executados.
properties.compatibilityLevel	CompatibilityLevel	Controla determinados comportamentos de runtime do trabalho de streaming.
properties.contentStoragePolicy	ContentStoragePolicy	Os valores válidos são JobStorageAccount e SystemAccount. Se definido como JobStorageAccount, isso exigirá que o usuário também especifique a propriedade jobStorageAccount. .
properties.dataLocale	string	A localidade de dados do trabalho do Stream Analytics. O valor deve ser o nome de uma cultura .NET com suporte do conjunto https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Se nenhuma for especificada, o padrão será 'en-US'.
properties.eventsLateArrivalMaxDelayInSeconds	integer	O atraso máximo tolerável em segundos em que os eventos que chegam atrasados podem ser incluídos. O intervalo com suporte é de -1 a 1814399 (20.23:59:59 dias) e -1 é usado para especificar a espera indefinidamente. Se a propriedade estiver ausente, ela será interpretada como tendo um valor de -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	O atraso máximo tolerável em segundos em que os eventos fora de ordem podem ser ajustados para voltar à ordem.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Indica a política a ser aplicada aos eventos que chegam fora de ordem no fluxo de eventos de entrada.
properties.functions	Function[]	Uma lista de uma ou mais funções para o trabalho de streaming. A propriedade name para cada função é necessária ao especificar essa propriedade em uma solicitação PUT. Essa propriedade não pode ser modificada por meio de uma operação PATCH. Você deve usar a API PATCH disponível para a transformação individual.
properties.inputs	Input[]	Uma lista de uma ou mais entradas para o trabalho de streaming. A propriedade name para cada entrada é necessária ao especificar essa propriedade em uma solicitação PUT. Essa propriedade não pode ser modificada por meio de uma operação PATCH. Você deve usar a API PATCH disponível para a entrada individual.
properties.jobStorageAccount	JobStorageAccount	As propriedades associadas a uma conta de Armazenamento do Azure com MSI
properties.jobType	JobType	Descreve o tipo do trabalho. Os modos válidos são Cloud e 'Edge'.
properties.outputErrorPolicy	OutputErrorPolicy	Indica a política a ser aplicada aos eventos que chegam à saída e não podem ser gravados no armazenamento externo por estarem malformados (faltando valores de coluna, valores de coluna de tipo ou tamanho incorreto).
properties.outputStartMode	OutputStartMode	Essa propriedade só deve ser utilizada quando desejar que o trabalho seja iniciado imediatamente após a criação. O valor pode ser JobStartTime, CustomTime ou LastOutputEventTime para indicar se o ponto inicial do fluxo de eventos de saída deve ser iniciado sempre que o trabalho for iniciado, começar em um carimbo de data/hora do usuário personalizado especificado por meio da propriedade outputStartTime ou começar a partir da hora de saída do último evento.
properties.outputStartTime	string	O valor é um carimbo de hora formatados com o ISO 8601 que indica o ponto de partida do fluxo de eventos de saída ou nulo para indicar que o fluxo de eventos de saída será iniciado sempre que o trabalho de streaming for iniciado. Essa propriedade deverá ter um valor se outputStartMode estiver definido como CustomTime.
properties.outputs	Output[]	Uma lista de uma ou mais saídas para o trabalho de streaming. A propriedade name para cada saída é necessária ao especificar essa propriedade em uma solicitação PUT. Essa propriedade não pode ser modificada por meio de uma operação PATCH. Você deve usar a API PATCH disponível para a saída individual.
properties.sku	Sku	Descreve a SKU do trabalho de streaming. Necessário em solicitações PUT (CreateOrReplace).
properties.transformation	Transformation	Indica a consulta e o número de unidades de streaming a serem usadas para o trabalho de streaming. A propriedade name da transformação é necessária ao especificar essa propriedade em uma solicitação PUT. Essa propriedade não pode ser modificada por meio de uma operação PATCH. Você deve usar a API PATCH disponível para a transformação individual.
tags	object	Marcas de recurso.

Respostas

Nome	Tipo	Description
200 OK	StreamingJob	O trabalho de streaming foi criado ou substituído com êxito. Cabeçalhos ETag: string
201 Created	StreamingJob	O trabalho de streaming foi criado ou substituído com êxito. Cabeçalhos ETag: string
Other Status Codes	Error	Erro.

Segurança

azure_auth

Fluxo do OAuth2 do Azure Active Directory

Tipo: oauth2
Flow: implicit
URL de Autorização: https://login.microsoftonline.com/common/oauth2/authorize

Escopos

Nome	Description
user_impersonation	representar sua conta de usuário

Exemplos

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)

Solicitação de exemplo

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

Resposta de exemplo

Código de status:

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

Código de status:

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)

Solicitação de exemplo

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

Resposta de exemplo

Código de status:

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

Código de status:

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

Definições

Nome	Description
AggregateFunctionProperties	As propriedades associadas a uma função de agregação.
AuthenticationMode	Modo de Autenticação. Os modos válidos são ConnectionStringe Msi 'UserToken'.
AvroSerialization	Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída no formato Avro.
AzureDataLakeStoreOutputDataSource	Descreve uma fonte de dados de saída do Azure Data Lake Store.
AzureFunctionOutputDataSource	Define os metadados de AzureFunctionOutputDataSource
AzureMachineLearningWebServiceFunctionBinding	A associação a um serviço Web do Azure Machine Learning.
AzureMachineLearningWebServiceInputColumn	Descreve uma coluna de entrada para o ponto de extremidade do serviço Web do Azure Machine Learning.
AzureMachineLearningWebServiceInputs	As entradas para o ponto de extremidade do serviço Web do Azure Machine Learning.
AzureMachineLearningWebServiceOutputColumn	Descreve uma coluna de saída para o ponto de extremidade do serviço Web do Azure Machine Learning.
AzureSqlDatabaseOutputDataSource	Descreve uma fonte de dados de saída de banco de dados SQL do Azure.
AzureSqlReferenceInputDataSource	Descreve uma fonte de dados de entrada de referência de banco de dados SQL do Azure.
AzureSynapseOutputDataSource	Descreve uma fonte de dados de saída Azure Synapse.
AzureTableOutputDataSource	Descreve uma fonte de dados de saída da Tabela do Azure.
BlobOutputDataSource	Descreve uma fonte de dados de saída de blob.
BlobReferenceInputDataSource	Descreve uma fonte de dados de entrada de blob que contém dados de referência.
BlobStreamInputDataSource	Descreve uma fonte de dados de entrada de blob que contém dados de fluxo.
ClusterInfo	As propriedades associadas a um cluster do Stream Analytics.
CompatibilityLevel	Controla determinados comportamentos de runtime do trabalho de streaming.
Compression	Descreve como os dados de entrada são compactados
CompressionType	Indica o tipo de compactação que a entrada usa. Necessário em solicitações PUT (CreateOrReplace).
ContentStoragePolicy	Os valores válidos são JobStorageAccount e SystemAccount. Se definido como JobStorageAccount, isso exigirá que o usuário também especifique a propriedade jobStorageAccount. .
CsvSerialization	Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída no formato CSV.
DiagnosticCondition	Condição aplicável ao recurso ou ao trabalho em geral, que garantem a atenção do cliente.
Diagnostics	Descreve as condições aplicáveis à Entrada, à Saída ou ao trabalho em geral, que garantem a atenção do cliente.
DocumentDbOutputDataSource	Descreve uma fonte de dados de saída do DocumentDB.
Encoding	Especifica a codificação dos dados de entrada no caso de entrada e a codificação de dados de saída no caso de saída.
Error	Representação de erro comum.
EventHubOutputDataSource	Descreve uma fonte de dados de saída do Hub de Eventos.
EventHubStreamInputDataSource	Descreve uma fonte de dados de entrada do Hub de Eventos que contém dados de fluxo.
EventHubV2OutputDataSource	Descreve uma fonte de dados de saída do Hub de Eventos.
EventHubV2StreamInputDataSource	Descreve uma fonte de dados de entrada do Hub de Eventos que contém dados de fluxo.
EventSerializationType	Indica o tipo de serialização que a entrada ou saída usa. Necessário em solicitações PUT (CreateOrReplace).
EventsOutOfOrderPolicy	Indica a política a ser aplicada aos eventos que chegam fora de ordem no fluxo de eventos de entrada.
FileReferenceInputDataSource	Descreve uma fonte de dados de entrada de arquivo que contém dados de referência.
Function	Um objeto de função, contendo todas as informações associadas à função nomeada. Todas as funções estão contidas em um trabalho de streaming.
FunctionInput	Descreve um parâmetro de entrada de uma função.
FunctionOutput	Descreve a saída de uma função.
GatewayMessageBusOutputDataSource	Descreve uma fonte de dados de saída do Barramento de Mensagens do Gateway.
GatewayMessageBusStreamInputDataSource	Descreve uma fonte de dados de entrada de blob que contém dados de fluxo.
Identity	Descreve como a identidade é verificada
Input	Um objeto de entrada, contendo todas as informações associadas à entrada nomeada. Todas as entradas estão contidas em um trabalho de streaming.
IoTHubStreamInputDataSource	Descreve uma fonte de dados de entrada Hub IoT que contém dados de fluxo.
JavaScriptFunctionBinding	A associação a uma função JavaScript.
JobStorageAccount	As propriedades associadas a uma conta de Armazenamento do Azure com MSI
JobType	Descreve o tipo do trabalho. Os modos válidos são Cloud e "Edge".
JsonOutputSerializationFormat	Especifica o formato do JSON no qual a saída será gravada. Os valores atualmente compatíveis são 'lineSeparated' indicando que a saída será formatada com cada objeto JSON separado por uma nova linha e 'matriz' indicando que a saída será formatada como uma matriz de objetos JSON.
JsonSerialization	Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída no formato JSON.
Output	Um objeto de saída, contendo todas as informações associadas à saída nomeada. Todas as saídas estão contidas em um trabalho de streaming.
OutputErrorPolicy	Indica a política a ser aplicada aos eventos que chegam à saída e não podem ser gravados no armazenamento externo por estarem malformados (faltando valores de coluna, valores de coluna de tipo ou tamanho incorreto).
OutputStartMode	O valor pode ser JobStartTime, CustomTime ou LastOutputEventTime para indicar se o ponto inicial do fluxo de eventos de saída deve ser iniciado sempre que o trabalho for iniciado, iniciar em um carimbo de data/hora do usuário personalizado especificado por meio da propriedade outputStartTime ou começar a partir da hora de saída do último evento.
ParquetSerialization	Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída no formato Parquet.
PowerBIOutputDataSource	Descreve uma fonte de dados de saída do Power BI.
ReferenceInputProperties	As propriedades associadas a uma entrada que contém dados de referência.
RefreshType	Indica o tipo de opção de atualização de dados.
ScalarFunctionProperties	As propriedades associadas a uma função escalar.
ServiceBusQueueOutputDataSource	Descreve uma fonte de dados de saída da Fila do Barramento de Serviço.
ServiceBusTopicOutputDataSource	Descreve uma fonte de dados de saída do Tópico do Barramento de Serviço.
Sku	As propriedades associadas a um SKU.
SkuName	O nome da SKU. Necessário em solicitações PUT (CreateOrReplace).
StorageAccount	As propriedades associadas a uma conta de Armazenamento do Azure
StreamingJob	Um objeto de trabalho de streaming, contendo todas as informações associadas ao trabalho de streaming nomeado.
StreamInputProperties	As propriedades associadas a uma entrada que contém dados de fluxo.
Transformation	Um objeto de transformação que contém todas as informações associadas à transformação nomeada. Todas as transformações estão contidas em um trabalho de streaming.

AggregateFunctionProperties

As propriedades associadas a uma função de agregação.

Nome	Tipo	Description
etag	string	A marca de entidade atual para a função. Essa é uma cadeia de caracteres opaca. Você pode usá-lo para detectar se o recurso foi alterado entre solicitações. Você também pode usá-lo nos cabeçalhos If-Match ou If-None-Match para operações de gravação para simultaneidade otimista.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	A associação física da função. Por exemplo, no caso do serviço Web do Azure Machine Learning, isso descreve o ponto de extremidade.
properties.inputs	FunctionInput[]	Descreve um parâmetro de entrada de uma função.
properties.output	FunctionOutput	Descreve a saída de uma função.
type	string: Aggregate	Indica o tipo de função.

AuthenticationMode

Modo de Autenticação. Os modos válidos são ConnectionStringe Msi 'UserToken'.

Nome	Tipo	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída no formato Avro.

Nome	Tipo	Description
type	string: Avro	Indica o tipo de serialização que a entrada ou saída usa. Necessário em solicitações PUT (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Descreve uma fonte de dados de saída do Azure Data Lake Store.

Nome	Tipo	Valor padrão	Description
properties.accountName	string		O nome da conta do Azure Data Lake Store. Necessário em solicitações PUT (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.dateFormat	string		O formato de data. Onde quer que {date} apareça em filePathPrefix, o valor dessa propriedade é usado como o formato de data.
properties.filePathPrefix	string		O local do arquivo no qual a saída deve ser gravada. Necessário em solicitações PUT (CreateOrReplace).
properties.refreshToken	string		Um token de atualização que pode ser usado para obter um token de acesso válido que pode ser usado para autenticar com a fonte de dados. No momento, um token de atualização válido só pode ser obtido por meio do Portal do Azure. É recomendável colocar um valor de cadeia de caracteres fictício aqui ao criar a fonte de dados e, em seguida, acessar o Portal do Azure para autenticar a fonte de dados que atualizará essa propriedade com um token de atualização válido. Necessário em solicitações PUT (CreateOrReplace).
properties.tenantId	string		A ID do locatário do usuário usada para obter o token de atualização. Necessário em solicitações PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Onde quer que {time} apareça em filePathPrefix, o valor dessa propriedade é usado como o formato de hora.
properties.tokenUserDisplayName	string		O nome de exibição do usuário que foi usado para obter o token de atualização. Use essa propriedade para ajudar a lembrar qual usuário foi usado para obter o token de atualização.
properties.tokenUserPrincipalName	string		O UPN (nome principal do usuário) do usuário que foi usado para obter o token de atualização. Use essa propriedade para ajudar a lembrar qual usuário foi usado para obter o token de atualização.
type	string: Microsoft.DataLake/Accounts		Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

AzureFunctionOutputDataSource

Define os metadados de AzureFunctionOutputDataSource

Nome	Tipo	Description
properties.apiKey	string	Se você quiser usar um Azure Function de outra assinatura, você pode fazer isso fornecendo a chave para acessar sua função.
properties.functionAppName	string	O nome de seu aplicativo do Azure Functions.
properties.functionName	string	O nome da função em seu aplicativo do Azure Functions.
properties.maxBatchCount	number	Uma propriedade que permite que você especifique o número máximo de eventos em cada que é enviado ao Azure Functions. O valor padrão é 100.
properties.maxBatchSize	number	Uma propriedade que permite que você defina o tamanho máximo de cada lote de saída que é enviado para seu Azure Functions. A unidade de entrada é em bytes. Por padrão, esse valor é 262,144 bytes (256 KB).
type	string: Microsoft.AzureFunction	Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

A associação a um serviço Web do Azure Machine Learning.

Nome	Tipo	Description
properties.apiKey	string	A chave de API usada para autenticar com Request-Response ponto de extremidade.
properties.batchSize	integer	Número entre 1 e 10000 que descreve o número máximo de linhas para cada solicitação de execução do RRS do Azure ML. O padrão é 1000.
properties.endpoint	string	O Request-Response executar o ponto de extremidade do serviço Web do Azure Machine Learning. Saiba mais aqui: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
properties.inputs	AzureMachineLearningWebServiceInputs	As entradas para o ponto de extremidade do serviço Web do Azure Machine Learning.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Uma lista de saídas da execução do ponto de extremidade do serviço Web do Azure Machine Learning.
type	string: Microsoft.MachineLearning/WebService	Indica o tipo de associação de função.

AzureMachineLearningWebServiceInputColumn

Descreve uma coluna de entrada para o ponto de extremidade do serviço Web do Azure Machine Learning.

Nome	Tipo	Description
dataType	string	O tipo de dados (com suporte do Azure Machine Learning) da coluna de entrada. Uma lista de tipos de dados válidos do Azure Machine Learning é descrita em https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
mapTo	integer	O índice baseado em zero do parâmetro de função para o qual essa entrada é mapeada.
name	string	Nome da coluna de entrada.

AzureMachineLearningWebServiceInputs

As entradas para o ponto de extremidade do serviço Web do Azure Machine Learning.

Nome	Tipo	Description
columnNames	AzureMachineLearningWebServiceInputColumn[]	Uma lista de colunas de entrada para o ponto de extremidade do serviço Web do Azure Machine Learning.
name	string	Nome da entrada. Esse é o nome fornecido durante a criação do ponto de extremidade.

AzureMachineLearningWebServiceOutputColumn

Descreve uma coluna de saída para o ponto de extremidade do serviço Web do Azure Machine Learning.

Nome	Tipo	Description
dataType	string	O tipo de dados (com suporte do Azure Machine Learning) da coluna de saída. Uma lista de tipos de dados válidos do Azure Machine Learning é descrita em https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
name	string	Nome da coluna de saída.

AzureSqlDatabaseOutputDataSource

Descreve uma fonte de dados de saída de banco de dados SQL do Azure.

Nome	Tipo	Valor padrão	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.database	string		O nome do banco de dados SQL do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.maxBatchCount	number		Contagem máxima do Lote para gravação no banco de dados Sql, o valor padrão é 10.000. Opcional em solicitações PUT.
properties.maxWriterCount	number		A contagem máxima de gravadores, atualmente apenas 1(gravador único) e 0(com base na partição de consulta) estão disponíveis. Opcional em solicitações PUT.
properties.password	string		A senha que será usada para se conectar ao banco de dados SQL do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.server	string		O nome do SQL Server que contém o banco de dados SQL do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.table	string		O nome da tabela no banco de dados SQL do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.user	string		O nome de usuário que será usado para se conectar ao banco de dados SQL do Azure. Necessário em solicitações PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/Database		Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Descreve uma fonte de dados de entrada de referência de banco de dados SQL do Azure.

Nome	Tipo	Description
properties.database	string	Este elemento é associado ao elemento datasource. Esse é o nome do banco de dados no qual a saída será gravada.
properties.deltaSnapshotQuery	string	Este elemento é associado ao elemento datasource. Essa consulta é usada para buscar alterações incrementais do banco de dados SQL. Para usar essa opção, recomendamos usar tabelas temporais no banco de dados SQL do Azure.
properties.fullSnapshotQuery	string	Este elemento é associado ao elemento datasource. Essa consulta é usada para buscar dados do banco de dados sql.
properties.password	string	Este elemento é associado ao elemento datasource. Essa é a senha que será usada para se conectar à instância do banco de dados SQL.
properties.refreshRate	string	Este elemento é associado ao elemento datasource. Isso indica com que frequência os dados serão buscados do banco de dados. É do formato DateTime.
properties.refreshType	RefreshType	Indica o tipo de opção de atualização de dados.
properties.server	string	Este elemento é associado ao elemento datasource. Esse é o nome do servidor que contém o banco de dados no qual será gravado.
properties.table	string	Este elemento é associado ao elemento datasource. O nome da tabela no banco de dados SQL do Azure..
properties.user	string	Este elemento é associado ao elemento datasource. Esse é o nome de usuário que será usado para se conectar à instância do banco de dados SQL.
type	string: Microsoft.Sql/Server/Database	Indica o tipo de fonte de dados de entrada que contém dados de referência. Necessário em solicitações PUT (CreateOrReplace).

AzureSynapseOutputDataSource

Descreve uma fonte de dados de saída Azure Synapse.

Nome	Tipo	Description
properties.database	string	O nome do banco de dados SQL do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.password	string	A senha que será usada para se conectar ao banco de dados SQL do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.server	string	O nome do SQL Server que contém o banco de dados SQL do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.table	string	O nome da tabela no banco de dados SQL do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.user	string	O nome de usuário que será usado para se conectar ao banco de dados SQL do Azure. Necessário em solicitações PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/DataWarehouse	Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

AzureTableOutputDataSource

Descreve uma fonte de dados de saída da Tabela do Azure.

Nome	Tipo	Description
properties.accountKey	string	A chave de conta para a conta de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.accountName	string	O nome da conta de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.batchSize	integer	O número de linhas a serem gravadas na Tabela do Azure por vez.
properties.columnsToRemove	string[]	Se especificado, cada item da matriz é o nome de uma coluna a ser removida (se houver) a partir das entidades do evento de saída.
properties.partitionKey	string	Esse elemento indica o nome de uma coluna da instrução SELECT na consulta que será usada como a chave de partição para a Tabela do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.rowKey	string	Esse elemento indica o nome de uma coluna da instrução SELECT na consulta que será usada como a chave de linha para a Tabela do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.table	string	O nome da Tabela do Azure. Necessário em solicitações PUT (CreateOrReplace).
type	string: Microsoft.Storage/Table	Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

BlobOutputDataSource

Descreve uma fonte de dados de saída de blob.

Nome	Tipo	Valor padrão	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.blobPathPrefix	string		Prefixo do caminho do blob.
properties.container	string		O nome de um contêiner dentro da conta de Armazenamento associada. Esse contêiner contém os blob(s) a serem lidos ou gravados. Necessário em solicitações PUT (CreateOrReplace).
properties.dateFormat	string		O formato de data. Onde quer que {date} apareça em pathPattern, o valor dessa propriedade é usado como o formato de data.
properties.pathPattern	string		O padrão de caminho do blob. Não é uma expressão regular. Ele representa um padrão em relação ao qual os nomes de blob serão correspondidos para determinar se eles devem ou não ser incluídos como entrada ou saída para o trabalho. Confira https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input ou https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output para obter uma explicação e um exemplo mais detalhados.
properties.storageAccounts	StorageAccount[]		Uma lista de uma ou mais contas de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Onde quer que {time} apareça em pathPattern, o valor dessa propriedade é usado como o formato de hora.
type	string: Microsoft.Storage/Blob		Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

BlobReferenceInputDataSource

Descreve uma fonte de dados de entrada de blob que contém dados de referência.

Nome	Tipo	Valor padrão	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticação.
properties.container	string		O nome de um contêiner dentro da conta de Armazenamento associada. Esse contêiner contém os blob(s) a serem lidos ou gravados. Necessário em solicitações PUT (CreateOrReplace).
properties.dateFormat	string		O formato de data. Onde quer que {date} apareça em pathPattern, o valor dessa propriedade é usado como o formato de data.
properties.pathPattern	string		O padrão de caminho do blob. Não é uma expressão regular. Ele representa um padrão em relação ao qual os nomes de blob serão correspondidos para determinar se eles devem ou não ser incluídos como entrada ou saída para o trabalho. Confira https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input ou https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output para obter uma explicação e um exemplo mais detalhados.
properties.storageAccounts	StorageAccount[]		Uma lista de uma ou mais contas de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Onde quer que {time} apareça em pathPattern, o valor dessa propriedade é usado como o formato de hora.
type	string: Microsoft.Storage/Blob		Indica o tipo de fonte de dados de entrada que contém dados de referência. Necessário em solicitações PUT (CreateOrReplace).

BlobStreamInputDataSource

Descreve uma fonte de dados de entrada de blob que contém dados de fluxo.

Nome	Tipo	Valor padrão	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.container	string		O nome de um contêiner dentro da conta de Armazenamento associada. Esse contêiner contém os blob(s) a serem lidos ou gravados. Necessário em solicitações PUT (CreateOrReplace).
properties.dateFormat	string		O formato de data. Onde quer que {date} apareça em pathPattern, o valor dessa propriedade é usado como o formato de data.
properties.pathPattern	string		O padrão de caminho do blob. Não é uma expressão regular. Ele representa um padrão em relação ao qual os nomes de blob serão correspondidos para determinar se eles devem ou não ser incluídos como entrada ou saída para o trabalho. Confira https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input ou https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output para obter uma explicação e um exemplo mais detalhados.
properties.sourcePartitionCount	integer		A contagem de partições da fonte de dados de entrada de blob. Intervalo 1 a 1024.
properties.storageAccounts	StorageAccount[]		Uma lista de uma ou mais contas de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Onde quer que {time} apareça em pathPattern, o valor dessa propriedade é usado como o formato de hora.
type	string: Microsoft.Storage/Blob		Indica o tipo de fonte de dados de entrada que contém dados de fluxo. Necessário em solicitações PUT (CreateOrReplace).

ClusterInfo

As propriedades associadas a um cluster do Stream Analytics.

Nome	Tipo	Description
id	string	A ID do recurso do cluster.

CompatibilityLevel

Controla determinados comportamentos de runtime do trabalho de streaming.

Nome	Tipo	Description
1.0	string
1.2	string

Compression

Descreve como os dados de entrada são compactados

Nome	Tipo	Valor padrão	Description
type	CompressionType	None	Indica o tipo de compactação que a entrada usa. Necessário em solicitações PUT (CreateOrReplace).

CompressionType

Indica o tipo de compactação que a entrada usa. Necessário em solicitações PUT (CreateOrReplace).

Nome	Tipo	Description
Deflate	string
GZip	string
None	string

ContentStoragePolicy

Os valores válidos são JobStorageAccount e SystemAccount. Se definido como JobStorageAccount, isso exigirá que o usuário também especifique a propriedade jobStorageAccount. .

Nome	Tipo	Description
JobStorageAccount	string
SystemAccount	string

CsvSerialization

Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída no formato CSV.

Nome	Tipo	Description
properties.encoding	Encoding	Especifica a codificação dos dados de entrada no caso de entrada e a codificação de dados de saída no caso de saída. Necessário em solicitações PUT (CreateOrReplace).
properties.fieldDelimiter	string	Especifica o delimitador que será usado para separar registros CSV (valor separado por vírgula). Confira https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input ou https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output para obter uma lista de valores com suporte. Necessário em solicitações PUT (CreateOrReplace).
type	string: Csv	Indica o tipo de serialização que a entrada ou saída usa. Necessário em solicitações PUT (CreateOrReplace).

DiagnosticCondition

Condição aplicável ao recurso ou ao trabalho em geral, que garantem a atenção do cliente.

Nome	Tipo	Description
code	string	O código de diagnóstico opaco.
message	string	A mensagem legível por humanos que descreve a condição em detalhes. Localizado no Accept-Language da solicitação do cliente.
since	string	O carimbo de data/hora UTC de quando a condição foi iniciada. Os clientes devem ser capazes de encontrar um evento correspondente no log de operações por volta desta hora.

Diagnostics

Descreve as condições aplicáveis à Entrada, à Saída ou ao trabalho em geral, que garantem a atenção do cliente.

Nome	Tipo	Description
conditions	DiagnosticCondition[]	Uma coleção de zero ou mais condições aplicáveis ao recurso ou ao trabalho em geral, que garantem a atenção do cliente.

DocumentDbOutputDataSource

Descreve uma fonte de dados de saída do DocumentDB.

Nome	Tipo	Description
properties.accountId	string	O nome ou a ID da conta do DocumentDB. Necessário em solicitações PUT (CreateOrReplace).
properties.accountKey	string	A chave de conta da conta do DocumentDB. Necessário em solicitações PUT (CreateOrReplace).
properties.collectionNamePattern	string	O padrão de nome da coleção para as coleções a ser usado. O formato de nome da coleção pode ser construído com o token {partição} opcional, em que as partições começam em 0. Consulte a seção DocumentDB de https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output para obter mais informações. Necessário em solicitações PUT (CreateOrReplace).
properties.database	string	O nome do banco de dados do DocumentDB. Necessário em solicitações PUT (CreateOrReplace).
properties.documentId	string	O nome do campo em eventos de saída usado para especificar a chave primária na qual se baseiam as operações de inserção ou atualização.
properties.partitionKey	string	O nome do campo nos eventos de saída usado para especificar a chave para o particionamento de saída em várias coleções. Se 'collectionNamePattern' contiver o token {partition}, essa propriedade precisará ser especificada.
type	string: Microsoft.Storage/DocumentDB	Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

Encoding

Especifica a codificação dos dados de entrada no caso de entrada e a codificação de dados de saída no caso de saída.

Nome	Tipo	Description
UTF8	string

Error

Representação de erro comum.

Nome	Tipo	Description
error	Error	Propriedades de definição de erro.

EventHubOutputDataSource

Descreve uma fonte de dados de saída do Hub de Eventos.

Nome	Tipo	Valor padrão	Description
authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.eventHubName	string		O nome do Hub de Eventos. Necessário em solicitações PUT (CreateOrReplace).
properties.partitionKey	string		A chave/coluna usada para determinar para qual partição enviar dados de evento.
properties.propertyColumns	string[]		As propriedades associadas a essa saída do Hub de Eventos.
serviceBusNamespace	string		O namespace associado ao Hub de Eventos desejado, Fila do Barramento de Serviço, Tópico do Barramento de Serviço etc. Necessário em solicitações PUT (CreateOrReplace).
sharedAccessPolicyKey	string		A chave de política de acesso compartilhado para a política de acesso compartilhado especificada. Necessário em solicitações PUT (CreateOrReplace).
sharedAccessPolicyName	string		O nome da política de acesso compartilhado para o Hub de Eventos, Fila do Barramento de Serviço, Tópico do Barramento de Serviço etc. Necessário em solicitações PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

EventHubStreamInputDataSource

Descreve uma fonte de dados de entrada do Hub de Eventos que contém dados de fluxo.

Nome	Tipo	Valor padrão	Description
authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.consumerGroupName	string		O nome de um Grupo de Consumidores do Hub de Eventos que deve ser usado para ler eventos do Hub de Eventos. Especificar nomes de grupos de consumidores distintos para várias entradas permite que cada uma dessas entradas receba os mesmos eventos do Hub de Eventos. Se não for especificado, a entrada usará o grupo de consumidores padrão do Hub de Eventos.
properties.eventHubName	string		O nome do Hub de Eventos. Necessário em solicitações PUT (CreateOrReplace).
serviceBusNamespace	string		O namespace associado ao Hub de Eventos desejado, Fila do Barramento de Serviço, Tópico do Barramento de Serviço etc. Necessário em solicitações PUT (CreateOrReplace).
sharedAccessPolicyKey	string		A chave de política de acesso compartilhado para a política de acesso compartilhado especificada. Necessário em solicitações PUT (CreateOrReplace).
sharedAccessPolicyName	string		O nome da política de acesso compartilhado para o Hub de Eventos, Fila do Barramento de Serviço, Tópico do Barramento de Serviço etc. Necessário em solicitações PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indica o tipo de fonte de dados de entrada que contém dados de fluxo. Necessário em solicitações PUT (CreateOrReplace).

EventHubV2OutputDataSource

Descreve uma fonte de dados de saída do Hub de Eventos.

Nome	Tipo	Valor padrão	Description
authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.eventHubName	string		O nome do Hub de Eventos. Necessário em solicitações PUT (CreateOrReplace).
properties.partitionKey	string		A chave/coluna usada para determinar para qual partição enviar dados de evento.
properties.propertyColumns	string[]		As propriedades associadas a essa saída do Hub de Eventos.
serviceBusNamespace	string		O namespace associado ao Hub de Eventos desejado, Fila do Barramento de Serviço, Tópico do Barramento de Serviço etc. Necessário em solicitações PUT (CreateOrReplace).
sharedAccessPolicyKey	string		A chave de política de acesso compartilhado para a política de acesso compartilhado especificada. Necessário em solicitações PUT (CreateOrReplace).
sharedAccessPolicyName	string		O nome da política de acesso compartilhado para o Hub de Eventos, Fila do Barramento de Serviço, Tópico do Barramento de Serviço etc. Necessário em solicitações PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Descreve uma fonte de dados de entrada do Hub de Eventos que contém dados de fluxo.

Nome	Tipo	Valor padrão	Description
authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.consumerGroupName	string		O nome de um Grupo de Consumidores do Hub de Eventos que deve ser usado para ler eventos do Hub de Eventos. Especificar nomes de grupos de consumidores distintos para várias entradas permite que cada uma dessas entradas receba os mesmos eventos do Hub de Eventos. Se não for especificado, a entrada usará o grupo de consumidores padrão do Hub de Eventos.
properties.eventHubName	string		O nome do Hub de Eventos. Necessário em solicitações PUT (CreateOrReplace).
serviceBusNamespace	string		O namespace associado ao Hub de Eventos desejado, Fila do Barramento de Serviço, Tópico do Barramento de Serviço etc. Necessário em solicitações PUT (CreateOrReplace).
sharedAccessPolicyKey	string		A chave de política de acesso compartilhado para a política de acesso compartilhado especificada. Necessário em solicitações PUT (CreateOrReplace).
sharedAccessPolicyName	string		O nome da política de acesso compartilhado para o Hub de Eventos, Fila do Barramento de Serviço, Tópico do Barramento de Serviço etc. Necessário em solicitações PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indica o tipo de fonte de dados de entrada que contém dados de fluxo. Necessário em solicitações PUT (CreateOrReplace).

EventSerializationType

Indica o tipo de serialização que a entrada ou saída usa. Necessário em solicitações PUT (CreateOrReplace).

Nome	Tipo	Description
Avro	string
Csv	string
Json	string
Parquet	string

EventsOutOfOrderPolicy

Indica a política a ser aplicada aos eventos que chegam fora de ordem no fluxo de eventos de entrada.

Nome	Tipo	Description
Adjust	string
Drop	string

FileReferenceInputDataSource

Descreve uma fonte de dados de entrada de arquivo que contém dados de referência.

Nome	Tipo	Description
properties.path	string	O caminho do arquivo.
type	string: File	Indica o tipo de fonte de dados de entrada que contém dados de referência. Necessário em solicitações PUT (CreateOrReplace).

Function

Um objeto de função, contendo todas as informações associadas à função nomeada. Todas as funções estão contidas em um trabalho de streaming.

Nome	Tipo	Description
id	string	ID do recurso
name	string	Nome do recurso
properties	FunctionProperties: AggregateFunctionProperties ScalarFunctionProperties	As propriedades associadas a uma função.
type	string	Tipo de recurso

FunctionInput

Descreve um parâmetro de entrada de uma função.

Nome	Tipo	Description
dataType	string	O tipo de dados (com suporte do Azure Stream Analytics) do parâmetro de entrada de função. Uma lista de tipos de dados válidos do Azure Stream Analytics é descrita em https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	Um sinalizador que indica se o parâmetro é um parâmetro de configuração. True se espera-se que esse parâmetro de entrada seja uma constante. O padrão é false.

FunctionOutput

Descreve a saída de uma função.

Nome	Tipo	Description
dataType	string	O tipo de dados (com suporte do Azure Stream Analytics) da saída da função. Uma lista de tipos de dados válidos do Azure Stream Analytics é descrita em https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

Descreve uma fonte de dados de saída do Barramento de Mensagens do Gateway.

Nome	Tipo	Description
properties.topic	string	O nome do tópico do Barramento de Serviço.
type	string: GatewayMessageBus	Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Descreve uma fonte de dados de entrada de blob que contém dados de fluxo.

Nome	Tipo	Description
properties.topic	string	O nome do tópico do Barramento de Serviço.
type	string: GatewayMessageBus	Indica o tipo de fonte de dados de entrada que contém dados de fluxo. Necessário em solicitações PUT (CreateOrReplace).

Identity

Descreve como a identidade é verificada

Nome	Tipo	Description
principalId	string	A ID da entidade de identidade
tenantId	string	A tenantId de identidade
type	string	O tipo de identidade

Input

Um objeto de entrada, contendo todas as informações associadas à entrada nomeada. Todas as entradas estão contidas em um trabalho de streaming.

Nome	Tipo	Description
id	string	ID do recurso
name	string	Nome do recurso
properties	InputProperties: ReferenceInputProperties StreamInputProperties	As propriedades associadas a uma entrada. Necessário em solicitações PUT (CreateOrReplace).
type	string	Tipo de recurso

IoTHubStreamInputDataSource

Descreve uma fonte de dados de entrada Hub IoT que contém dados de fluxo.

Nome	Tipo	Description
properties.consumerGroupName	string	O nome de um grupo de consumidores Hub IoT que deve ser usado para ler eventos do Hub IoT. Se não for especificado, a entrada usará o grupo de consumidores padrão do Hub Iot.
properties.endpoint	string	O Hub IoT ponto de extremidade ao qual se conectar (ou seja, mensagens/eventos, mensagens/operaçõesMonitoringEvents etc.).
properties.iotHubNamespace	string	O nome ou o URI do Hub IoT. Necessário em solicitações PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	A chave de política de acesso compartilhado para a política de acesso compartilhado especificada. Necessário em solicitações PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	O nome da política de acesso compartilhado para o Hub IoT. Essa política deve conter pelo menos a permissão conexão de serviço. Necessário em solicitações PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Indica o tipo de fonte de dados de entrada que contém dados de fluxo. Necessário em solicitações PUT (CreateOrReplace).

JavaScriptFunctionBinding

A associação a uma função JavaScript.

Nome	Tipo	Description
properties.script	string	O código JavaScript que contém uma única definição de função. Por exemplo: 'function (x, y) { return x + y; }'
type	string: Microsoft.StreamAnalytics/JavascriptUdf	Indica o tipo de associação de função.

JobStorageAccount

As propriedades associadas a uma conta de Armazenamento do Azure com MSI

Nome	Tipo	Valor padrão	Description
accountKey	string		A chave de conta para a conta de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
accountName	string		O nome da conta de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.

JobType

Descreve o tipo do trabalho. Os modos válidos são Cloud e "Edge".

Nome	Tipo	Description
Cloud	string
Edge	string

JsonOutputSerializationFormat

Especifica o formato do JSON no qual a saída será gravada. Os valores atualmente compatíveis são 'lineSeparated' indicando que a saída será formatada com cada objeto JSON separado por uma nova linha e 'matriz' indicando que a saída será formatada como uma matriz de objetos JSON.

Nome	Tipo	Description
Array	string
LineSeparated	string

JsonSerialization

Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída no formato JSON.

Nome	Tipo	Description
properties.encoding	Encoding	Especifica a codificação dos dados de entrada no caso de entrada e a codificação de dados de saída no caso de saída. Necessário em solicitações PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Essa propriedade só se aplica à serialização JSON de saídas. Não é aplicável a entradas. Essa propriedade especifica o formato do JSON no qual a saída será gravada. Os valores atualmente compatíveis são 'lineSeparated' indicando que a saída será formatada com cada objeto JSON separado por uma nova linha e 'matriz' indicando que a saída será formatada como uma matriz de objetos JSON. O valor padrão será 'lineSeparated' se for nulo à esquerda.
type	string: Json	Indica o tipo de serialização que a entrada ou saída usa. Necessário em solicitações PUT (CreateOrReplace).

Output

Um objeto de saída, contendo todas as informações associadas à saída nomeada. Todas as saídas estão contidas em um trabalho de streaming.

Nome	Tipo	Description
id	string	ID do recurso
name	string	Nome do recurso
properties.datasource	OutputDataSource: AzureDataLakeStoreOutputDataSource AzureFunctionOutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource AzureTableOutputDataSource BlobOutputDataSource DocumentDbOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource GatewayMessageBusOutputDataSource PowerBIOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource	Descreve a fonte de dados na qual a saída será gravada. Necessário em solicitações PUT (CreateOrReplace).
properties.diagnostics	Diagnostics	Descreve as condições aplicáveis à Entrada, à Saída ou ao trabalho em geral, que garantem a atenção do cliente.
properties.etag	string	A marca de entidade atual para a saída. Essa é uma cadeia de caracteres opaca. Você pode usá-lo para detectar se o recurso foi alterado entre solicitações. Você também pode usá-lo nos cabeçalhos If-Match ou If-None-Match para operações de gravação para simultaneidade otimista.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída. Necessário em solicitações PUT (CreateOrReplace).
properties.sizeWindow	integer	A janela de tamanho para a qual restringir uma saída do Stream Analytics.
properties.timeWindow	string	O período para filtrar saídas de trabalho do Stream Analytics.
type	string	Tipo de recurso

OutputErrorPolicy

Indica a política a ser aplicada aos eventos que chegam à saída e não podem ser gravados no armazenamento externo por estarem malformados (faltando valores de coluna, valores de coluna de tipo ou tamanho incorreto).

Nome	Tipo	Description
Drop	string
Stop	string

OutputStartMode

O valor pode ser JobStartTime, CustomTime ou LastOutputEventTime para indicar se o ponto inicial do fluxo de eventos de saída deve ser iniciado sempre que o trabalho for iniciado, iniciar em um carimbo de data/hora do usuário personalizado especificado por meio da propriedade outputStartTime ou começar a partir da hora de saída do último evento.

Nome	Tipo	Description
CustomTime	string
JobStartTime	string
LastOutputEventTime	string

ParquetSerialization

Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída no formato Parquet.

Nome	Tipo	Description
type	string: Parquet	Indica o tipo de serialização que a entrada ou saída usa. Necessário em solicitações PUT (CreateOrReplace).

PowerBIOutputDataSource

Descreve uma fonte de dados de saída do Power BI.

Nome	Tipo	Valor padrão	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.dataset	string		O nome do conjunto de dados do Power BI. Necessário em solicitações PUT (CreateOrReplace).
properties.groupId	string		A ID do grupo do Power BI.
properties.groupName	string		O nome do grupo do Power BI. Use essa propriedade para ajudar a lembrar qual ID específica do grupo do Power BI foi usada.
properties.refreshToken	string		Um token de atualização que pode ser usado para obter um token de acesso válido que pode ser usado para autenticar com a fonte de dados. No momento, um token de atualização válido só pode ser obtido por meio do Portal do Azure. É recomendável colocar um valor de cadeia de caracteres fictício aqui ao criar a fonte de dados e, em seguida, acessar o Portal do Azure para autenticar a fonte de dados que atualizará essa propriedade com um token de atualização válido. Necessário em solicitações PUT (CreateOrReplace).
properties.table	string		O nome da tabela do Power BI no conjunto de dados especificado. Necessário em solicitações PUT (CreateOrReplace).
properties.tokenUserDisplayName	string		O nome de exibição do usuário que foi usado para obter o token de atualização. Use essa propriedade para ajudar a lembrar qual usuário foi usado para obter o token de atualização.
properties.tokenUserPrincipalName	string		O UPN (nome principal do usuário) do usuário que foi usado para obter o token de atualização. Use essa propriedade para ajudar a lembrar qual usuário foi usado para obter o token de atualização.
type	string: PowerBI		Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

ReferenceInputProperties

As propriedades associadas a uma entrada que contém dados de referência.

Nome	Tipo	Description
compression	Compression	Descreve como os dados de entrada são compactados
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Descreve uma fonte de dados de entrada que contém dados de referência. Necessário em solicitações PUT (CreateOrReplace).
diagnostics	Diagnostics	Descreve as condições aplicáveis à Entrada, à Saída ou ao trabalho em geral, que garantem a atenção do cliente.
etag	string	A marca de entidade atual para a entrada. Essa é uma cadeia de caracteres opaca. Você pode usá-lo para detectar se o recurso foi alterado entre solicitações. Você também pode usá-lo nos cabeçalhos If-Match ou If-None-Match para operações de gravação para simultaneidade otimista.
partitionKey	string	partitionKey Descreve uma chave nos dados de entrada que é usada para particionar os dados de entrada
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída. Necessário em solicitações PUT (CreateOrReplace).
type	string: Reference	Indica se a entrada é uma fonte de dados de referência ou dados de fluxo. Necessário em solicitações PUT (CreateOrReplace).

RefreshType

Indica o tipo de opção de atualização de dados.

Nome	Tipo	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

ScalarFunctionProperties

As propriedades associadas a uma função escalar.

Nome	Tipo	Description
etag	string	A marca de entidade atual para a função. Essa é uma cadeia de caracteres opaca. Você pode usá-lo para detectar se o recurso foi alterado entre solicitações. Você também pode usá-lo nos cabeçalhos If-Match ou If-None-Match para operações de gravação para simultaneidade otimista.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	A associação física da função. Por exemplo, no caso do serviço Web do Azure Machine Learning, isso descreve o ponto de extremidade.
properties.inputs	FunctionInput[]	Descreve um parâmetro de entrada de uma função.
properties.output	FunctionOutput	Descreve a saída de uma função.
type	string: Scalar	Indica o tipo de função.

ServiceBusQueueOutputDataSource

Descreve uma fonte de dados de saída da Fila do Barramento de Serviço.

Nome	Tipo	Valor padrão	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.propertyColumns	string[]		Uma matriz de cadeia de caracteres dos nomes das colunas de saída a serem anexadas às mensagens do Barramento de Serviço como propriedades personalizadas.
properties.queueName	string		O nome da fila do Barramento de Serviço. Necessário em solicitações PUT (CreateOrReplace).
properties.serviceBusNamespace	string		O namespace associado ao Hub de Eventos desejado, Fila do Barramento de Serviço, Tópico do Barramento de Serviço etc. Necessário em solicitações PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		A chave de política de acesso compartilhado para a política de acesso compartilhado especificada. Necessário em solicitações PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		O nome da política de acesso compartilhado para o Hub de Eventos, Fila do Barramento de Serviço, Tópico do Barramento de Serviço etc. Necessário em solicitações PUT (CreateOrReplace).
properties.systemPropertyColumns	object		As propriedades do sistema associadas à Fila do Barramento de Serviço. Há suporte para as seguintes propriedades do sistema: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
type	string: Microsoft.ServiceBus/Queue		Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

ServiceBusTopicOutputDataSource

Descreve uma fonte de dados de saída do Tópico do Barramento de Serviço.

Nome	Tipo	Valor padrão	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.propertyColumns	string[]		Uma matriz de cadeia de caracteres dos nomes das colunas de saída a serem anexadas às mensagens do Barramento de Serviço como propriedades personalizadas.
properties.serviceBusNamespace	string		O namespace associado ao Hub de Eventos desejado, Fila do Barramento de Serviço, Tópico do Barramento de Serviço etc. Necessário em solicitações PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		A chave de política de acesso compartilhado para a política de acesso compartilhado especificada. Necessário em solicitações PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		O nome da política de acesso compartilhado para o Hub de Eventos, Fila do Barramento de Serviço, Tópico do Barramento de Serviço etc. Necessário em solicitações PUT (CreateOrReplace).
properties.systemPropertyColumns	object		As propriedades do sistema associadas à Saída do Tópico do Barramento de Serviço. Há suporte para as seguintes propriedades do sistema: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
properties.topicName	string		O nome do Tópico do Barramento de Serviço. Necessário em solicitações PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/Topic		Indica que o tipo de saída da fonte de dados será gravado. Necessário em solicitações PUT (CreateOrReplace).

Sku

As propriedades associadas a um SKU.

Nome	Tipo	Description
name	SkuName	O nome da SKU. Necessário em solicitações PUT (CreateOrReplace).

SkuName

O nome da SKU. Necessário em solicitações PUT (CreateOrReplace).

Nome	Tipo	Description
Standard	string

StorageAccount

As propriedades associadas a uma conta de Armazenamento do Azure

Nome	Tipo	Description
accountKey	string	A chave de conta para a conta de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
accountName	string	O nome da conta de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).

StreamingJob

Um objeto de trabalho de streaming, contendo todas as informações associadas ao trabalho de streaming nomeado.

Nome	Tipo	Description
id	string	ID de recurso totalmente qualificado para o recurso. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Descreve a identidade gerenciada atribuída pelo sistema atribuída a esse trabalho que pode ser usada para autenticar com entradas e saídas.
location	string	A localização geográfica em que o recurso reside
name	string	O nome do recurso
properties.cluster	ClusterInfo	O cluster no qual os trabalhos de streaming serão executados.
properties.compatibilityLevel	CompatibilityLevel	Controla determinados comportamentos de runtime do trabalho de streaming.
properties.contentStoragePolicy	ContentStoragePolicy	Os valores válidos são JobStorageAccount e SystemAccount. Se definido como JobStorageAccount, isso exigirá que o usuário também especifique a propriedade jobStorageAccount. .
properties.createdDate	string	O valor é um carimbo de data/hora UTC formatado em ISO-8601 que indica quando o trabalho de streaming foi criado.
properties.dataLocale	string	A localidade de dados do trabalho do Stream Analytics. Value deve ser o nome de uma cultura .NET com suporte do conjunto https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Se nenhuma for especificada, o padrão será 'en-US'.
properties.etag	string	A marca de entidade atual para o trabalho de streaming. Essa é uma cadeia de caracteres opaca. Você pode usá-lo para detectar se o recurso foi alterado entre solicitações. Você também pode usá-lo nos cabeçalhos If-Match ou If-None-Match para operações de gravação para simultaneidade otimista.
properties.eventsLateArrivalMaxDelayInSeconds	integer	O atraso máximo tolerável em segundos em que os eventos que chegam atrasados podem ser incluídos. O intervalo com suporte é de -1 a 1814399 (20.23:59:59 dias) e -1 é usado para especificar a espera indefinidamente. Se a propriedade estiver ausente, ela será interpretada como tendo um valor de -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	O atraso máximo tolerável em segundos em que os eventos fora de ordem podem ser ajustados para voltar à ordem.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Indica a política a ser aplicada aos eventos que chegam fora de ordem no fluxo de eventos de entrada.
properties.functions	Function[]	Uma lista de uma ou mais funções para o trabalho de streaming. A propriedade name para cada função é necessária ao especificar essa propriedade em uma solicitação PUT. Essa propriedade não pode ser modificada por meio de uma operação PATCH. Você deve usar a API PATCH disponível para a transformação individual.
properties.inputs	Input[]	Uma lista de uma ou mais entradas para o trabalho de streaming. A propriedade name para cada entrada é necessária ao especificar essa propriedade em uma solicitação PUT. Essa propriedade não pode ser modificada por meio de uma operação PATCH. Você deve usar a API PATCH disponível para a entrada individual.
properties.jobId	string	Um GUID que identifica exclusivamente o trabalho de streaming. Esse GUID é gerado após a criação do trabalho de streaming.
properties.jobState	string	Descreve o estado do trabalho de streaming.
properties.jobStorageAccount	JobStorageAccount	As propriedades associadas a uma conta de Armazenamento do Azure com MSI
properties.jobType	JobType	Descreve o tipo do trabalho. Os modos válidos são Cloud e "Edge".
properties.lastOutputEventTime	string	Value é um carimbo de data/hora formatado iso-8601 que indica a hora do último evento de saída do trabalho de streaming ou nulo indicando que a saída ainda não foi produzida. No caso de várias saídas ou vários fluxos, isso mostra o valor mais recente nesse conjunto.
properties.outputErrorPolicy	OutputErrorPolicy	Indica a política a ser aplicada aos eventos que chegam à saída e não podem ser gravados no armazenamento externo por estarem malformados (faltando valores de coluna, valores de coluna de tipo ou tamanho incorreto).
properties.outputStartMode	OutputStartMode	Essa propriedade só deve ser utilizada quando desejar que o trabalho seja iniciado imediatamente após a criação. O valor pode ser JobStartTime, CustomTime ou LastOutputEventTime para indicar se o ponto inicial do fluxo de eventos de saída deve ser iniciado sempre que o trabalho for iniciado, iniciar em um carimbo de data/hora do usuário personalizado especificado por meio da propriedade outputStartTime ou começar a partir da hora de saída do último evento.
properties.outputStartTime	string	O valor é um carimbo de hora formatados com o ISO 8601 que indica o ponto de partida do fluxo de eventos de saída ou nulo para indicar que o fluxo de eventos de saída será iniciado sempre que o trabalho de streaming for iniciado. Essa propriedade deve ter um valor se outputStartMode estiver definido como CustomTime.
properties.outputs	Output[]	Uma lista de uma ou mais saídas para o trabalho de streaming. A propriedade name para cada saída é necessária ao especificar essa propriedade em uma solicitação PUT. Essa propriedade não pode ser modificada por meio de uma operação PATCH. Você deve usar a API PATCH disponível para a saída individual.
properties.provisioningState	string	Descreve o status de provisionamento do trabalho de streaming.
properties.sku	Sku	Descreve o SKU do trabalho de streaming. Necessário em solicitações PUT (CreateOrReplace).
properties.transformation	Transformation	Indica a consulta e o número de unidades de streaming a serem usadas para o trabalho de streaming. A propriedade name da transformação é necessária ao especificar essa propriedade em uma solicitação PUT. Essa propriedade não pode ser modificada por meio de uma operação PATCH. Você deve usar a API PATCH disponível para a transformação individual.
tags	object	Marcas de recurso.
type	string	Tipo do recurso. Por exemplo: Microsoft.Compute/virtualMachines ou Microsoft.Storage/storageAccounts.

StreamInputProperties

As propriedades associadas a uma entrada que contém dados de fluxo.

Nome	Tipo	Description
compression	Compression	Descreve como os dados de entrada são compactados
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Descreve uma fonte de dados de entrada que contém dados de fluxo. Necessário em solicitações PUT (CreateOrReplace).
diagnostics	Diagnostics	Descreve as condições aplicáveis à Entrada, à Saída ou ao trabalho em geral, que garantem a atenção do cliente.
etag	string	A marca de entidade atual para a entrada. Essa é uma cadeia de caracteres opaca. Você pode usá-lo para detectar se o recurso foi alterado entre solicitações. Você também pode usá-lo nos cabeçalhos If-Match ou If-None-Match para operações de gravação para simultaneidade otimista.
partitionKey	string	partitionKey Descreve uma chave nos dados de entrada que é usada para particionar os dados de entrada
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída. Necessário em solicitações PUT (CreateOrReplace).
type	string: Stream	Indica se a entrada é uma fonte de dados de referência ou dados de fluxo. Necessário em solicitações PUT (CreateOrReplace).

Transformation

Um objeto de transformação que contém todas as informações associadas à transformação nomeada. Todas as transformações estão contidas em um trabalho de streaming.

Nome	Tipo	Valor padrão	Description
id	string		ID do recurso
name	string		Nome do recurso
properties.etag	string		A marca de entidade atual para a transformação. Essa é uma cadeia de caracteres opaca. Você pode usá-lo para detectar se o recurso foi alterado entre solicitações. Você também pode usá-lo nos cabeçalhos If-Match ou If-None-Match para operações de gravação para simultaneidade otimista.
properties.query	string		Especifica a consulta que será executada no trabalho de streaming. Você pode saber mais sobre a SAQL (Linguagem de Consulta do Stream Analytics) aqui: https://msdn.microsoft.com/library/azure/dn834998 . Necessário em solicitações PUT (CreateOrReplace).
properties.streamingUnits	integer	3	Especifica o número de unidades de streaming que usa o trabalho de streaming.
properties.validStreamingUnits	integer[]		Especifica as unidades de streaming válidas para as quais um trabalho de streaming pode ser dimensionado.
type	string		Tipo de recurso