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 do URI

Name	Em	Necessá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 do Pedido

Name	Necessário	Tipo	Description
If-Match		string	O ETag do trabalho de streaming. Omita esse valor para sempre substituir o conjunto de registros atual. Especifique o valor ETag visto pela última vez para evitar a substituição acidental de alterações simultâneas.
If-None-Match		string	Defina como '*' para permitir 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 na pré-condição 412.

Corpo do Pedido

Name	Tipo	Description
identity	Identity	Descreve a identidade gerenciada atribuída ao sistema atribuída a esse trabalho que pode ser usada para autenticar com entradas e saídas.
location	string	A geolocalização onde o recurso vive
properties.cluster	ClusterInfo	O cluster no qual os trabalhos de streaming serão executados.
properties.compatibilityLevel	CompatibilityLevel	Controla determinados comportamentos de tempo de execução 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. Valor deve ser o nome de uma cultura .NET suportada do conjunto https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. O padrão é 'en-US' se nenhum for especificado.
properties.eventsLateArrivalMaxDelayInSeconds	integer (int32)	O atraso máximo tolerável em segundos em que os eventos que chegam atrasados podem ser incluídos. O intervalo suportado é -1 para 1814399 (20.23:59:59 dias) e -1 é usado para especificar esperar indefinidamente. Se a propriedade estiver ausente, ela é interpretada como tendo um valor de -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer (int32)	O atraso máximo tolerável em segundos em que os eventos fora de ordem podem ser ajustados para voltarem à 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 name para cada função é necessária ao especificar essa propriedade em uma solicitação PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Você deve usar a API PATCH disponível para a transformação individual.
properties.inputs	Input[]	Uma lista de uma ou mais entradas para o trabalho de streaming. A propriedade name para cada entrada é necessária ao especificar essa propriedade em uma solicitação PUT. Esta propriedade não pode ser modificada através 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 de 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 a estarem malformados (valores de coluna ausentes, valores de coluna de tipo ou tamanho errados).
properties.outputStartMode	OutputStartMode	Esta propriedade só deve ser utilizada quando se deseja 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 começar sempre que o trabalho for iniciado, começar em um carimbo de data/hora de usuário personalizado especificado por meio da propriedade outputStartTime ou começar a partir da hora de saída do último evento.
properties.outputStartTime	string (date-time)	Valor é um carimbo de data/hora formatado ISO-8601 que indica o ponto inicial do fluxo de eventos de saída ou null para indicar que o fluxo de eventos de saída será iniciado sempre que o trabalho de streaming for iniciado. Essa propriedade deve ter um valor se outputStartMode estiver definido como CustomTime.
properties.outputs	Output[]	Uma lista de uma ou mais saídas para o trabalho de streaming. A propriedade name para cada saída é necessária ao especificar essa propriedade em uma solicitação PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Você deve usar a API PATCH disponível para a saída individual.
properties.sku	Sku	Descreve a SKU do trabalho de streaming. Necessário em solicitações PUT (CreateOrReplace).
properties.transformation	Transformation	Indica a consulta e o número de unidades de streaming a serem usadas para o trabalho de streaming. A propriedade name da transformação é necessária ao especificar essa propriedade em uma solicitação PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Você deve usar a API PATCH disponível para a transformação individual.
tags	object	Tags de recursos.

Respostas

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

Name

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

Azure Ative Directory OAuth2 Flow

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

Âmbitos

Name	Description
user_impersonation	personificar a sua conta de utilizador

Exemplos

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

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

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

Pedido de amostra

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

Código de estado:: 201

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

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

Código de estado:: 200

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

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

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

Pedido de amostra

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

Código de estado:: 201

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

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

Código de estado:: 200

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

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

Definições

