Streaming Jobs - Create Or Replace

Serviço:: Stream Analytics

Versão da API:: 2020-03-01

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

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

Parâmetros de URI

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

Cabeçalho da solicitação

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

Corpo da solicitação

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

Respostas

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

Nome

Tipo

Description

200 OK

StreamingJob

O trabalho de streaming foi criado ou substituído com êxito.

Cabeçalhos

ETag: string

201 Created

StreamingJob

O trabalho de streaming foi criado ou substituído com êxito.

Cabeçalhos

ETag: string

Other Status Codes

Error

Erro.

Segurança

azure_auth

Fluxo OAuth2 do Azure Active Directory

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

Escopos

Nome	Description
user_impersonation	representar sua conta de usuário

Exemplos

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

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

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

Solicitação de exemplo

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

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


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

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

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

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

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

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

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

createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output().catch(
  console.error
);

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

Resposta de exemplo

Código de status:: 201

ETag: 87551cc5-1290-4d08-afcd-cdaa92e5ade0

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804",
  "name": "sj7804",
  "type": "Microsoft.StreamAnalytics/streamingjobs",
  "location": "West US",
  "tags": {
    "key1": "value1",
    "randomKey": "randomValue",
    "key3": "value3"
  },
  "properties": {
    "sku": {
      "name": "Standard"
    },
    "jobId": "732e4b1d-94a7-43ae-8297-3ad04f1540b9",
    "provisioningState": "Succeeded",
    "jobState": "Created",
    "eventsOutOfOrderPolicy": "Drop",
    "outputErrorPolicy": "Drop",
    "eventsOutOfOrderMaxDelayInSeconds": 0,
    "eventsLateArrivalMaxDelayInSeconds": 5,
    "dataLocale": "en-US",
    "createdDate": "2017-05-11T04:37:11.54Z",
    "compatibilityLevel": "1.0",
    "inputs": [
      {
        "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/inputs/inputtest",
        "name": "inputtest",
        "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
        "properties": {
          "type": "Stream",
          "datasource": {
            "type": "Microsoft.Storage/Blob",
            "properties": {
              "storageAccounts": [
                {
                  "accountName": "accountName"
                }
              ],
              "container": "containerName",
              "pathPattern": ""
            }
          },
          "serialization": {
            "type": "Json",
            "properties": {
              "encoding": "UTF8"
            }
          },
          "etag": "ca88f8fa-605b-4c7f-8695-46f5faa60cd0"
        }
      }
    ],
    "transformation": {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/transformations/transformationtest",
      "name": "transformationtest",
      "type": "Microsoft.StreamAnalytics/streamingjobs/transformations",
      "properties": {
        "streamingUnits": 1,
        "query": "Select Id, Name from inputtest",
        "etag": "91d8fcbe-60b3-49c3-9f21-9942b95602b8"
      }
    },
    "functions": [],
    "outputs": [
      {
        "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/outputs/outputtest",
        "name": "outputtest",
        "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
        "properties": {
          "datasource": {
            "type": "Microsoft.Sql/Server/Database",
            "properties": {
              "server": "serverName",
              "database": "databaseName",
              "table": "tableName",
              "user": "userName"
            }
          },
          "etag": "62097c3c-b503-41ff-a56f-196a9598ab90"
        }
      }
    ]
  }
}

Código de status:: 200

ETag: 87551cc5-1290-4d08-afcd-cdaa92e5ade0

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804",
  "name": "sj7804",
  "type": "Microsoft.StreamAnalytics/streamingjobs",
  "location": "West US",
  "tags": {
    "key1": "value1",
    "randomKey": "randomValue",
    "key3": "value3"
  },
  "properties": {
    "sku": {
      "name": "Standard"
    },
    "jobId": "732e4b1d-94a7-43ae-8297-3ad04f1540b9",
    "provisioningState": "Succeeded",
    "jobState": "Created",
    "eventsOutOfOrderPolicy": "Drop",
    "outputErrorPolicy": "Drop",
    "eventsOutOfOrderMaxDelayInSeconds": 0,
    "eventsLateArrivalMaxDelayInSeconds": 5,
    "dataLocale": "en-US",
    "createdDate": "2017-05-11T04:37:11.54Z",
    "compatibilityLevel": "1.0",
    "inputs": [
      {
        "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/inputs/inputtest",
        "name": "inputtest",
        "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
        "properties": {
          "type": "Stream",
          "datasource": {
            "type": "Microsoft.Storage/Blob",
            "properties": {
              "storageAccounts": [
                {
                  "accountName": "accountName"
                }
              ],
              "container": "containerName",
              "pathPattern": ""
            }
          },
          "serialization": {
            "type": "Json",
            "properties": {
              "encoding": "UTF8"
            }
          },
          "etag": "ca88f8fa-605b-4c7f-8695-46f5faa60cd0"
        }
      }
    ],
    "transformation": {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/transformations/transformationtest",
      "name": "transformationtest",
      "type": "Microsoft.StreamAnalytics/streamingjobs/transformations",
      "properties": {
        "streamingUnits": 1,
        "query": "Select Id, Name from inputtest",
        "etag": "91d8fcbe-60b3-49c3-9f21-9942b95602b8"
      }
    },
    "functions": [],
    "outputs": [
      {
        "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/outputs/outputtest",
        "name": "outputtest",
        "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
        "properties": {
          "datasource": {
            "type": "Microsoft.Sql/Server/Database",
            "properties": {
              "server": "serverName",
              "database": "databaseName",
              "table": "tableName",
              "user": "userName"
            }
          },
          "etag": "62097c3c-b503-41ff-a56f-196a9598ab90"
        }
      }
    ]
  }
}

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

