Streaming Jobs - Create Or Replace

Serviço:

Stream Analytics

Versão da API:

2020-03-01

Cria uma tarefa de transmissão em fluxo ou substitui uma tarefa de transmissão em fluxo já existente.

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

Parâmetros do URI

Name	Em	Necessário	Tipo	Description
jobName	path	True	string	O nome da tarefa de transmissão em fluxo.
resourceGroupName	path	True	string	O nome do grupo de recursos. O nome não é sensível a maiúsculas e minúsculas. Padrão Regex: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	O ID da subscrição de destino.
api-version	query	True	string	A versão da API a utilizar para esta operação.

Cabeçalho do Pedido

Name	Necessário	Tipo	Description
If-Match		string	O ETag da tarefa de transmissão em fluxo. Omita este valor para substituir sempre o conjunto de registos atual. Especifique o valor ETag visto pela última vez para evitar a substituição acidental de alterações simultâneas.
If-None-Match		string	Defina como '*' para permitir a criação de uma nova tarefa de transmissão em fluxo, mas para impedir a atualização de um conjunto de registos existente. Outros valores resultarão numa resposta 412 Pré-condição Falhada.

Corpo do Pedido

Name	Tipo	Description
identity	Identity	Descreve a identidade gerida atribuída pelo sistema atribuída a esta tarefa que pode ser utilizada para autenticar com entradas e saídas.
location	string	A localização geográfica onde o recurso se encontra
properties.cluster	ClusterInfo	O cluster em que as tarefas de transmissão em fluxo serão executadas.
properties.compatibilityLevel	CompatibilityLevel	Controla determinados comportamentos de runtime da tarefa de transmissão em fluxo.
properties.contentStoragePolicy	ContentStoragePolicy	Os valores válidos são JobStorageAccount e SystemAccount. Se estiver definido como JobStorageAccount, isto requer que o utilizador também especifique a propriedade jobStorageAccount. .
properties.dataLocale	string	A região de dados da tarefa de análise de fluxos. O valor deve ser o nome de uma Cultura .NET suportada do conjunto https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. A predefinição é "en-US" se nenhuma especificada.
properties.eventsLateArrivalMaxDelayInSeconds	integer	O atraso máximo tolerável em segundos em que os eventos que chegam atrasados podem ser incluídos. O intervalo suportado é de -1 a 1814399 (20.23:59:59 dias) e -1 é utilizado para especificar a espera indefinidamente. Se a propriedade estiver ausente, será interpretado como se tivesse um valor de -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	O atraso tolerável máximo em segundos em que os eventos fora de ordem podem ser ajustados para estarem de volta à ordem.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Indica a política a aplicar 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 a tarefa de transmissão em fluxo. A propriedade name para cada função é necessária ao especificar esta propriedade num pedido PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Tem de utilizar a API PATCH disponível para a transformação individual.
properties.inputs	Input[]	Uma lista de uma ou mais entradas para a tarefa de transmissão em fluxo. A propriedade name para cada entrada é necessária ao especificar esta propriedade num pedido PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Tem de utilizar 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 de tarefa. Os modos válidos são Cloud e "Edge".
properties.outputErrorPolicy	OutputErrorPolicy	Indica a política a aplicar a eventos que chegam à saída e que não podem ser escritos no armazenamento externo devido a uma forma incorreta (valores de coluna em falta, valores de coluna de tipo ou tamanho errado).
properties.outputStartMode	OutputStartMode	Esta propriedade só deve ser utilizada quando pretender que a tarefa seja iniciada imediatamente após a criação. O valor pode ser JobStartTime, CustomTime ou LastOutputEventTime para indicar se o ponto de partida do fluxo de eventos de saída deve ser iniciado sempre que a tarefa for iniciada, começar com um carimbo de data/hora de utilizador personalizado especificado através da propriedade outputStartTime ou começar a partir da hora de saída do último evento.
properties.outputStartTime	string	O valor é um carimbo de data/hora formatado 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 a tarefa de transmissão em fluxo for iniciada. Esta propriedade tem de ter um valor se outputStartMode estiver definido como CustomTime.
properties.outputs	Output[]	Uma lista de uma ou mais saídas para a tarefa de transmissão em fluxo. A propriedade name para cada saída é necessária ao especificar esta propriedade num pedido PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Tem de utilizar a API PATCH disponível para o resultado individual.
properties.sku	Sku	Descreve o SKU da tarefa de transmissão em fluxo. Necessário em pedidos PUT (CreateOrReplace).
properties.transformation	Transformation	Indica a consulta e o número de unidades de transmissão em fluxo a utilizar para a tarefa de transmissão em fluxo. A propriedade name da transformação é necessária ao especificar esta propriedade num pedido PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Tem de utilizar a API PATCH disponível para a transformação individual.
tags	object	Etiquetas de recursos.

Respostas

Name	Tipo	Description
200 OK	StreamingJob	A tarefa de transmissão em fluxo foi criada ou substituída com êxito. Cabeçalhos ETag: string
201 Created	StreamingJob	A tarefa de transmissão em fluxo foi criada ou substituída com êxito. Cabeçalhos ETag: string
Other Status Codes	Error	Error.

Segurança

azure_auth

Fluxo OAuth2 do Azure Active Directory

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

Âmbitos

Name	Description
user_impersonation	representar a sua conta de utilizador

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)

Pedido de amostra

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", "value1", "key3", "value3", "randomKey", "randomValue"))
            .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("yourAccountKey==")))
                                            .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())))
            .withFunctions(Arrays.asList())
            .create();
    }

    @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 da amostra

Código de estado:

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 estado:

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)

Pedido de amostra

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", "value1", "key3", "value3", "randomKey", "randomValue"))
            .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();
    }

    @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 da amostra

Código de estado:

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 estado:

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