Name	Description
AggregateFunctionProperties	As propriedades associadas a uma função agregada.
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 Repositório Azure Data Lake.
AzureFunctionOutputDataSource	Define os metadados de AzureFunctionOutputDataSource
AzureMachineLearningWebServiceFunctionBinding	A associação a um serviço Web do Azure Machine Learning.
AzureMachineLearningWebServiceInputColumn	Descreve uma coluna de entrada para o ponto de extremidade do serviço Web do Azure Machine Learning.
AzureMachineLearningWebServiceInputs	As entradas para o ponto de extremidade do serviço Web do Azure Machine Learning.
AzureMachineLearningWebServiceOutputColumn	Descreve uma coluna de saída para o ponto de extremidade do serviço Web do Azure Machine Learning.
AzureSqlDatabaseOutputDataSource	Descreve uma fonte de dados de saída 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 tempo de execução do trabalho de streaming.
Compression	Descreve como os dados de entrada são compactados
CompressionType	Indica o tipo de compactação que a entrada usa. Necessário em solicitações PUT (CreateOrReplace).
ContentStoragePolicy	Os valores válidos são JobStorageAccount e SystemAccount. Se definido como JobStorageAccount, isso 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 mereça a atenção do cliente.
Diagnostics	Descreve as condições aplicáveis à entrada, saída ou ao trabalho em geral, que merecem atenção do cliente.
DocumentDbOutputDataSource	Descreve uma fonte de dados de saída do Banco de Dados de Documentos.
Encoding	Especifica a codificação dos dados de entrada no caso de entrada e a codificação de dados de saída no caso de saída.
Error	Representação de erro comum.
EventHubOutputDataSource	Descreve uma fonte de dados de saída do Hub de Eventos.
EventHubStreamInputDataSource	Descreve uma fonte de dados de entrada do Hub de Eventos que contém dados de fluxo.
EventHubV2OutputDataSource	Descreve uma fonte de dados de saída do Hub de Eventos.
EventHubV2StreamInputDataSource	Descreve uma fonte de dados de entrada do Hub de Eventos que contém dados de fluxo.
EventSerializationType	Indica o tipo de serialização que a entrada ou saída usa. Necessário em solicitações PUT (CreateOrReplace).
EventsOutOfOrderPolicy	Indica a política a ser aplicada 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, contendo todas as informações associadas à função nomeada. Todas as funções estão contidas em um trabalho de streaming.
FunctionInput	Descreve um parâmetro de entrada de uma função.
FunctionOutput	Descreve a saída de uma função.
GatewayMessageBusOutputDataSource	Descreve uma fonte de dados de saída do Barramento de Mensagens de Gateway.
GatewayMessageBusStreamInputDataSource	Descreve uma fonte de dados de entrada de blob que contém dados de fluxo.
Identity	Descreve como a identidade é verificada
Input	Um objeto de entrada, contendo todas as informações associadas à entrada nomeada. Todas as entradas estão contidas em um trabalho de streaming.
IoTHubStreamInputDataSource	Descreve uma fonte de dados de entrada do Hub IoT que contém dados de fluxo.
JavaScriptFunctionBinding	A ligação a uma função JavaScript.
JobStorageAccount	As propriedades associadas a uma conta de Armazenamento do Azure com MSI
JobType	Descreve o tipo de 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 suportados são 'lineSeparated' indicando que a saída será formatada por ter cada objeto JSON separado por uma nova linha e 'array' indicando que a saída será formatada como uma matriz de objetos JSON.
JsonSerialization	Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída no formato JSON.
Output	Um objeto de saída, contendo todas as informações associadas à saída nomeada. Todas as saídas estão contidas em um trabalho de streaming.
OutputErrorPolicy	Indica a política a ser aplicada a eventos que chegam à saída e não podem ser gravados no armazenamento externo devido a estarem malformados (valores de coluna ausentes, valores de coluna de tipo ou tamanho errados).
OutputStartMode	O valor pode ser JobStartTime, CustomTime ou LastOutputEventTime para indicar se o ponto inicial do fluxo de eventos de saída deve começar sempre que o trabalho for iniciado, começar em um carimbo de data/hora de usuário personalizado especificado por meio da propriedade outputStartTime ou começar a partir da hora de saída do último evento.
ParquetSerialization	Descreve como os dados de uma entrada são serializados ou como os dados são serializados quando gravados em uma saída no formato Parquet.
PowerBIOutputDataSource	Descreve uma fonte de dados de saída do Power BI.
ReferenceInputProperties	As propriedades associadas a uma entrada que contém dados de referência.
RefreshType	Indica o tipo de opção de atualização de dados.
ScalarFunctionProperties	As propriedades associadas a uma função escalar.
ServiceBusQueueOutputDataSource	Descreve uma fonte de dados de saída da fila do Service Bus.
ServiceBusTopicOutputDataSource	Descreve uma fonte de dados de saída do Tópico do Service Bus.
Sku	As propriedades associadas a uma SKU.
SkuName	O nome do SKU. Necessário em solicitações PUT (CreateOrReplace).
StorageAccount	As propriedades associadas a uma conta de Armazenamento do Azure
StreamingJob	Um objeto de trabalho de streaming, contendo todas as informações associadas ao trabalho de streaming nomeado.
StreamInputProperties	As propriedades associadas a uma entrada que contém dados de fluxo.
Transformation	Um objeto de transformação, contendo todas as informações associadas à transformação nomeada. Todas as transformações estão contidas em um trabalho de streaming.