Solicitação de exemplo

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

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


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

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

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

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

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

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

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

createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions().catch(
  console.error
);

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

Resposta de exemplo

Código de status:: 201

ETag: 3e6872bc-c9d0-45b6-91b6-da66f1773056

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6936/providers/Microsoft.StreamAnalytics/streamingjobs/sj59",
  "name": "sj59",
  "type": "Microsoft.StreamAnalytics/streamingjobs",
  "location": "West US",
  "tags": {
    "key1": "value1",
    "randomKey": "randomValue",
    "key3": "value3"
  },
  "properties": {
    "sku": {
      "name": "Standard"
    },
    "jobId": "d53ecc3c-fcb0-485d-9caf-25e20fcb2061",
    "provisioningState": "Succeeded",
    "jobState": "Created",
    "eventsOutOfOrderPolicy": "Drop",
    "outputErrorPolicy": "Drop",
    "eventsOutOfOrderMaxDelayInSeconds": 5,
    "eventsLateArrivalMaxDelayInSeconds": 16,
    "dataLocale": "en-US",
    "createdDate": "2017-05-11T04:37:04.697Z",
    "compatibilityLevel": "1.0",
    "inputs": [],
    "functions": [],
    "outputs": []
  }
}

Código de status:: 200

ETag: 3e6872bc-c9d0-45b6-91b6-da66f1773056

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6936/providers/Microsoft.StreamAnalytics/streamingjobs/sj59",
  "name": "sj59",
  "type": "Microsoft.StreamAnalytics/streamingjobs",
  "location": "West US",
  "tags": {
    "key1": "value1",
    "randomKey": "randomValue",
    "key3": "value3"
  },
  "properties": {
    "sku": {
      "name": "Standard"
    },
    "jobId": "d53ecc3c-fcb0-485d-9caf-25e20fcb2061",
    "provisioningState": "Succeeded",
    "jobState": "Created",
    "eventsOutOfOrderPolicy": "Drop",
    "outputErrorPolicy": "Drop",
    "eventsOutOfOrderMaxDelayInSeconds": 5,
    "eventsLateArrivalMaxDelayInSeconds": 16,
    "dataLocale": "en-US",
    "createdDate": "2017-05-11T04:37:04.697Z",
    "compatibilityLevel": "1.0",
    "inputs": [],
    "functions": [],
    "outputs": []
  }
}

Definições

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

AggregateFunctionProperties

Objeto

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

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

AuthenticationMode

Enumeração

Modo de autenticação. Os modos válidos são ConnectionString, Msi e 'UserToken'.

Valor	Description
Msi
UserToken
ConnectionString

AvroSerialization

Objeto

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