Name	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 são escritos numa saída no formato Avro.
AzureDataLakeStoreOutputDataSource	Descreve uma origem de dados de saída do Azure Data Lake Store.
AzureFunctionOutputDataSource	Define os metadados de AzureFunctionOutputDataSource
AzureMachineLearningWebServiceFunctionBinding	O enlace a um serviço Web do Azure Machine Learning.
AzureMachineLearningWebServiceInputColumn	Descreve uma coluna de entrada para o ponto final de serviço Web do Azure Machine Learning.
AzureMachineLearningWebServiceInputs	As entradas para o ponto final de serviço Web do Azure Machine Learning.
AzureMachineLearningWebServiceOutputColumn	Descreve uma coluna de saída para o ponto final de serviço Web do Azure Machine Learning.
AzureSqlDatabaseOutputDataSource	Descreve uma SQL do Azure origem de dados de saída da base de dados.
AzureSqlReferenceInputDataSource	Descreve uma origem de dados de entrada de referência de base de dados SQL do Azure.
AzureSynapseOutputDataSource	Descreve uma origem de dados de saída Azure Synapse.
AzureTableOutputDataSource	Descreve uma origem de dados de saída da Tabela do Azure.
BlobOutputDataSource	Descreve uma origem de dados de saída de blobs.
BlobReferenceInputDataSource	Descreve uma origem de dados de entrada de blobs que contém dados de referência.
BlobStreamInputDataSource	Descreve uma origem de dados de entrada de blobs que contém dados de fluxo.
ClusterInfo	As propriedades associadas a um cluster do Stream Analytics.
CompatibilityLevel	Controla determinados comportamentos de runtime da tarefa de transmissão em fluxo.
Compression	Descreve como os dados de entrada são comprimidos
CompressionType	Indica o tipo de compressão que a entrada utiliza. Necessário em pedidos PUT (CreateOrReplace).
ContentStoragePolicy	Os valores válidos são JobStorageAccount e SystemAccount. Se estiver definido como JobStorageAccount, é necessário que o utilizador especifique também a propriedade jobStorageAccount. .
CsvSerialization	Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando são escritos numa saída no formato CSV.
DiagnosticCondition	Condição aplicável ao recurso, ou ao trabalho geral, que justifica a atenção do cliente.
Diagnostics	Descreve as condições aplicáveis à Entrada, Saída ou tarefa geral, que garantem a atenção do cliente.
DocumentDbOutputDataSource	Descreve uma origem de dados de saída do DocumentDB.
Encoding	Especifica a codificação dos dados recebidos no caso da entrada e da codificação de dados de saída em caso de saída.
Error	Representação de erros comuns.
EventHubOutputDataSource	Descreve uma origem de dados de saída do Hub de Eventos.
EventHubStreamInputDataSource	Descreve uma origem de dados de entrada do Hub de Eventos que contém dados de fluxo.
EventHubV2OutputDataSource	Descreve uma origem de dados de saída do Hub de Eventos.
EventHubV2StreamInputDataSource	Descreve uma origem 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 utiliza. Necessário em pedidos PUT (CreateOrReplace).
EventsOutOfOrderPolicy	Indica a política a aplicar aos eventos que chegam fora de ordem no fluxo de eventos de entrada.
FileReferenceInputDataSource	Descreve uma origem de dados de entrada de ficheiro que contém dados de referência.
Function	Um objeto de função que contém todas as informações associadas à função nomeada. Todas as funções estão contidas numa tarefa de transmissão em fluxo.
FunctionInput	Descreve um parâmetro de entrada de uma função.
FunctionOutput	Descreve o resultado de uma função.
GatewayMessageBusOutputDataSource	Descreve uma origem de dados de saída do Gateway Message Bus.
GatewayMessageBusStreamInputDataSource	Descreve uma origem de dados de entrada de blobs que contém dados de fluxo.
Identity	Descreve como a identidade é verificada
Input	Um objeto de entrada que contém todas as informações associadas à entrada nomeada. Todas as entradas estão contidas numa tarefa de transmissão em fluxo.
IoTHubStreamInputDataSource	Descreve uma origem de dados de entrada Hub IoT que contém dados de fluxo.
JavaScriptFunctionBinding	O enlace a uma função JavaScript.
JobStorageAccount	As propriedades associadas a uma conta de Armazenamento do Azure com MSI
JobType	Descreve o tipo de tarefa. Os modos válidos são Cloud e "Edge".
JsonOutputSerializationFormat	Especifica o formato do JSON no qual a saída será escrita. Os valores atualmente suportados são "lineSeparated" que indica que a saída será formatada ao ter cada objeto JSON separado por uma nova linha e "matriz" a indicar 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 são escritos numa saída no formato JSON.
Output	Um objeto de saída, que contém todas as informações associadas à saída nomeada. Todas as saídas estão contidas numa tarefa de transmissão em fluxo.
OutputErrorPolicy	Indica a política a aplicar aos eventos que chegam à saída e não podem ser escritos no armazenamento externo devido a um formato incorreto (valores de coluna em falta, valores de coluna de tipo ou tamanho errados).
OutputStartMode	O valor pode ser JobStartTime, CustomTime ou LastOutputEventTime para indicar se o ponto de partida do fluxo de eventos de saída deve ser iniciado sempre que a tarefa for iniciada, começar com um carimbo de data/hora de utilizador personalizado especificado através 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 são escritos numa saída no formato Parquet.
PowerBIOutputDataSource	Descreve uma origem 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 origem de dados de saída da Fila do Service Bus.
ServiceBusTopicOutputDataSource	Descreve uma origem de dados de saída do Tópico do Service Bus.
Sku	As propriedades associadas a um SKU.
SkuName	O nome do SKU. Necessário em pedidos PUT (CreateOrReplace).
StorageAccount	As propriedades associadas a uma conta de Armazenamento do Azure
StreamingJob	Um objeto de tarefa de transmissão em fluxo, que contém todas as informações associadas à tarefa de transmissão em fluxo nomeada.
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 numa tarefa de transmissão em fluxo.

AggregateFunctionProperties

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

Name	Tipo	Description
etag	string	A etiqueta de entidade atual para a função. Esta é uma cadeia opaca. Pode utilizá-lo para detetar se o recurso foi alterado entre pedidos. Também pode utilizá-lo nos cabeçalhos If-Match ou If-None-Match para operações de escrita para simultaneidade otimista.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	O enlace físico da função. Por exemplo, no caso do serviço Web Azure Machine Learning, isto descreve o ponto final.
properties.inputs	FunctionInput[]	Descreve um parâmetro de entrada de uma função.
properties.output	FunctionOutput	Descreve o resultado 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".

Name	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 são escritos numa saída no formato Avro.