AggregateFunctionProperties

Object

As propriedades associadas a uma função agregada.

Name	Tipo	Description
etag	string	A marca de entidade atual para a função. Esta é uma cadeia de caracteres opaca. Você pode usá-lo para detetar 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 ligaçã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

Object

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.

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

AzureDataLakeStoreOutputDataSource

Object

Descreve uma fonte de dados de saída do Repositório Azure Data Lake.

Name	Tipo	Default value	Description
properties.accountName	string		O nome da conta do Repositório Azure Data Lake. Necessário em solicitações PUT (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticação.
properties.dateFormat	string		O formato de 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. Necessário em solicitações PUT (CreateOrReplace).
properties.refreshToken	string		Um token de atualização que pode ser usado para obter um token de acesso válido que pode ser usado para autenticar com a fonte de dados. Atualmente, 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ícia aqui ao criar a fonte de dados e, em seguida, ir para o Portal do Azure para autenticar a fonte de dados que atualizará essa propriedade com um token de atualização válido. Necessário em solicitações PUT (CreateOrReplace).
properties.tenantId	string		A ID do locatário do usuário usada para obter o token de atualização. Necessário em solicitações PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. 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 nome principal do usuário (UPN) 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 o tipo de saída da fonte de dados na qual a saída será gravada. Necessário em solicitações PUT (CreateOrReplace).

AzureFunctionOutputDataSource

Object

Define os metadados de AzureFunctionOutputDataSource

Name	Tipo	Description
properties.apiKey	string	Se você quiser usar uma Função do Azure de outra assinatura, poderá fazê-lo fornecendo a chave para acessar sua função.
properties.functionAppName	string	O nome do seu aplicativo Azure Functions.
properties.functionName	string	O nome da função em seu aplicativo Azure Functions.
properties.maxBatchCount	number	Uma propriedade que permite especificar o número máximo de eventos em cada lote enviado para o 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 é 262.144 bytes (256 KB).
type	string: Microsoft.AzureFunction	Indica o tipo de saída da fonte de dados na qual a saída será gravada. Necessário em solicitações PUT (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

Object

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

Name	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 descrevendo 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 ponto de extremidade de execução Request-Response 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 Azure Machine Learning.
type	string: Microsoft.MachineLearning/WebService	Indica o tipo de ligação de função.

AzureMachineLearningWebServiceInputColumn

Object

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

Name	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 esta entrada é mapeada.
name	string	O nome da coluna de entrada.

AzureMachineLearningWebServiceInputs

Object

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

Name	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. Este é o nome fornecido durante a criação do ponto de extremidade.

AzureMachineLearningWebServiceOutputColumn

Object

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

Name	Tipo	Description
dataType	string	O tipo de dados (Azure Machine Learning suportado) 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

Object

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

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

AzureSqlReferenceInputDataSource

Object

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

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

AzureSynapseOutputDataSource

Object

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

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

AzureTableOutputDataSource

Object

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

Name	Tipo	Description
properties.accountKey	string	A chave de conta para a conta de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.accountName	string	O nome da conta de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.batchSize	integer (int32)	O número de linhas para gravar 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	Este elemento indica o nome de uma coluna da instrução SELECT na consulta que será usada como a chave de partição para a Tabela do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.rowKey	string	Este elemento indica o nome de uma coluna da instrução SELECT na consulta que será usada como a chave de linha para a Tabela do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.table	string	O nome da Tabela do Azure. Necessário em solicitações PUT (CreateOrReplace).
type	string: Microsoft.Storage/Table	Indica o tipo de saída da fonte de dados na qual a saída será gravada. Necessário em solicitações PUT (CreateOrReplace).

BlobOutputDataSource

Object

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

Name	Tipo	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticação.
properties.blobPathPrefix	string		Prefixo do caminho de Blob.
properties.container	string		O nome de um contêiner dentro da conta de armazenamento associada. Este recipiente contém o(s) blob(s) a serem lidos ou gravados. Necessário em solicitações PUT (CreateOrReplace).
properties.dateFormat	string		O formato de data. Sempre que {date} aparece em pathPattern, o valor dessa propriedade é usado como o formato de data.
properties.pathPattern	string		O padrão de caminho de blob. Não é uma expressão regular. Ele representa um padrão com o qual os nomes de blob serão combinados 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 mais detalhada e um exemplo.
properties.storageAccounts	StorageAccount[]		Uma lista de uma ou mais contas de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Sempre que {time} aparece em pathPattern, o valor dessa propriedade é usado como o formato de hora.
type	string: Microsoft.Storage/Blob		Indica o tipo de saída da fonte de dados na qual a saída será gravada. Necessário em solicitações PUT (CreateOrReplace).

BlobReferenceInputDataSource

Object

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

Name	Tipo	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticação.
properties.container	string		O nome de um contêiner dentro da conta de armazenamento associada. Este recipiente contém o(s) blob(s) a serem lidos ou gravados. Necessário em solicitações PUT (CreateOrReplace).
properties.dateFormat	string		O formato de data. Sempre que {date} aparece em pathPattern, o valor dessa propriedade é usado como o formato de data.
properties.pathPattern	string		O padrão de caminho de blob. Não é uma expressão regular. Ele representa um padrão com o qual os nomes de blob serão combinados 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 mais detalhada e um exemplo.
properties.storageAccounts	StorageAccount[]		Uma lista de uma ou mais contas de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Sempre que {time} aparece em pathPattern, o valor dessa propriedade é usado como o formato de hora.
type	string: Microsoft.Storage/Blob		Indica o tipo de fonte de dados de entrada que contém dados de referência. Necessário em solicitações PUT (CreateOrReplace).

BlobStreamInputDataSource

Object

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

Name	Tipo	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticação.
properties.container	string		O nome de um contêiner dentro da conta de armazenamento associada. Este recipiente contém o(s) blob(s) a serem lidos ou gravados. Necessário em solicitações PUT (CreateOrReplace).
properties.dateFormat	string		O formato de data. Sempre que {date} aparece em pathPattern, o valor dessa propriedade é usado como o formato de data.
properties.pathPattern	string		O padrão de caminho de blob. Não é uma expressão regular. Ele representa um padrão com o qual os nomes de blob serão combinados 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 mais detalhada e um exemplo.
properties.sourcePartitionCount	integer (int32)		A contagem de partições da fonte de dados de entrada de blob. Gama 1 - 1024.
properties.storageAccounts	StorageAccount[]		Uma lista de uma ou mais contas de Armazenamento do Azure. Necessário em solicitações PUT (CreateOrReplace).
properties.timeFormat	string		O formato de hora. Sempre que {time} aparece em pathPattern, o valor dessa propriedade é usado como o formato de hora.
type	string: Microsoft.Storage/Blob		Indica o tipo de fonte de dados de entrada que contém dados de fluxo. Necessário em solicitações PUT (CreateOrReplace).

ClusterInfo

Object

As propriedades associadas a um cluster do Stream Analytics.

Name	Tipo	Description
id	string	A id do recurso do cluster.

CompatibilityLevel

Enumeração

Controla determinados comportamentos de tempo de execução do trabalho de streaming.

Valor	Description
1.0
1.2

Compression

Object

Descreve como os dados de entrada são compactados

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

CompressionType

Enumeração

Indica o tipo de compactação que a entrada usa. Necessá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

Object

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.

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

DiagnosticCondition

Object

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

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

Diagnostics

Object

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

Name	Tipo	Description
conditions	DiagnosticCondition[]	Um conjunto de zero ou mais condições aplicáveis ao recurso, ou ao trabalho em geral, que mereçam a atenção do cliente.

DocumentDbOutputDataSource

Object

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

Name	Tipo	Description
properties.accountId	string	O nome ou ID da conta do Banco de Dados de Documentos. Necessário em solicitações PUT (CreateOrReplace).
properties.accountKey	string	A chave de conta para a conta do Banco de Dados de Documentos. Necessário em solicitações PUT (CreateOrReplace).
properties.collectionNamePattern	string	O padrão de nome de coleção para as coleções a serem usadas. O formato do nome da coleção pode ser construído usando o token opcional {partition}, onde as partições começam a partir de 0. Consulte a seção Banco de Dados de Documentos do https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output para obter mais informações. Necessário em solicitações PUT (CreateOrReplace).
properties.database	string	O nome do banco de dados do Banco de Dados de Documentos. Necessá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 usado 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 o tipo de saída da fonte de dados na qual a saída será gravada. Necessá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

Object

Representação de erro comum.

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

EventHubOutputDataSource

Object

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

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

EventHubStreamInputDataSource

Object

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

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

EventHubV2OutputDataSource

Object

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

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

EventHubV2StreamInputDataSource

Object

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

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

EventSerializationType

Enumeração

Indica o tipo de serialização que a entrada ou saída usa. Necessá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

Object

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

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

Function

Object

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

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

FunctionInput

Object

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

Name	Tipo	Description
dataType	string	O tipo de dados (com suporte do 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 se espera que este parâmetro de entrada seja uma constante. O padrão é false.

FunctionOutput

Object

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

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

GatewayMessageBusOutputDataSource

Object

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

Name	Tipo	Description
properties.topic	string	O nome do tópico do Service Bus.
type	string: GatewayMessageBus	Indica o tipo de saída da fonte de dados na qual a saída será gravada. Necessário em solicitações PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Object

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

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

Identity

Object

Descreve como a identidade é verificada

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

Input

Object

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

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

IoTHubStreamInputDataSource

Object

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

Name	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 especificada, 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/operaçõesMonitoringEvents, etc.).
properties.iotHubNamespace	string	O nome ou o URI do Hub IoT. Necessário em solicitações PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	A chave de política de acesso compartilhado para a política de acesso compartilhado especificada. Necessário em solicitações PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	O nome da política de acesso compartilhado para o Hub IoT. Esta política deve conter pelo menos a permissão de conexão de serviço. Necessário em solicitações PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Indica o tipo de fonte de dados de entrada que contém dados de fluxo. Necessário em solicitações PUT (CreateOrReplace).

JavaScriptFunctionBinding

Object

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

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

JobStorageAccount

Object

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

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

JobType

Enumeração

Descreve o tipo de 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 suportados são 'lineSeparated' indicando que a saída será formatada por ter cada objeto JSON separado por uma nova linha e 'array' indicando que a saída será formatada como uma matriz de objetos JSON.

Valor	Description
LineSeparated
Array

JsonSerialization

Object

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.

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

Output

Object

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

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

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 começar sempre que o trabalho for iniciado, começar em um carimbo de data/hora de usuário personalizado especificado por meio da propriedade outputStartTime ou começar a partir da hora de saída do último evento.

Valor	Description
JobStartTime
CustomTime
LastOutputEventTime

ParquetSerialization

Object

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.

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

PowerBIOutputDataSource

Object

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

Name	Tipo	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticação.
properties.dataset	string		O nome do conjunto de dados do Power BI. Necessário em 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ífico do Power BI foi usado.
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. Atualmente, 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ícia aqui ao criar a fonte de dados e, em seguida, ir para o Portal do Azure para autenticar a fonte de dados que atualizará essa propriedade com um token de atualização válido. Necessário em solicitações PUT (CreateOrReplace).
properties.table	string		O nome da tabela do Power BI no conjunto de dados especificado. Necessário em solicitações PUT (CreateOrReplace).
properties.tokenUserDisplayName	string		O nome de exibição do usuário que foi usado para obter o token de atualização. Use essa propriedade para ajudar a lembrar qual usuário foi usado para obter o token de atualização.
properties.tokenUserPrincipalName	string		O nome principal do usuário (UPN) 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 o tipo de saída da fonte de dados na qual a saída será gravada. Necessário em solicitações PUT (CreateOrReplace).

ReferenceInputProperties

Object

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

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

Object

As propriedades associadas a uma função escalar.

Name	Tipo	Description
etag	string	A marca de entidade atual para a função. Esta é uma cadeia de caracteres opaca. Você pode usá-lo para detetar 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 ligaçã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

Object

Descreve uma fonte de dados de saída da fila do Service Bus.

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

ServiceBusTopicOutputDataSource

Object

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

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

Sku

Object

As propriedades associadas a uma SKU.

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

SkuName

Enumeração

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

Valor	Description
Standard

StorageAccount

Object

As propriedades associadas a uma conta de Armazenamento do Azure

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

StreamingJob

Object

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

Name	Tipo	Description
id	string	ID do recurso totalmente qualificado para o recurso. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Descreve a identidade gerenciada atribuída ao sistema atribuída a esse trabalho que pode ser usada para autenticar com entradas e saídas.
location	string	A geolocalização onde o recurso vive
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 tempo de execução 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)	Valor é um carimbo de data/hora UTC formatado ISO-8601 que indica quando o trabalho de streaming foi criado.
properties.dataLocale	string	A localidade de dados do trabalho de análise de fluxo. Valor deve ser o nome de uma cultura .NET suportada do conjunto https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. O padrão é 'en-US' se nenhum for especificado.
properties.etag	string	A tag de entidade atual para o trabalho de streaming. Esta é uma cadeia de caracteres opaca. Você pode usá-lo para detetar 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 máximo tolerável em segundos em que os eventos que chegam atrasados podem ser incluídos. O intervalo suportado é -1 para 1814399 (20.23:59:59 dias) e -1 é usado para especificar esperar indefinidamente. Se a propriedade estiver ausente, ela é interpretada como tendo um valor de -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer (int32)	O atraso máximo tolerável em segundos em que os eventos fora de ordem podem ser ajustados para voltarem à 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 name para cada função é necessária ao especificar essa propriedade em uma solicitação PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Você deve usar a API PATCH disponível para a transformação individual.
properties.inputs	Input[]	Uma lista de uma ou mais entradas para o trabalho de streaming. A propriedade name para cada entrada é necessária ao especificar essa propriedade em uma solicitação PUT. Esta propriedade não pode ser modificada através 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. Este 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 de trabalho. Os modos válidos são `Cloud` e 'Edge'.
properties.lastOutputEventTime	string (date-time)	Valor é um carimbo de data/hora formatado ISO-8601 indicando 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 a estarem malformados (valores de coluna ausentes, valores de coluna de tipo ou tamanho errados).
properties.outputStartMode	OutputStartMode	Esta propriedade só deve ser utilizada quando se deseja 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 começar sempre que o trabalho for iniciado, começar em um carimbo de data/hora de usuário personalizado especificado por meio da propriedade outputStartTime ou começar a partir da hora de saída do último evento.
properties.outputStartTime	string (date-time)	Valor é um carimbo de data/hora formatado ISO-8601 que indica o ponto inicial do fluxo de eventos de saída ou null para indicar que o fluxo de eventos de saída será iniciado sempre que o trabalho de streaming for iniciado. Essa propriedade deve ter um valor se outputStartMode estiver definido como CustomTime.
properties.outputs	Output[]	Uma lista de uma ou mais saídas para o trabalho de streaming. A propriedade name para cada saída é necessária ao especificar essa propriedade em uma solicitação PUT. Esta propriedade não pode ser modificada através 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. Necessário em solicitações PUT (CreateOrReplace).
properties.transformation	Transformation	Indica a consulta e o número de unidades de streaming a serem usadas para o trabalho de streaming. A propriedade name da transformação é necessária ao especificar essa propriedade em uma solicitação PUT. Esta propriedade não pode ser modificada através de uma operação PATCH. Você deve usar a API PATCH disponível para a transformação individual.
tags	object	Tags de recursos.
type	string	O tipo do recurso. Ex- Microsoft.Compute/virtualMachines ou Microsoft.Storage/storageAccounts.

StreamInputProperties

Object

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

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

Transformation

Object

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

Name	Tipo	Default value	Description
id	string		ID do recurso
name	string		Nome do recurso
properties.etag	string		A marca de entidade atual para a transformação. Esta é uma cadeia de caracteres opaca. Você pode usá-lo para detetar se o recurso foi alterado entre solicitações. Você também pode usá-lo nos cabeçalhos If-Match ou If-None-Match para operações de gravação para simultaneidade otimista.
properties.query	string		Especifica a consulta que será executada no trabalho de streaming. Você pode saber mais sobre a SAQL (Stream Analytics Query Language) aqui: https://msdn.microsoft.com/library/azure/dn834998 . Necessá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

Partilhar via

Streaming Jobs - Create Or Replace

Parâmetros do URI

Cabeçalho do Pedido

Corpo do Pedido

Respostas

Segurança

azure_auth

Âmbitos

Exemplos

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

Pedido de amostra

Resposta da amostra

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

Pedido de amostra

Resposta da amostra

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