Nome	Tipo	Description
type	string: Avro	Indica o tipo de serialização usado pela entrada ou saída. Obrigatório em solicitações PUT (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Objeto

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

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

AzureFunctionOutputDataSource

Objeto

Define os metadados do AzureFunctionOutputDataSource

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

AzureMachineLearningWebServiceFunctionBinding

Objeto

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

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

AzureMachineLearningWebServiceInputColumn

Objeto

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

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

AzureMachineLearningWebServiceInputs

Objeto

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

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

AzureMachineLearningWebServiceOutputColumn

Objeto

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

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

AzureSqlDatabaseOutputDataSource

Objeto

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

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

AzureSqlReferenceInputDataSource

Objeto

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

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

AzureSynapseOutputDataSource

Objeto

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

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

AzureTableOutputDataSource

Objeto

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

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

BlobOutputDataSource

Objeto

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

Nome	Tipo	Valor padrão	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticação.
properties.blobPathPrefix	string		Prefixo de caminho de blob.
properties.container	string		O nome de um contêiner dentro da conta de Armazenamento associada. Esse contêiner contém os blob(s) a serem lidos ou gravados. Obrigatório em solicitações PUT (CreateOrReplace).
properties.dateFormat	string		O formato da data. Onde {date} aparecer em pathPattern, o valor dessa propriedade será usado como o formato de data.
properties.pathPattern	string		O padrão de caminho do blob. Não é uma expressão regular. Ele representa um padrão em relação ao qual os nomes de blob serão correspondidos para determinar se eles devem ou não ser incluídos como entrada ou saída para o trabalho. Consulte 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. Obrigatório em solicitações PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Onde {time} aparecer em pathPattern, o valor dessa propriedade será usado como o formato de hora.
type	string: Microsoft.Storage/Blob		Indica que o tipo de saída da fonte de dados será gravado. Obrigatório em solicitações PUT (CreateOrReplace).

BlobReferenceInputDataSource

Objeto

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

Nome	Tipo	Valor padrão	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticação.
properties.container	string		O nome de um contêiner dentro da conta de Armazenamento associada. Esse contêiner contém os blob(s) a serem lidos ou gravados. Obrigatório em solicitações PUT (CreateOrReplace).
properties.dateFormat	string		O formato da data. Onde {date} aparecer em pathPattern, o valor dessa propriedade será usado como o formato de data.
properties.pathPattern	string		O padrão de caminho do blob. Não é uma expressão regular. Ele representa um padrão em relação ao qual os nomes de blob serão correspondidos para determinar se eles devem ou não ser incluídos como entrada ou saída para o trabalho. Consulte 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. Obrigatório em solicitações PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Onde {time} aparecer em pathPattern, o valor dessa propriedade será usado como o formato de hora.
type	string: Microsoft.Storage/Blob		Indica o tipo de fonte de dados de entrada que contém dados de referência. Obrigatório em solicitações PUT (CreateOrReplace).

BlobStreamInputDataSource

Objeto

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

Nome	Tipo	Valor padrão	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticação.
properties.container	string		O nome de um contêiner dentro da conta de Armazenamento associada. Esse contêiner contém os blob(s) a serem lidos ou gravados. Obrigatório em solicitações PUT (CreateOrReplace).
properties.dateFormat	string		O formato da data. Onde {date} aparecer em pathPattern, o valor dessa propriedade será usado como o formato de data.
properties.pathPattern	string		O padrão de caminho do blob. Não é uma expressão regular. Ele representa um padrão em relação ao qual os nomes de blob serão correspondidos para determinar se eles devem ou não ser incluídos como entrada ou saída para o trabalho. Consulte 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 (int32)		A contagem de partições da fonte de dados de entrada de blob. Intervalo 1 a 1024.
properties.storageAccounts	StorageAccount[]		Uma lista de uma ou mais contas de Armazenamento do Azure. Obrigatório em solicitações PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Onde {time} aparecer em pathPattern, o valor dessa propriedade será usado como o formato de hora.
type	string: Microsoft.Storage/Blob		Indica o tipo de fonte de dados de entrada que contém dados de fluxo. Obrigatório em solicitações PUT (CreateOrReplace).

ClusterInfo

Objeto

As propriedades associadas a um cluster do Stream Analytics.

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

CompatibilityLevel

Enumeração

Controla determinados comportamentos de runtime do trabalho de streaming.

Valor	Description
1.0
1.2

Compression

Objeto

Descreve como os dados de entrada são compactados

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

CompressionType

Enumeração

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

Valor	Description
None
GZip
Deflate

ContentStoragePolicy

Enumeração

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

Valor	Description
SystemAccount
JobStorageAccount

CsvSerialization

Objeto

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

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

DiagnosticCondition

Objeto

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

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

Diagnostics

Objeto

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

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

DocumentDbOutputDataSource

Objeto

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

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

Encoding

Enumeração

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

Valor	Description
UTF8

Error

Objeto

Representação de erro comum.

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

EventHubOutputDataSource

Objeto

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

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

EventHubStreamInputDataSource

Objeto

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

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

EventHubV2OutputDataSource

Objeto

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

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

EventHubV2StreamInputDataSource

Objeto

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

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

EventSerializationType

Enumeração

Indica o tipo de serialização usado pela entrada ou saída. Obrigatório em solicitações PUT (CreateOrReplace).

Valor	Description
Csv
Avro
Json
Parquet

EventsOutOfOrderPolicy

Enumeração

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

Valor	Description
Adjust
Drop

FileReferenceInputDataSource

Objeto

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

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

Function

Objeto

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

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

FunctionInput

Objeto

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

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

FunctionOutput

Objeto

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

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

GatewayMessageBusOutputDataSource

Objeto

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

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

GatewayMessageBusStreamInputDataSource

Objeto

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

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

Identity

Objeto

Descreve como a identidade é verificada

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

Input

Objeto

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

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

IoTHubStreamInputDataSource

Objeto

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

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

JavaScriptFunctionBinding

Objeto

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

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

JobStorageAccount

Objeto

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

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

JobType

Enumeração

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

Valor	Description
Cloud
Edge

JsonOutputSerializationFormat

Enumeração

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

Valor	Description
LineSeparated
Array

JsonSerialization

Objeto

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

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

Output

Objeto

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

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

OutputErrorPolicy

Enumeração

Indica a política a ser aplicada a eventos que chegam à saída e não podem ser gravados no armazenamento externo devido à má formação (valores de coluna ausentes, valores de coluna de tipo ou tamanho incorretos).

Valor	Description
Stop
Drop

OutputStartMode

Enumeração

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

Valor	Description
JobStartTime
CustomTime
LastOutputEventTime

ParquetSerialization

Objeto

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

Nome	Tipo	Description
type	string: Parquet	Indica o tipo de serialização usado pela entrada ou saída. Obrigatório em solicitações PUT (CreateOrReplace).

PowerBIOutputDataSource

Objeto

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

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

ReferenceInputProperties

Objeto

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

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

RefreshType

Enumeração

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

Valor	Description
Static
RefreshPeriodicallyWithFull
RefreshPeriodicallyWithDelta

ScalarFunctionProperties

Objeto

As propriedades associadas a uma função escalar.

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

ServiceBusQueueOutputDataSource

Objeto

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

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

ServiceBusTopicOutputDataSource

Objeto

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

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

Sku

Objeto

As propriedades associadas a um SKU.

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

SkuName

Enumeração

O nome da SKU. Obrigatório em solicitações PUT (CreateOrReplace).

Valor	Description
Standard

StorageAccount

Objeto

As propriedades associadas a uma conta de Armazenamento do Azure

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

StreamingJob

Objeto

Um objeto de trabalho de streaming, que contém todas as informações associadas ao trabalho de streaming nomeado.

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

StreamInputProperties

Objeto

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

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

Transformation

Objeto

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

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

Compartilhar via

Streaming Jobs - Create Or Replace

Parâmetros de URI

Cabeçalho da solicitação

Corpo da solicitação

Respostas

Segurança

azure_auth

Escopos

Exemplos

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

Solicitação de exemplo

Resposta de exemplo

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

Solicitação de exemplo

Resposta de exemplo

Definições

AggregateFunctionProperties

AuthenticationMode

AvroSerialization

AzureDataLakeStoreOutputDataSource

AzureFunctionOutputDataSource

AzureMachineLearningWebServiceFunctionBinding

AzureMachineLearningWebServiceInputColumn

AzureMachineLearningWebServiceInputs

AzureMachineLearningWebServiceOutputColumn

AzureSqlDatabaseOutputDataSource

AzureSqlReferenceInputDataSource

AzureSynapseOutputDataSource

AzureTableOutputDataSource

BlobOutputDataSource

BlobReferenceInputDataSource

BlobStreamInputDataSource

ClusterInfo

CompatibilityLevel

Compression

CompressionType

ContentStoragePolicy

CsvSerialization

DiagnosticCondition

Diagnostics

DocumentDbOutputDataSource

Encoding

Error

EventHubOutputDataSource

EventHubStreamInputDataSource

EventHubV2OutputDataSource

EventHubV2StreamInputDataSource

EventSerializationType

EventsOutOfOrderPolicy

FileReferenceInputDataSource

Function

FunctionInput

FunctionOutput

GatewayMessageBusOutputDataSource

GatewayMessageBusStreamInputDataSource

Identity

Input

IoTHubStreamInputDataSource

JavaScriptFunctionBinding

JobStorageAccount

JobType

JsonOutputSerializationFormat

JsonSerialization

Output

OutputErrorPolicy

OutputStartMode

ParquetSerialization

PowerBIOutputDataSource

ReferenceInputProperties

RefreshType

ScalarFunctionProperties

ServiceBusQueueOutputDataSource

ServiceBusTopicOutputDataSource

Sku

SkuName

StorageAccount

StreamingJob

StreamInputProperties

Transformation