Name	Tipo	Description
type	string: Avro	Indica o tipo de serialização que a entrada ou saída utiliza. Necessário em pedidos PUT (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

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

Name	Tipo	Default value	Description
properties.accountName	string		O nome da conta do Azure Data Lake Store. Necessário em pedidos PUT (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.dateFormat	string		O formato de data. Sempre que {date} aparecer em filePathPrefix, o valor desta propriedade é utilizado como o formato de data.
properties.filePathPrefix	string		A localização do ficheiro no qual a saída deve ser escrita. Necessário em pedidos PUT (CreateOrReplace).
properties.refreshToken	string		Um token de atualização que pode ser utilizado para obter um token de acesso válido que pode ser utilizado para autenticar com a origem de dados. Atualmente, um token de atualização válido só pode ser obtido através do portal do Azure. Recomenda-se colocar aqui um valor de cadeia fictício ao criar a origem de dados e, em seguida, aceder ao Portal do Azure para autenticar a origem de dados que irá atualizar esta propriedade com um token de atualização válido. Necessário em pedidos PUT (CreateOrReplace).
properties.tenantId	string		O ID de inquilino do utilizador utilizado para obter o token de atualização. Necessário em pedidos PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Onde {time} aparecer em filePathPrefix, o valor desta propriedade é utilizado como o formato de hora.
properties.tokenUserDisplayName	string		O nome a apresentar do utilizador que foi utilizado para obter o token de atualização. Utilize esta propriedade para ajudar a lembrar que utilizador foi utilizado para obter o token de atualização.
properties.tokenUserPrincipalName	string		O nome principal de utilizador (UPN) do utilizador que foi utilizado para obter o token de atualização. Utilize esta propriedade para ajudar a lembrar que utilizador foi utilizado para obter o token de atualização.
type	string: Microsoft.DataLake/Accounts		Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

AzureFunctionOutputDataSource

Define os metadados de AzureFunctionOutputDataSource

Name	Tipo	Description
properties.apiKey	string	Se quiser utilizar uma Função do Azure a partir de outra subscrição, pode fazê-lo ao fornecer a chave para aceder à sua função.
properties.functionAppName	string	O nome da sua aplicação Funções do Azure.
properties.functionName	string	O nome da função na sua aplicação Funções do Azure.
properties.maxBatchCount	number	Uma propriedade que lhe permite especificar o número máximo de eventos em cada lote que é enviado para Funções do Azure. O valor predefinido é 100.
properties.maxBatchSize	number	Uma propriedade que lhe permite definir o tamanho máximo para cada lote de saída que é enviado para a função do Azure. A unidade de entrada está em bytes. Por predefinição, este valor é de 262 144 bytes (256 KB).
type	string: Microsoft.AzureFunction	Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

O enlace a um serviço Web do Azure Machine Learning.

Name	Tipo	Description
properties.apiKey	string	A chave de API utilizada para autenticar com Request-Response ponto final.
properties.batchSize	integer	Número entre 1 e 10000 que descreve o número máximo de linhas para cada pedido de execução do RRS do Azure ML. A predefinição é 1000.
properties.endpoint	string	O Request-Response executar o ponto final do serviço Web 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 final de serviço Web do Azure Machine Learning.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Uma lista de saídas da execução do ponto final de serviço Web do Azure Machine Learning.
type	string: Microsoft.MachineLearning/WebService	Indica o tipo de enlace de função.

AzureMachineLearningWebServiceInputColumn

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

Name	Tipo	Description
dataType	string	O tipo de dados (suportado pelo Azure Machine Learning) da coluna de entrada. É descrita uma lista de tipos de dados válidos do Azure Machine Learning em https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
mapTo	integer	O índice baseado em zero do parâmetro de função a que esta entrada é mapeado.
name	string	O nome da coluna de entrada.

AzureMachineLearningWebServiceInputs

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

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

AzureMachineLearningWebServiceOutputColumn

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

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

AzureSqlDatabaseOutputDataSource

Descreve uma SQL do Azure origem de dados de saída da base de dados.

Name	Tipo	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.database	string		O nome da base de dados SQL do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.maxBatchCount	number		Contagem máxima do Batch para escrita na base de dados Sql, o valor predefinido é 10 000. Opcional em pedidos PUT.
properties.maxWriterCount	number		Contagem máxima de Escritores, atualmente estão disponíveis apenas 1 (escritor único) e 0 (com base na partição de consulta). Opcional em pedidos PUT.
properties.password	string		A palavra-passe que será utilizada para ligar à base de dados SQL do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.server	string		O nome do servidor SQL que contém a base de dados SQL do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.table	string		O nome da tabela na base de dados SQL do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.user	string		O nome de utilizador que será utilizado para ligar à base de dados SQL do Azure. Necessário em pedidos PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/Database		Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Descreve uma origem de dados de entrada de referência de base de dados SQL do Azure.

Name	Tipo	Description
properties.database	string	Este elemento está associado ao elemento de origem de dados. Este é o nome da base de dados na qual a saída será escrita.
properties.deltaSnapshotQuery	string	Este elemento está associado ao elemento de origem de dados. Esta consulta é utilizada para obter alterações incrementais da base de dados SQL. Para utilizar esta opção, recomendamos a utilização de tabelas temporais na Base de Dados SQL do Azure.
properties.fullSnapshotQuery	string	Este elemento está associado ao elemento de origem de dados. Esta consulta é utilizada para obter dados da base de dados sql.
properties.password	string	Este elemento está associado ao elemento de origem de dados. Esta é a palavra-passe que será utilizada para ligar à instância Base de Dados SQL.
properties.refreshRate	string	Este elemento está associado ao elemento de origem de dados. Isto indica a frequência com que os dados serão obtidos a partir da base de dados. É do formato DateTime.
properties.refreshType	RefreshType	Indica o tipo de opção de atualização de dados.
properties.server	string	Este elemento está associado ao elemento de origem de dados. Este é o nome do servidor que contém a base de dados que será escrita.
properties.table	string	Este elemento está associado ao elemento de origem de dados. O nome da tabela na base de dados SQL do Azure..
properties.user	string	Este elemento está associado ao elemento de origem de dados. Este é o nome de utilizador que será utilizado para ligar à instância Base de Dados SQL.
type	string: Microsoft.Sql/Server/Database	Indica o tipo de origem de dados de entrada que contém dados de referência. Necessário em pedidos PUT (CreateOrReplace).

AzureSynapseOutputDataSource

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

Name	Tipo	Description
properties.database	string	O nome da base de dados SQL do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.password	string	A palavra-passe que será utilizada para ligar à base de dados SQL do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.server	string	O nome do servidor SQL que contém a base de dados SQL do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.table	string	O nome da tabela na base de dados SQL do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.user	string	O nome de utilizador que será utilizado para ligar à base de dados SQL do Azure. Necessário em pedidos PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/DataWarehouse	Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

AzureTableOutputDataSource

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

Name	Tipo	Description
properties.accountKey	string	A chave de conta da conta de Armazenamento do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.accountName	string	O nome da conta de Armazenamento do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.batchSize	integer	O número de linhas a escrever na Tabela do Azure de cada vez.
properties.columnsToRemove	string[]	Se for especificado, cada item na matriz é o nome de uma coluna a remover (se estiver presente) das entidades de eventos de saída.
properties.partitionKey	string	Este elemento indica o nome de uma coluna da instrução SELECT na consulta que será utilizada como a chave de partição da Tabela do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.rowKey	string	Este elemento indica o nome de uma coluna da instrução SELECT na consulta que será utilizada como a chave de linha da Tabela do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.table	string	O nome da Tabela do Azure. Necessário em pedidos PUT (CreateOrReplace).
type	string: Microsoft.Storage/Table	Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

BlobOutputDataSource

Descreve uma origem de dados de saída de blobs.

Name	Tipo	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.blobPathPrefix	string		Prefixo do caminho do blob.
properties.container	string		O nome de um contentor na conta de Armazenamento associada. Este contentor contém os blobs a serem lidos ou escritos. Necessário em pedidos PUT (CreateOrReplace).
properties.dateFormat	string		O formato de data. Onde {date} aparecer em pathPattern, o valor desta propriedade é utilizado como o formato de data.
properties.pathPattern	string		O padrão do caminho do blob. Não é uma expressão normal. Representa um padrão em relação ao qual os nomes de blobs serão correspondidos para determinar se devem ou não ser incluídos como entrada ou saída para a tarefa. Veja 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 exemplo mais detalhados.
properties.storageAccounts	StorageAccount[]		Uma lista de uma ou mais contas de Armazenamento do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Onde {time} aparecer em pathPattern, o valor desta propriedade é utilizado como o formato de hora.
type	string: Microsoft.Storage/Blob		Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

BlobReferenceInputDataSource

Descreve uma origem de dados de entrada de blobs que contém dados de referência.

Name	Tipo	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.container	string		O nome de um contentor na conta de Armazenamento associada. Este contentor contém os blob(s) a serem lidos ou escritos em. Necessário em pedidos PUT (CreateOrReplace).
properties.dateFormat	string		O formato de data. Onde quer que {date} apareça no pathPattern, o valor desta propriedade é utilizado como o formato de data.
properties.pathPattern	string		O padrão do caminho do blob. Não é uma expressão normal. Representa um padrão em relação ao qual os nomes de blobs serão correspondidos para determinar se devem ou não ser incluídos como entrada ou saída para a tarefa. Veja 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 pedidos PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Onde quer que {time} apareça no pathPattern, o valor desta propriedade é utilizado como o formato de hora.
type	string: Microsoft.Storage/Blob		Indica o tipo de origem de dados de entrada que contém dados de referência. Necessário em pedidos PUT (CreateOrReplace).

BlobStreamInputDataSource

Descreve uma origem de dados de entrada de blobs que contém dados de fluxo.

Name	Tipo	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.container	string		O nome de um contentor na conta de Armazenamento associada. Este contentor contém os blob(s) a serem lidos ou escritos em. Necessário em pedidos PUT (CreateOrReplace).
properties.dateFormat	string		O formato de data. Onde quer que {date} apareça no pathPattern, o valor desta propriedade é utilizado como o formato de data.
properties.pathPattern	string		O padrão do caminho do blob. Não é uma expressão normal. Representa um padrão em relação ao qual os nomes de blobs serão correspondidos para determinar se devem ou não ser incluídos como entrada ou saída para a tarefa. Veja 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 origem de dados de entrada de blobs. Intervalo 1 - 1024.
properties.storageAccounts	StorageAccount[]		Uma lista de uma ou mais contas de Armazenamento do Azure. Necessário em pedidos PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Onde quer que {time} apareça no pathPattern, o valor desta propriedade é utilizado como o formato de hora.
type	string: Microsoft.Storage/Blob		Indica o tipo de origem de dados de entrada que contém dados de fluxo. Necessário em pedidos PUT (CreateOrReplace).

ClusterInfo

As propriedades associadas a um cluster do Stream Analytics.

Name	Tipo	Description
id	string	O ID de recurso do cluster.

CompatibilityLevel

Controla determinados comportamentos de runtime da tarefa de transmissão em fluxo.

Name	Tipo	Description
1.0	string
1.2	string

Compression

Descreve como os dados de entrada são comprimidos

Name	Tipo	Default value	Description
type	CompressionType	None	Indica o tipo de compressão que a entrada utiliza. Necessário em pedidos PUT (CreateOrReplace).

CompressionType

Indica o tipo de compressão que a entrada utiliza. Necessário em pedidos PUT (CreateOrReplace).

Name	Tipo	Description
Deflate	string
GZip	string
None	string

ContentStoragePolicy

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

Name	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 são escritos numa saída no formato CSV.

Name	Tipo	Description
properties.encoding	Encoding	Especifica a codificação dos dados recebidos no caso da entrada e a codificação de dados de saída no caso da saída. Necessário em pedidos PUT (CreateOrReplace).
properties.fieldDelimiter	string	Especifica o delimitador que será utilizado para separar registos de valores separados por vírgulas (CSV). Veja 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 suportados. Necessário em pedidos PUT (CreateOrReplace).
type	string: Csv	Indica o tipo de serialização que a entrada ou saída utiliza. Necessário em pedidos PUT (CreateOrReplace).

DiagnosticCondition

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

Name	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 detalhe. Localizado na Accept-Language do pedido de cliente.
since	string	O carimbo de data/hora UTC de quando a condição começou. Os clientes devem conseguir encontrar um evento correspondente no registo de operações por esta altura.

Diagnostics

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

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

DocumentDbOutputDataSource

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

Name	Tipo	Description
properties.accountId	string	O nome ou ID da conta do DocumentDB. Necessário em pedidos PUT (CreateOrReplace).
properties.accountKey	string	A chave da conta do DocumentDB. Necessário em pedidos PUT (CreateOrReplace).
properties.collectionNamePattern	string	O padrão de nome da coleção para as coleções a serem utilizadas. O formato de nome da coleção pode ser construído com o token opcional {partition}, em que as partições começam a partir de 0. Consulte a secção DocumentDB de https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output para obter mais informações. Necessário em pedidos PUT (CreateOrReplace).
properties.database	string	O nome da base de dados do DocumentDB. Necessário em pedidos PUT (CreateOrReplace).
properties.documentId	string	O nome do campo em eventos de saída utilizados para especificar a chave primária em que as operações de inserção ou atualização se baseiam.
properties.partitionKey	string	O nome do campo em eventos de saída utilizados para especificar a chave para a criação de partições de saída entre coleções. Se "collectionNamePattern" contiver o token {partition}, esta propriedade tem de ser especificada.
type	string: Microsoft.Storage/DocumentDB	Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

Encoding

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

Name	Tipo	Description
UTF8	string

Error

Representação de erros comuns.

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

EventHubOutputDataSource

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

Name	Tipo	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.eventHubName	string		O nome do Hub de Eventos. Necessário em pedidos PUT (CreateOrReplace).
properties.partitionKey	string		A chave/coluna que é utilizada para determinar a partição a enviar dados de eventos.
properties.propertyColumns	string[]		As propriedades associadas a esta saída do Hub de Eventos.
serviceBusNamespace	string		O espaço de nomes associado ao Hub de Eventos pretendido, à Fila do Service Bus, ao Tópico do Service Bus, etc. Necessário em pedidos PUT (CreateOrReplace).
sharedAccessPolicyKey	string		A chave de política de acesso partilhado para a política de acesso partilhado especificada. Necessário em pedidos PUT (CreateOrReplace).
sharedAccessPolicyName	string		O nome da política de acesso partilhado para o Hub de Eventos, Fila do Service Bus, Tópico do Service Bus, etc. Necessário em pedidos PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

EventHubStreamInputDataSource

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

Name	Tipo	Default value	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 utilizado para ler eventos a partir do Hub de Eventos. Especificar nomes de grupos de consumidores distintos para múltiplas entradas permite que cada uma dessas entradas receba os mesmos eventos do Hub de Eventos. Se não for especificado, a entrada utiliza o grupo de consumidores predefinido do Hub de Eventos.
properties.eventHubName	string		O nome do Hub de Eventos. Necessário em pedidos PUT (CreateOrReplace).
serviceBusNamespace	string		O espaço de nomes associado ao Hub de Eventos pretendido, à Fila do Service Bus, ao Tópico do Service Bus, etc. Necessário em pedidos PUT (CreateOrReplace).
sharedAccessPolicyKey	string		A chave de política de acesso partilhado para a política de acesso partilhado especificada. Necessário em pedidos PUT (CreateOrReplace).
sharedAccessPolicyName	string		O nome da política de acesso partilhado para o Hub de Eventos, Fila do Service Bus, Tópico do Service Bus, etc. Necessário em pedidos PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indica o tipo de origem de dados de entrada que contém dados de fluxo. Necessário em pedidos PUT (CreateOrReplace).

EventHubV2OutputDataSource

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

Name	Tipo	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.eventHubName	string		O nome do Hub de Eventos. Necessário em pedidos PUT (CreateOrReplace).
properties.partitionKey	string		A chave/coluna que é utilizada para determinar a partição a enviar dados de eventos.
properties.propertyColumns	string[]		As propriedades associadas a esta saída do Hub de Eventos.
serviceBusNamespace	string		O espaço de nomes associado ao Hub de Eventos pretendido, à Fila do Service Bus, ao Tópico do Service Bus, etc. Necessário em pedidos PUT (CreateOrReplace).
sharedAccessPolicyKey	string		A chave de política de acesso partilhado para a política de acesso partilhado especificada. Necessário em pedidos PUT (CreateOrReplace).
sharedAccessPolicyName	string		O nome da política de acesso partilhado para o Hub de Eventos, Fila do Service Bus, Tópico do Service Bus, etc. Necessário em pedidos PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

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

Name	Tipo	Default value	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 utilizado para ler eventos a partir do Hub de Eventos. Especificar nomes de grupos de consumidores distintos para múltiplas entradas permite que cada uma dessas entradas receba os mesmos eventos do Hub de Eventos. Se não for especificado, a entrada utiliza o grupo de consumidores predefinido do Hub de Eventos.
properties.eventHubName	string		O nome do Hub de Eventos. Necessário em pedidos PUT (CreateOrReplace).
serviceBusNamespace	string		O espaço de nomes associado ao Hub de Eventos pretendido, à Fila do Service Bus, ao Tópico do Service Bus, etc. Necessário em pedidos PUT (CreateOrReplace).
sharedAccessPolicyKey	string		A chave de política de acesso partilhado para a política de acesso partilhado especificada. Necessário em pedidos PUT (CreateOrReplace).
sharedAccessPolicyName	string		O nome da política de acesso partilhado para o Hub de Eventos, Fila do Service Bus, Tópico do Service Bus, etc. Necessário em pedidos PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indica o tipo de origem de dados de entrada que contém dados de fluxo. Necessário em pedidos PUT (CreateOrReplace).

EventSerializationType

Indica o tipo de serialização que a entrada ou saída utiliza. Necessário em pedidos PUT (CreateOrReplace).

Name	Tipo	Description
Avro	string
Csv	string
Json	string
Parquet	string

EventsOutOfOrderPolicy

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

Name	Tipo	Description
Adjust	string
Drop	string

FileReferenceInputDataSource

Descreve uma origem de dados de entrada de ficheiro que contém dados de referência.

Name	Tipo	Description
properties.path	string	O caminho do ficheiro.
type	string: File	Indica o tipo de origem de dados de entrada que contém dados de referência. Necessário em pedidos PUT (CreateOrReplace).

Function

Um objeto de função que contém todas as informações associadas à função nomeada. Todas as funções estão contidas numa tarefa de transmissão em fluxo.

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

Name	Tipo	Description
dataType	string	O tipo de dados (suportado pelo Azure Stream Analytics) do parâmetro de entrada da função. É descrita uma lista de tipos de dados válidos do Azure Stream Analytics 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. Verdadeiro se se espera que este parâmetro de entrada seja uma constante. A predefinição é falso.

FunctionOutput

Descreve o resultado de uma função.

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

GatewayMessageBusOutputDataSource

Descreve uma origem de dados de saída do Gateway Message Bus.

Name	Tipo	Description
properties.topic	string	O nome do tópico do Service Bus.
type	string: GatewayMessageBus	Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Descreve uma origem de dados de entrada de blobs que contém dados de fluxo.

Name	Tipo	Description
properties.topic	string	O nome do tópico do Service Bus.
type	string: GatewayMessageBus	Indica o tipo de origem de dados de entrada que contém dados de fluxo. Necessário em pedidos PUT (CreateOrReplace).

Identity

Descreve como a identidade é verificada

Name	Tipo	Description
principalId	string	O ID do principal de identidade
tenantId	string	O identity tenantId
type	string	O tipo de identidade

Input

Um objeto de entrada que contém todas as informações associadas à entrada nomeada. Todas as entradas estão contidas numa tarefa de transmissão em fluxo.

Name	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 pedidos PUT (CreateOrReplace).
type	string	Tipo de recurso

IoTHubStreamInputDataSource

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

Name	Tipo	Description
properties.consumerGroupName	string	O nome de um Grupo de Consumidores Hub IoT que deve ser utilizado para ler eventos do Hub IoT. Se não for especificado, a entrada utiliza o grupo de consumidores predefinido do Hub Iot.
properties.endpoint	string	O ponto final Hub IoT ao qual se ligar (ou seja, mensagens/eventos, mensagens/operaçõesMonitorizaçãoEventos, etc.).
properties.iotHubNamespace	string	O nome ou o URI do Hub IoT. Necessário em pedidos PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	A chave de política de acesso partilhado para a política de acesso partilhado especificada. Necessário em pedidos PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	O nome da política de acesso partilhado do Hub IoT. Esta política tem de conter, pelo menos, a permissão ligação do Serviço. Necessário em pedidos PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Indica o tipo de origem de dados de entrada que contém dados de fluxo. Necessário em pedidos PUT (CreateOrReplace).

JavaScriptFunctionBinding

O enlace a uma função JavaScript.

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

JobStorageAccount

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

Name	Tipo	Default value	Description
accountKey	string		A chave de conta da conta de Armazenamento do Azure. Necessário em pedidos PUT (CreateOrReplace).
accountName	string		O nome da conta de Armazenamento do Azure. Necessário em pedidos PUT (CreateOrReplace).
authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.

JobType

Descreve o tipo de tarefa. Os modos válidos são Cloud e "Edge".

Name	Tipo	Description
Cloud	string
Edge	string

JsonOutputSerializationFormat

Especifica o formato do JSON no qual a saída será escrita. Os valores atualmente suportados são "lineSeparated" que indica que a saída será formatada ao ter cada objeto JSON separado por uma nova linha e "matriz" a indicar que a saída será formatada como uma matriz de objetos JSON.

Name	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 são escritos numa saída no formato JSON.

Name	Tipo	Description
properties.encoding	Encoding	Especifica a codificação dos dados recebidos no caso da entrada e a codificação de dados de saída no caso da saída. Necessário em pedidos PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Esta propriedade aplica-se apenas à serialização JSON de saídas. Não é aplicável a entradas. Esta propriedade especifica o formato do JSON no qual a saída será escrita. Os valores atualmente suportados são "lineSeparated" que indica que a saída será formatada ao separar cada objeto JSON por uma nova linha e "matriz", que indica que a saída será formatada como uma matriz de objetos JSON. O valor predefinido é "lineSeparated" se for deixado nulo.
type	string: Json	Indica o tipo de serialização que a entrada ou saída utiliza. Necessário em pedidos PUT (CreateOrReplace).

Output

Um objeto de saída, que contém todas as informações associadas à saída nomeada. Todas as saídas estão contidas numa tarefa de transmissão em fluxo.

Name	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 origem de dados na qual a saída será escrita. Necessário em pedidos PUT (CreateOrReplace).
properties.diagnostics	Diagnostics	Descreve as condições aplicáveis à Entrada, Saída ou à tarefa em geral, que garantem a atenção do cliente.
properties.etag	string	A etiqueta de entidade atual para o resultado. Esta é uma cadeia opaca. Pode utilizá-lo para detetar se o recurso mudou entre pedidos. Também pode utilizá-lo nos cabeçalhos If-Match ou If-None-Match para operações de escrita 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 escritos numa saída. Necessário em pedidos PUT (CreateOrReplace).
properties.sizeWindow	integer	A janela de tamanho para restringir uma saída do Stream Analytics.
properties.timeWindow	string	O período de tempo para filtrar saídas de tarefas do Stream Analytics.
type	string	Tipo de recurso

OutputErrorPolicy

Indica a política a aplicar aos eventos que chegam à saída e não podem ser escritos no armazenamento externo devido a um formato incorreto (valores de coluna em falta, valores de coluna de tipo ou tamanho errados).

Name	Tipo	Description
Drop	string
Stop	string

OutputStartMode

O valor pode ser JobStartTime, CustomTime ou LastOutputEventTime para indicar se o ponto de partida do fluxo de eventos de saída deve ser iniciado sempre que a tarefa for iniciada, começar com um carimbo de data/hora de utilizador personalizado especificado através da propriedade outputStartTime ou começar a partir da hora de saída do último evento.

Name	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 são escritos numa saída no formato Parquet.

Name	Tipo	Description
type	string: Parquet	Indica o tipo de serialização que a entrada ou saída utiliza. Necessário em pedidos PUT (CreateOrReplace).

PowerBIOutputDataSource

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

Name	Tipo	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.dataset	string		O nome do conjunto de dados do Power BI. Necessário em pedidos PUT (CreateOrReplace).
properties.groupId	string		O ID do grupo do Power BI.
properties.groupName	string		O nome do grupo do Power BI. Utilize esta propriedade para ajudar a lembrar que ID de grupo específico do Power BI foi utilizado.
properties.refreshToken	string		Um token de atualização que pode ser utilizado para obter um token de acesso válido que pode ser utilizado para autenticar com a origem de dados. Atualmente, um token de atualização válido só pode ser obtido através do portal do Azure. Recomenda-se colocar aqui um valor de cadeia fictício ao criar a origem de dados e, em seguida, aceder ao Portal do Azure para autenticar a origem de dados que irá atualizar esta propriedade com um token de atualização válido. Necessário em pedidos PUT (CreateOrReplace).
properties.table	string		O nome da tabela do Power BI no conjunto de dados especificado. Necessário em pedidos PUT (CreateOrReplace).
properties.tokenUserDisplayName	string		O nome a apresentar do utilizador que foi utilizado para obter o token de atualização. Utilize esta propriedade para ajudar a lembrar que utilizador foi utilizado para obter o token de atualização.
properties.tokenUserPrincipalName	string		O nome principal de utilizador (UPN) do utilizador que foi utilizado para obter o token de atualização. Utilize esta propriedade para ajudar a lembrar que utilizador foi utilizado para obter o token de atualização.
type	string: PowerBI		Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

ReferenceInputProperties

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

Name	Tipo	Description
compression	Compression	Descreve como os dados de entrada são comprimidos
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Descreve uma origem de dados de entrada que contém dados de referência. Necessário em pedidos PUT (CreateOrReplace).
diagnostics	Diagnostics	Descreve as condições aplicáveis à Entrada, Saída ou tarefa geral, que garantem a atenção do cliente.
etag	string	A etiqueta de entidade atual para a entrada. Esta é uma cadeia opaca. Pode utilizá-lo para detetar se o recurso foi alterado entre pedidos. Também pode utilizá-lo nos cabeçalhos If-Match ou If-None-Match para operações de escrita para simultaneidade otimista.
partitionKey	string	partitionKey Descreve uma chave nos dados de entrada que é utilizada para criar partições dos 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 são escritos numa saída. Necessário em pedidos PUT (CreateOrReplace).
type	string: Reference	Indica se a entrada é uma origem de dados de referência ou dados de fluxo. Necessário em pedidos PUT (CreateOrReplace).

RefreshType

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

Name	Tipo	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

ScalarFunctionProperties

As propriedades associadas a uma função escalar.

Name	Tipo	Description
etag	string	A etiqueta de entidade atual para a função. Esta é uma cadeia opaca. Pode utilizá-lo para detetar se o recurso foi alterado entre pedidos. Também pode utilizá-lo nos cabeçalhos If-Match ou If-None-Match para operações de escrita para simultaneidade otimista.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	O enlace físico da função. Por exemplo, no caso do serviço Web Azure Machine Learning, isto descreve o ponto final.
properties.inputs	FunctionInput[]	Descreve um parâmetro de entrada de uma função.
properties.output	FunctionOutput	Descreve o resultado de uma função.
type	string: Scalar	Indica o tipo de função.

ServiceBusQueueOutputDataSource

Descreve uma origem de dados de saída da Fila do Service Bus.

Name	Tipo	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.propertyColumns	string[]		Uma matriz de cadeia dos nomes das colunas de saída a anexar às mensagens do Service Bus como propriedades personalizadas.
properties.queueName	string		O nome da Fila do Service Bus. Necessário em pedidos PUT (CreateOrReplace).
properties.serviceBusNamespace	string		O espaço de nomes associado ao Hub de Eventos pretendido, à Fila do Service Bus, ao Tópico do Service Bus, etc. Necessário em pedidos PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		A chave de política de acesso partilhado para a política de acesso partilhado especificada. Necessário em pedidos PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		O nome da política de acesso partilhado para o Hub de Eventos, Fila do Service Bus, Tópico do Service Bus, etc. Necessário em pedidos PUT (CreateOrReplace).
properties.systemPropertyColumns	object		As propriedades do sistema associadas à Fila do Service Bus. As seguintes propriedades do sistema são suportadas: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
type	string: Microsoft.ServiceBus/Queue		Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

ServiceBusTopicOutputDataSource

Descreve uma origem de dados de saída do Tópico do Service Bus.

Name	Tipo	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de Autenticação.
properties.propertyColumns	string[]		Uma matriz de cadeia dos nomes das colunas de saída a anexar às mensagens do Service Bus como propriedades personalizadas.
properties.serviceBusNamespace	string		O espaço de nomes associado ao Hub de Eventos pretendido, à Fila do Service Bus, ao Tópico do Service Bus, etc. Necessário em pedidos PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		A chave de política de acesso partilhado para a política de acesso partilhado especificada. Necessário em pedidos PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		O nome da política de acesso partilhado para o Hub de Eventos, Fila do Service Bus, Tópico do Service Bus, etc. Necessário em pedidos PUT (CreateOrReplace).
properties.systemPropertyColumns	object		As propriedades do sistema associadas à Saída do Tópico do Service Bus. As seguintes propriedades do sistema são suportadas: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
properties.topicName	string		O nome do Tópico do Service Bus. Necessário em pedidos PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/Topic		Indica o tipo de saída da origem de dados em que será escrito. Necessário em pedidos PUT (CreateOrReplace).

Sku

As propriedades associadas a um SKU.

Name	Tipo	Description
name	SkuName	O nome do SKU. Necessário em pedidos PUT (CreateOrReplace).

SkuName

O nome do SKU. Necessário em pedidos PUT (CreateOrReplace).

Name	Tipo	Description
Standard	string

StorageAccount

As propriedades associadas a uma conta de Armazenamento do Azure

Name	Tipo	Description
accountKey	string	A chave de conta da conta de Armazenamento do Azure. Necessário em pedidos PUT (CreateOrReplace).
accountName	string	O nome da conta de Armazenamento do Azure. Necessário em pedidos PUT (CreateOrReplace).

StreamingJob

Um objeto de tarefa de transmissão em fluxo, que contém todas as informações associadas à tarefa de transmissão em fluxo nomeada.

Name	Tipo	Description
id	string	ID de recurso completamente qualificado para o recurso. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Descreve a identidade gerida atribuída pelo sistema atribuída a esta tarefa que pode ser utilizada para autenticar com entradas e saídas.
location	string	A localização geográfica onde reside o recurso
name	string	O nome do recurso
properties.cluster	ClusterInfo	O cluster em que as tarefas de transmissão em fluxo serão executadas.
properties.compatibilityLevel	CompatibilityLevel	Controla determinados comportamentos de runtime da tarefa de transmissão em fluxo.
properties.contentStoragePolicy	ContentStoragePolicy	Os valores válidos são JobStorageAccount e SystemAccount. Se estiver definido como JobStorageAccount, é necessário que o utilizador especifique também a propriedade jobStorageAccount. .
properties.createdDate	string	O valor é um carimbo de data/hora UTC formatado ISO-8601 que indica quando a tarefa de transmissão em fluxo foi criada.
properties.dataLocale	string	A região de dados da tarefa de análise de fluxos. O valor deve ser o nome de uma Cultura .NET suportada do conjunto https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. A predefinição é "en-US" se nenhuma especificada.
properties.etag	string	A etiqueta de entidade atual para a tarefa de transmissão em fluxo. Esta é uma cadeia opaca. Pode utilizá-lo para detetar se o recurso foi alterado entre pedidos. Também pode utilizá-lo nos cabeçalhos If-Match ou If-None-Match para operações de escrita 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 suportado é de -1 a 1814399 (20.23:59:59 dias) e -1 é utilizado para especificar a espera indefinidamente. Se a propriedade estiver ausente, será interpretado como se tivesse um valor de -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	O atraso tolerável máximo em segundos em que os eventos fora de ordem podem ser ajustados para estarem de volta à ordem.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Indica a política a aplicar 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 a tarefa de transmissão em fluxo. A propriedade name para cada função é necessária ao especificar esta propriedade num pedido PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Tem de utilizar a API PATCH disponível para a transformação individual.
properties.inputs	Input[]	Uma lista de uma ou mais entradas para a tarefa de transmissão em fluxo. A propriedade name para cada entrada é necessária ao especificar esta propriedade num pedido PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Tem de utilizar a API PATCH disponível para a entrada individual.
properties.jobId	string	Um GUID que identifica exclusivamente a tarefa de transmissão em fluxo. Este GUID é gerado após a criação da tarefa de transmissão em fluxo.
properties.jobState	string	Descreve o estado da tarefa de transmissão em fluxo.
properties.jobStorageAccount	JobStorageAccount	As propriedades associadas a uma conta de Armazenamento do Azure com MSI
properties.jobType	JobType	Descreve o tipo de tarefa. Os modos válidos são Cloud e "Edge".
properties.lastOutputEventTime	string	O valor é um carimbo de data/hora formatado ISO-8601 que indica a hora do último evento de saída da tarefa de transmissão em fluxo ou nulo que indica que a saída ainda não foi produzida. No caso de várias saídas ou de vários fluxos, isto mostra o valor mais recente nesse conjunto.
properties.outputErrorPolicy	OutputErrorPolicy	Indica a política a aplicar a eventos que chegam à saída e que não podem ser escritos no armazenamento externo devido a uma forma incorreta (valores de coluna em falta, valores de coluna de tipo ou tamanho errado).
properties.outputStartMode	OutputStartMode	Esta propriedade só deve ser utilizada quando pretender que a tarefa seja iniciada imediatamente após a criação. O valor pode ser JobStartTime, CustomTime ou LastOutputEventTime para indicar se o ponto de partida do fluxo de eventos de saída deve ser iniciado sempre que a tarefa for iniciada, começar com um carimbo de data/hora de utilizador personalizado especificado através da propriedade outputStartTime ou começar a partir da hora de saída do último evento.
properties.outputStartTime	string	O valor é um carimbo de data/hora formatado 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 a tarefa de transmissão em fluxo for iniciada. Esta propriedade tem de ter um valor se outputStartMode estiver definido como CustomTime.
properties.outputs	Output[]	Uma lista de uma ou mais saídas para a tarefa de transmissão em fluxo. A propriedade name para cada saída é necessária ao especificar esta propriedade num pedido PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Tem de utilizar a API PATCH disponível para o resultado individual.
properties.provisioningState	string	Descreve o estado de aprovisionamento da tarefa de transmissão em fluxo.
properties.sku	Sku	Descreve o SKU da tarefa de transmissão em fluxo. Necessário em pedidos PUT (CreateOrReplace).
properties.transformation	Transformation	Indica a consulta e o número de unidades de transmissão em fluxo a utilizar para a tarefa de transmissão em fluxo. A propriedade name da transformação é necessária ao especificar esta propriedade num pedido PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Tem de utilizar a API PATCH disponível para a transformação individual.
tags	object	Etiquetas de recursos.
type	string	O tipo do recurso. Ex- Microsoft.Compute/virtualMachines ou Microsoft.Storage/storageAccounts.

StreamInputProperties

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

Name	Tipo	Description
compression	Compression	Descreve como os dados de entrada são comprimidos
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Descreve uma origem de dados de entrada que contém dados de fluxo. Necessário em pedidos PUT (CreateOrReplace).
diagnostics	Diagnostics	Descreve as condições aplicáveis à Entrada, Saída ou tarefa geral, que garantem a atenção do cliente.
etag	string	A etiqueta de entidade atual para a entrada. Esta é uma cadeia opaca. Pode utilizá-lo para detetar se o recurso foi alterado entre pedidos. Também pode utilizá-lo nos cabeçalhos If-Match ou If-None-Match para operações de escrita para simultaneidade otimista.
partitionKey	string	partitionKey Descreve uma chave nos dados de entrada que é utilizada para criar partições dos 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 são escritos numa saída. Necessário em pedidos PUT (CreateOrReplace).
type	string: Stream	Indica se a entrada é uma origem de dados de referência ou dados de fluxo. Necessário em pedidos 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 numa tarefa de transmissão em fluxo.

Name	Tipo	Default value	Description
id	string		ID do Recurso
name	string		Nome do recurso
properties.etag	string		A etiqueta de entidade atual para a transformação. Esta é uma cadeia opaca. Pode utilizá-lo para detetar se o recurso mudou entre pedidos. Também pode utilizá-lo nos cabeçalhos If-Match ou If-None-Match para operações de escrita para simultaneidade otimista.
properties.query	string		Especifica a consulta que será executada na tarefa de transmissão em fluxo. Pode saber mais sobre a Linguagem de Consulta do Stream Analytics (SAQL) aqui: https://msdn.microsoft.com/library/azure/dn834998 . Necessário em pedidos PUT (CreateOrReplace).
properties.streamingUnits	integer	3	Especifica o número de unidades de transmissão em fluxo que a tarefa de transmissão em fluxo utiliza.
properties.validStreamingUnits	integer[]		Especifica as unidades de transmissão em fluxo válidas para as quais uma tarefa de transmissão em fluxo pode ser dimensionada.
type	string		Tipo de recurso