Streaming Jobs - Create Or Replace

Service:

Stream Analytics

API Version:

2020-03-01

Crea un trabajo de streaming o reemplaza un trabajo de streaming ya existente.

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

Parámetros de identificador URI

Nombre	En	Requerido	Tipo	Description
jobName	path	True	string	Nombre del trabajo de streaming.
resourceGroupName	path	True	string	Nombre del grupo de recursos. El nombre distingue mayúsculas de minúsculas. Regex pattern: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	Identificador de la suscripción de destino.
api-version	query	True	string	Versión de API que se usará para la operación.

Encabezado de la solicitud

Nombre	Requerido	Tipo	Description
If-Match		string	ETag del trabajo de streaming. Omita este valor para sobrescribir siempre el conjunto de registros actual. Especifique el último valor de ETag visto para evitar que se sobrescriba accidentalmente los cambios simultáneos.
If-None-Match		string	Establézcalo en "*" para permitir la creación de un nuevo trabajo de streaming, pero para evitar la actualización de un conjunto de registros existente. Otros valores darán como resultado una respuesta 412 Con error de condición previa.

Cuerpo de la solicitud

Nombre	Tipo	Description
identity	Identity	Describe la identidad administrada asignada por el sistema asignada a este trabajo que se puede usar para autenticarse con entradas y salidas.
location	string	Ubicación geográfica donde reside el recurso
properties.cluster	ClusterInfo	El clúster en el que se ejecutarán los trabajos de streaming.
properties.compatibilityLevel	CompatibilityLevel	Controla ciertos comportamientos del runtime del trabajo de streaming.
properties.contentStoragePolicy	ContentStoragePolicy	Los valores válidos son JobStorageAccount y SystemAccount. Si se establece en JobStorageAccount, esto requiere que el usuario también especifique la propiedad jobStorageAccount. .
properties.dataLocale	string	La configuración regional de los datos del trabajo de análisis del flujo de datos. El valor debe ser el nombre de una referencia cultural de .NET compatible del conjunto https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. El valor predeterminado es "en-US" si no se ha especificado ninguno.
properties.eventsLateArrivalMaxDelayInSeconds	integer	El retraso tolerable máximo, en segundos, que pueden tener los eventos que llegan tarde para ser incluidos. El rango admitido es -1 a 1814399 (20.23:59:59 días) y-1 se usa para especificar que la espera es indefinida. Si la propiedad no está presente, se interpreta que tiene el valor -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	El retraso máximo tolerable, en segundos, en que se pueden ajustar los eventos que no funcionan para que vuelvan a estar en orden.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Indica la directiva que aplicar a los eventos que llegan desordenados en el flujo de eventos de entrada.
properties.functions	Function[]	Lista de una o varias funciones para el trabajo de streaming. La propiedad name de cada función es necesaria al especificar esta propiedad en una solicitud PUT. Esta propiedad no se puede modificar a través de una operación PATCH. Debe usar patch API disponible para la transformación individual.
properties.inputs	Input[]	Una lista de una o varias entradas para el trabajo de streaming. La propiedad name de cada entrada es necesaria al especificar esta propiedad en una solicitud PUT. Esta propiedad no se puede modificar a través de una operación PATCH. Debe usar la API PATCH disponible para la entrada individual.
properties.jobStorageAccount	JobStorageAccount	Propiedades asociadas a una cuenta de Azure Storage con MSI
properties.jobType	JobType	Describe el tipo del trabajo. Los modos válidos son Cloud y "Edge".
properties.outputErrorPolicy	OutputErrorPolicy	Indica la directiva que se aplica a los eventos que llegan a la salida y no se pueden escribir en el almacenamiento externo porque están mal formados (faltan valores de las columnas o el tamaño o tipo de los valores de las columnas no son correctos).
properties.outputStartMode	OutputStartMode	Esta propiedad solo se debe utilizar cuando se desea que el trabajo se inicie inmediatamente después de la creación. El valor puede ser JobStartTime, CustomTime o LastOutputEventTime para indicar si el punto inicial del flujo de eventos de salida debe iniciarse cada vez que se inicia el trabajo, comenzar en una marca de tiempo de usuario personalizada especificada mediante la propiedad outputStartTime o comenzar desde la hora de salida del último evento.
properties.outputStartTime	string	El valor es una marca de tiempo con formato ISO-8601 que indica el punto inicial de la secuencia de eventos de salida o NULL para indicar que la secuencia de eventos de salida empezará cuando se inicie el trabajo de transmisión. Esta propiedad debe tener un valor si outputStartMode está establecido en CustomTime.
properties.outputs	Output[]	Lista de una o varias salidas para el trabajo de streaming. La propiedad name de cada salida es necesaria al especificar esta propiedad en una solicitud PUT. Esta propiedad no se puede modificar a través de una operación PATCH. Debe usar la API PATCH disponible para la salida individual.
properties.sku	Sku	Describe la SKU del trabajo de streaming. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.transformation	Transformation	Indica la consulta y el número de unidades de streaming que se van a usar para el trabajo de streaming. La propiedad name de la transformación es necesaria al especificar esta propiedad en una solicitud PUT. Esta propiedad no se puede modificar a través de una operación PATCH. Debe usar patch API disponible para la transformación individual.
tags	object	Etiquetas del recurso.

Respuestas

Nombre	Tipo	Description
200 OK	StreamingJob	El trabajo de streaming se ha creado o reemplazado correctamente. Headers ETag: string
201 Created	StreamingJob	El trabajo de streaming se ha creado o reemplazado correctamente. Headers ETag: string
Other Status Codes	Error	Error.

Seguridad

azure_auth

Flujo OAuth2 de Azure Active Directory

Type: oauth2
Flow: implicit
Authorization URL: https://login.microsoftonline.com/common/oauth2/authorize

Scopes

Nombre	Description
user_impersonation	suplantación de su cuenta de usuario

Ejemplos

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)

Sample Request

HTTP

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

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

Java

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

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

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

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

JavaScript

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

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

createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output().catch(
  console.error
);

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

Sample Response

Status code:

201

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

Response Body

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

Status code:

200

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

Response Body

{
  "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)

Sample Request

HTTP

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

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

Java

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

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

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

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

JavaScript

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

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

createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions().catch(
  console.error
);

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

Sample Response

Status code:

201

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

Response Body

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

Status code:

200

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

Response Body

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

Definiciones

Nombre	Description
AggregateFunctionProperties	Propiedades asociadas a una función de agregado.
AuthenticationMode	Modo de autenticación. Los modos válidos son ConnectionString, Msi y "UserToken".
AvroSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato Avro.
AzureDataLakeStoreOutputDataSource	Describe un origen de datos de salida de Azure Data Lake Store.
AzureFunctionOutputDataSource	Define los metadatos de AzureFunctionOutputDataSource
AzureMachineLearningWebServiceFunctionBinding	El enlace a un servicio web de Azure Machine Learning.
AzureMachineLearningWebServiceInputColumn	Describe una columna de entrada para el punto de conexión del servicio web de Azure Machine Learning.
AzureMachineLearningWebServiceInputs	Las entradas para el punto de conexión del servicio web de Azure Machine Learning.
AzureMachineLearningWebServiceOutputColumn	Describe una columna de salida para el punto de conexión de servicio web de Azure Machine Learning.
AzureSqlDatabaseOutputDataSource	Describe un origen de datos de salida de base de datos Azure SQL.
AzureSqlReferenceInputDataSource	Describe un Azure SQL origen de datos de entrada de referencia de base de datos.
AzureSynapseOutputDataSource	Describe un Azure Synapse origen de datos de salida.
AzureTableOutputDataSource	Describe un origen de datos de salida de tabla de Azure.
BlobOutputDataSource	Describe un origen de datos de salida de blobs.
BlobReferenceInputDataSource	Describe un origen de datos de entrada de blobs que contiene datos de referencia.
BlobStreamInputDataSource	Describe un origen de datos de entrada de blobs que contiene datos de flujo.
ClusterInfo	Propiedades asociadas a un clúster de Stream Analytics.
CompatibilityLevel	Controla ciertos comportamientos del runtime del trabajo de streaming.
Compression	Describe cómo se comprimen los datos de entrada.
CompressionType	Indica el tipo de compresión que usa la entrada. Se requiere en las solicitudes PUT (CreateOrReplace).
ContentStoragePolicy	Los valores válidos son JobStorageAccount y SystemAccount. Si se establece en JobStorageAccount, esto requiere que el usuario especifique también la propiedad jobStorageAccount. .
CsvSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato CSV.
DiagnosticCondition	Condición aplicable al recurso, o al trabajo en general, que garantiza la atención al cliente.
Diagnostics	Describe las condiciones aplicables a la entrada, la salida o el trabajo en general, que garantizan la atención al cliente.
DocumentDbOutputDataSource	Describe un origen de datos de salida de DocumentDB.
Encoding	Especifica la codificación de los datos entrantes en el caso de la entrada y la codificación de los datos salientes en el caso de la salida.
Error	Representación de error común.
EventHubOutputDataSource	Describe un origen de datos de salida del centro de eventos.
EventHubStreamInputDataSource	Describe un origen de datos de entrada del centro de eventos que contiene datos de flujo.
EventHubV2OutputDataSource	Describe un origen de datos de salida del centro de eventos.
EventHubV2StreamInputDataSource	Describe un origen de datos de entrada del centro de eventos que contiene datos de flujo.
EventSerializationType	Indica el tipo de serialización que usa la entrada o salida. Se requiere en las solicitudes PUT (CreateOrReplace).
EventsOutOfOrderPolicy	Indica la directiva que aplicar a los eventos que llegan desordenados en el flujo de eventos de entrada.
FileReferenceInputDataSource	Describe un origen de datos de entrada de archivo que contiene datos de referencia.
Function	Objeto de función que contiene toda la información asociada a la función con nombre. Todas las funciones están contenidas en un trabajo de streaming.
FunctionInput	Describe un parámetro de entrada de una función.
FunctionOutput	Describe la salida de una función.
GatewayMessageBusOutputDataSource	Describe un origen de datos de salida de Gateway Message Bus.
GatewayMessageBusStreamInputDataSource	Describe un origen de datos de entrada de blobs que contiene datos de flujo.
Identity	Describe cómo se comprueba la identidad.
Input	Objeto de entrada que contiene toda la información asociada a la entrada con nombre. Todas las entradas están contenidas en un trabajo de streaming.
IoTHubStreamInputDataSource	Describe un origen de datos de entrada IoT Hub que contiene datos de flujo.
JavaScriptFunctionBinding	Enlace a una función de JavaScript.
JobStorageAccount	Propiedades asociadas a una cuenta de Azure Storage con MSI
JobType	Describe el tipo del trabajo. Los modos válidos son Cloud y "Edge".
JsonOutputSerializationFormat	Especifica el formato del JSON en el que se escribirá la salida. Los valores admitidos actualmente son "lineSeparated" que indican que la salida tendrá el formato de cada objeto JSON separado por una nueva línea y "matriz" que indica que la salida se formateará como una matriz de objetos JSON.
JsonSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato JSON.
Output	Objeto de salida que contiene toda la información asociada a la salida con nombre. Todas las salidas están contenidas en un trabajo de streaming.
OutputErrorPolicy	Indica la directiva que se aplica a los eventos que llegan a la salida y no se pueden escribir en el almacenamiento externo porque están mal formados (faltan valores de las columnas o el tamaño o tipo de los valores de las columnas no son correctos).
OutputStartMode	El valor puede ser JobStartTime, CustomTime o LastOutputEventTime para indicar si el punto inicial del flujo de eventos de salida debe iniciarse cada vez que se inicia el trabajo, empezar en una marca de tiempo de usuario personalizada especificada a través de la propiedad outputStartTime o comenzar desde la última hora de salida del evento.
ParquetSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato Parquet.
PowerBIOutputDataSource	Describe un origen de datos de salida de Power BI.
ReferenceInputProperties	Propiedades asociadas a una entrada que contiene datos de referencia.
RefreshType	Indica el tipo de opción de actualización de datos.
ScalarFunctionProperties	Propiedades asociadas a una función escalar.
ServiceBusQueueOutputDataSource	Describe un origen de datos de salida de cola de Service Bus.
ServiceBusTopicOutputDataSource	Describe un origen de datos de salida del tema de Service Bus.
Sku	Propiedades asociadas a una SKU.
SkuName	El nombre de la SKU. Se requiere en las solicitudes PUT (CreateOrReplace).
StorageAccount	Propiedades asociadas a una cuenta de Azure Storage
StreamingJob	Objeto de trabajo de streaming que contiene toda la información asociada al trabajo de streaming con nombre.
StreamInputProperties	Propiedades asociadas a una entrada que contiene datos de flujo.
Transformation	Objeto de transformación que contiene toda la información asociada a la transformación con nombre. Todas las transformaciones están contenidas en un trabajo de streaming.

AggregateFunctionProperties

Propiedades asociadas a una función de agregado.

Nombre	Tipo	Description
etag	string	Etiqueta de entidad actual para la función. Se trata de una cadena opaca. Puede usarlo para detectar si el recurso ha cambiado entre solicitudes. También puede usarlo en los encabezados If-Match o If-None-Match para operaciones de escritura para la simultaneidad optimista.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Enlace físico de la función. Por ejemplo, en el caso del servicio web Azure Machine Learning, se describe el punto de conexión.
properties.inputs	FunctionInput[]	Describe un parámetro de entrada de una función.
properties.output	FunctionOutput	Describe la salida de una función.
type	string: Aggregate	Indica el tipo de función.

AuthenticationMode

Modo de autenticación. Los modos válidos son ConnectionString, Msi y "UserToken".

Nombre	Tipo	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato Avro.

Nombre	Tipo	Description
type	string: Avro	Indica el tipo de serialización que usa la entrada o salida. Obligatorio en las solicitudes PUT (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Describe un origen de datos de salida de Azure Data Lake Store.

Nombre	Tipo	Valor predeterminado	Description
properties.accountName	string		Nombre de la cuenta de Azure Data Lake Store. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.dateFormat	string		El formato de la fecha. Siempre que {date} aparezca en filePathPrefix, el valor de esta propiedad se usa como formato de fecha en su lugar.
properties.filePathPrefix	string		Ubicación del archivo en el que se debe escribir la salida. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.refreshToken	string		Token de actualización que se puede usar para obtener un token de acceso válido que se puede usar para autenticarse con el origen de datos. Actualmente, solo se puede obtener un token de actualización válido a través de Azure Portal. Se recomienda colocar aquí un valor ficticio de cadena al crear el origen de datos y, a continuación, ir a Azure Portal para autenticar el origen de datos que actualizará esta propiedad con un token de actualización válido. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.tenantId	string		Identificador de inquilino del usuario usado para obtener el token de actualización. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.timeFormat	string		Formato de hora. Siempre que aparezca {time} en filePathPrefix, el valor de esta propiedad se usa como formato de hora en su lugar.
properties.tokenUserDisplayName	string		Nombre para mostrar del usuario que se usó para obtener el token de actualización. Use esta propiedad para ayudar a recordar qué usuario se usó para obtener el token de actualización.
properties.tokenUserPrincipalName	string		El nombre principal de usuario (UPN) del usuario que se usó para obtener el token de actualización. Use esta propiedad para ayudar a recordar qué usuario se usó para obtener el token de actualización.
type	string: Microsoft.DataLake/Accounts		Indica el tipo de salida del origen de datos en el que se escribirá. Obligatorio en las solicitudes PUT (CreateOrReplace).

AzureFunctionOutputDataSource

Define los metadatos de AzureFunctionOutputDataSource

Nombre	Tipo	Description
properties.apiKey	string	Si quiere usar una instancia de Azure Functions desde otra suscripción, debe proporcionar la clave para acceder a la función.
properties.functionAppName	string	Nombre de la aplicación de Azure Functions.
properties.functionName	string	Nombre de la función en la aplicación de Azure Functions.
properties.maxBatchCount	number	Propiedad que permite especificar el número máximo de eventos en cada lote que se envía a Azure Functions. El valor predeterminado es 100.
properties.maxBatchSize	number	Propiedad que permite establecer el tamaño máximo de cada lote de salida que se envía a la instancia de Azure Functions. La unidad de entrada se muestra en bytes. De manera predeterminada, este valor es 262 144 bytes (256 KB).
type	string: Microsoft.AzureFunction	Indica el tipo de salida del origen de datos en el que se escribirá. Obligatorio en las solicitudes PUT (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

El enlace a un servicio web de Azure Machine Learning.

Nombre	Tipo	Description
properties.apiKey	string	Clave de API que se usa para autenticarse con Request-Response punto de conexión.
properties.batchSize	integer	Número entre 1 y 10000 que describe el número máximo de filas para cada solicitud de ejecución rrS de Azure ML. El valor predeterminado es 1000.
properties.endpoint	string	El Request-Response ejecutar el punto de conexión del servicio web Azure Machine Learning. Obtenga más información aquí: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
properties.inputs	AzureMachineLearningWebServiceInputs	Las entradas para el punto de conexión del servicio web de Azure Machine Learning.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Una lista de salidas de la ejecución del punto de conexión del servicio web de Azure Machine Learning.
type	string: Microsoft.MachineLearning/WebService	Indica el tipo de enlace de función.

AzureMachineLearningWebServiceInputColumn

Describe una columna de entrada para el punto de conexión del servicio web de Azure Machine Learning.

Nombre	Tipo	Description
dataType	string	El tipo de datos (compatible con Azure Machine Learning) de la columna de entrada. https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx En .
mapTo	integer	Índice de base cero del parámetro de función al que se asigna esta entrada.
name	string	Nombre de la columna de entrada.

AzureMachineLearningWebServiceInputs

Las entradas para el punto de conexión del servicio web de Azure Machine Learning.

Nombre	Tipo	Description
columnNames	AzureMachineLearningWebServiceInputColumn[]	Una lista de columnas de entrada para el punto de conexión de servicio web de Azure Machine Learning.
name	string	Nombre de la entrada. Este es el nombre proporcionado al crear el punto de conexión.

AzureMachineLearningWebServiceOutputColumn

Describe una columna de salida para el punto de conexión de servicio web de Azure Machine Learning.

Nombre	Tipo	Description
dataType	string	Tipo de datos (compatible con Azure Machine Learning) de la columna de salida. https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx En .
name	string	Nombre de la columna de resultados.

AzureSqlDatabaseOutputDataSource

Describe un origen de datos de salida de base de datos Azure SQL.

Nombre	Tipo	Valor predeterminado	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.database	string		Nombre de la base de datos Azure SQL. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.maxBatchCount	number		Número máximo de lotes para escritura en Sql Database, el valor predeterminado es 10 000. Opcional en las solicitudes PUT.
properties.maxWriterCount	number		Recuento máximo de escritor, actualmente solo hay disponibles 1 (escritor único) y 0 (basado en la partición de consulta). Opcional en las solicitudes PUT.
properties.password	string		Contraseña que se usará para conectarse a la base de datos de Azure SQL. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.server	string		Nombre del servidor SQL server que contiene la base de datos de Azure SQL. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.table	string		Nombre de la tabla de la base de datos Azure SQL. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.user	string		Nombre de usuario que se usará para conectarse a la base de datos de Azure SQL. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/Database		Indica el tipo de salida del origen de datos en el que se escribirá. Obligatorio en las solicitudes PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Describe un Azure SQL origen de datos de entrada de referencia de base de datos.

Nombre	Tipo	Description
properties.database	string	Este elemento está asociado al elemento datasource. Este es el nombre de la base de datos en la que se escribirá la salida.
properties.deltaSnapshotQuery	string	Este elemento está asociado al elemento datasource. Esta consulta se usa para capturar los cambios incrementales de la base de datos SQL. Para usar esta opción, se recomienda usar tablas temporales en Azure SQL Database.
properties.fullSnapshotQuery	string	Este elemento está asociado al elemento datasource. Esta consulta se usa para capturar datos de la base de datos sql.
properties.password	string	Este elemento está asociado al elemento datasource. Esta es la contraseña que se utilizará para conectarse a la instancia de Base de datos SQL.
properties.refreshRate	string	Este elemento está asociado al elemento datasource. Esto indica la frecuencia con la que se capturarán los datos de la base de datos. Es del formato DateTime.
properties.refreshType	RefreshType	Indica el tipo de opción de actualización de datos.
properties.server	string	Este elemento está asociado al elemento datasource. Este es el nombre del servidor que contiene la base de datos en la que se escribirá.
properties.table	string	Este elemento está asociado al elemento datasource. Nombre de la tabla de la Azure SQL base de datos.
properties.user	string	Este elemento está asociado al elemento datasource. Este es el nombre de usuario que se utilizará para conectarse a la instancia de Base de datos SQL.
type	string: Microsoft.Sql/Server/Database	Indica el tipo de origen de datos de entrada que contiene datos de referencia. Obligatorio en las solicitudes PUT (CreateOrReplace).

AzureSynapseOutputDataSource

Describe un Azure Synapse origen de datos de salida.

Nombre	Tipo	Description
properties.database	string	Nombre de la base de datos Azure SQL. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.password	string	Contraseña que se usará para conectarse a la base de datos de Azure SQL. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.server	string	Nombre del servidor SQL server que contiene la base de datos de Azure SQL. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.table	string	Nombre de la tabla de la base de datos Azure SQL. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.user	string	Nombre de usuario que se usará para conectarse a la base de datos de Azure SQL. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/DataWarehouse	Indica el tipo de salida del origen de datos en el que se escribirá. Obligatorio en las solicitudes PUT (CreateOrReplace).

AzureTableOutputDataSource

Describe un origen de datos de salida de tabla de Azure.

Nombre	Tipo	Description
properties.accountKey	string	Clave de cuenta de la cuenta de Azure Storage. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.accountName	string	nombre de la cuenta de Azure Storage. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.batchSize	integer	Número de filas que se van a escribir en la tabla de Azure a la vez.
properties.columnsToRemove	string[]	Si se especifica, cada elemento de la matriz es el nombre de una columna para quitar (si existe) de entidades de eventos de salida.
properties.partitionKey	string	Este elemento indica el nombre de una columna de la instrucción SELECT de la consulta que se usará como clave de partición para la tabla de Azure. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.rowKey	string	Este elemento indica el nombre de una columna de la instrucción SELECT de la consulta que se usará como clave de fila para la tabla de Azure. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.table	string	Nombre de la tabla de Azure. Se requiere en las solicitudes PUT (CreateOrReplace).
type	string: Microsoft.Storage/Table	Indica el tipo de salida del origen de datos en el que se escribirá. Se requiere en las solicitudes PUT (CreateOrReplace).

BlobOutputDataSource

Describe un origen de datos de salida de blobs.

Nombre	Tipo	Valor predeterminado	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.blobPathPrefix	string		Prefijo de ruta de acceso de blob.
properties.container	string		Nombre de un contenedor dentro de la cuenta de almacenamiento asociada. Este contenedor contiene los blobs en los que se van a leer o escribir. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.dateFormat	string		El formato de la fecha. Siempre que {date} aparezca en pathPattern, el valor de esta propiedad se usa como formato de fecha en su lugar.
properties.pathPattern	string		Patrón de ruta de acceso del blob. No es una expresión regular. Representa un patrón con el que se coincidirán los nombres de blob para determinar si deben incluirse o no como entrada o salida en el trabajo. Vea https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input o https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output para obtener una explicación y un ejemplo más detallados.
properties.storageAccounts	StorageAccount[]		Lista de una o varias cuentas de Azure Storage. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.timeFormat	string		Formato de hora. Siempre que aparezca {time} en pathPattern, el valor de esta propiedad se usa como formato de hora en su lugar.
type	string: Microsoft.Storage/Blob		Indica el tipo de salida del origen de datos en el que se escribirá. Se requiere en las solicitudes PUT (CreateOrReplace).

BlobReferenceInputDataSource

Describe un origen de datos de entrada de blobs que contiene datos de referencia.

Nombre	Tipo	Valor predeterminado	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.container	string		Nombre de un contenedor dentro de la cuenta de almacenamiento asociada. Este contenedor contiene los blobs en los que se van a leer o escribir. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.dateFormat	string		El formato de la fecha. Siempre que {date} aparezca en pathPattern, el valor de esta propiedad se usa como formato de fecha en su lugar.
properties.pathPattern	string		Patrón de ruta de acceso del blob. No es una expresión regular. Representa un patrón con el que se coincidirán los nombres de blob para determinar si deben incluirse o no como entrada o salida en el trabajo. Vea https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input o https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output para obtener una explicación y un ejemplo más detallados.
properties.storageAccounts	StorageAccount[]		Lista de una o varias cuentas de Azure Storage. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.timeFormat	string		Formato de hora. Siempre que aparezca {time} en pathPattern, el valor de esta propiedad se usa como formato de hora en su lugar.
type	string: Microsoft.Storage/Blob		Indica el tipo de origen de datos de entrada que contiene datos de referencia. Se requiere en las solicitudes PUT (CreateOrReplace).

BlobStreamInputDataSource

Describe un origen de datos de entrada de blobs que contiene datos de flujo.

Nombre	Tipo	Valor predeterminado	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.container	string		Nombre de un contenedor dentro de la cuenta de almacenamiento asociada. Este contenedor contiene los blobs en los que se van a leer o escribir. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.dateFormat	string		El formato de la fecha. Siempre que {date} aparezca en pathPattern, el valor de esta propiedad se usa como formato de fecha en su lugar.
properties.pathPattern	string		Patrón de ruta de acceso del blob. No es una expresión regular. Representa un patrón con el que se coincidirán los nombres de blob para determinar si deben incluirse o no como entrada o salida en el trabajo. Vea https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input o https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output para obtener una explicación y un ejemplo más detallados.
properties.sourcePartitionCount	integer		Recuento de particiones del origen de datos de entrada del blob. Intervalo 1 - 1024.
properties.storageAccounts	StorageAccount[]		Lista de una o varias cuentas de Azure Storage. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.timeFormat	string		Formato de hora. Siempre que aparezca {time} en pathPattern, el valor de esta propiedad se usa como formato de hora en su lugar.
type	string: Microsoft.Storage/Blob		Indica el tipo de origen de datos de entrada que contiene datos de flujo. Se requiere en las solicitudes PUT (CreateOrReplace).

ClusterInfo

Propiedades asociadas a un clúster de Stream Analytics.

Nombre	Tipo	Description
id	string	Identificador de recurso del clúster.

CompatibilityLevel

Controla ciertos comportamientos del runtime del trabajo de streaming.

Nombre	Tipo	Description
1.0	string
1.2	string

Compression

Describe cómo se comprimen los datos de entrada.

Nombre	Tipo	Valor predeterminado	Description
type	CompressionType	None	Indica el tipo de compresión que usa la entrada. Obligatorio en las solicitudes PUT (CreateOrReplace).

CompressionType

Indica el tipo de compresión que usa la entrada. Se requiere en las solicitudes PUT (CreateOrReplace).

Nombre	Tipo	Description
Deflate	string
GZip	string
None	string

ContentStoragePolicy

Los valores válidos son JobStorageAccount y SystemAccount. Si se establece en JobStorageAccount, esto requiere que el usuario especifique también la propiedad jobStorageAccount. .

Nombre	Tipo	Description
JobStorageAccount	string
SystemAccount	string

CsvSerialization

Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato CSV.

Nombre	Tipo	Description
properties.encoding	Encoding	Especifica la codificación de los datos entrantes en el caso de la entrada y la codificación de los datos salientes en el caso de la salida. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.fieldDelimiter	string	Especifica el delimitador que se usará para separar los registros de valores separados por comas (CSV). Consulte https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input o https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output para obtener una lista de valores admitidos. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string: Csv	Indica el tipo de serialización que usa la entrada o salida. Obligatorio en las solicitudes PUT (CreateOrReplace).

DiagnosticCondition

Condición aplicable al recurso, o al trabajo en general, que garantiza la atención al cliente.

Nombre	Tipo	Description
code	string	Código de diagnóstico opaco.
message	string	Mensaje legible que describe la condición en detalle. Localizado en el Accept-Language de la solicitud de cliente.
since	string	Marca de tiempo UTC de cuándo se inició la condición. Los clientes deben poder encontrar un evento correspondiente en el registro de operaciones en este momento.

Diagnostics

Describe las condiciones aplicables a la entrada, la salida o el trabajo en general, que garantizan la atención al cliente.

Nombre	Tipo	Description
conditions	DiagnosticCondition[]	Colección de cero o más condiciones aplicables al recurso, o al trabajo en general, que garantizan atención al cliente.

DocumentDbOutputDataSource

Describe un origen de datos de salida de DocumentDB.

Nombre	Tipo	Description
properties.accountId	string	El nombre o el identificador de la cuenta de DocumentDB. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.accountKey	string	Clave de cuenta de la cuenta de DocumentDB. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.collectionNamePattern	string	Patrón de nombre de colección para las colecciones que se usará. El formato de nombre de la colección se pueden construir con el token opcional {partition}, donde las particiones comienzan desde 0. Consulte la sección DocumentDB de https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output para obtener más información. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.database	string	Nombre de la base de datos de DocumentDB. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.documentId	string	Nombre del campo de los eventos de salida utilizado para especificar la clave principal en la que se basan las operaciones de inserción o actualización.
properties.partitionKey	string	Nombre del campo en los eventos de salida que se utiliza para especificar la clave de partición de salida entre colecciones. Si 'collectionNamePattern' contiene el token {partition}, se necesita especificar esta propiedad.
type	string: Microsoft.Storage/DocumentDB	Indica el tipo de salida del origen de datos en el que se escribirá. Obligatorio en las solicitudes PUT (CreateOrReplace).

Encoding

Especifica la codificación de los datos entrantes en el caso de la entrada y la codificación de los datos salientes en el caso de la salida.

Nombre	Tipo	Description
UTF8	string

Error

Representación de error común.

Nombre	Tipo	Description
error	Error	Propiedades de definición de error.

EventHubOutputDataSource

Describe un origen de datos de salida del centro de eventos.

Nombre	Tipo	Valor predeterminado	Description
authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.eventHubName	string		Nombre del centro de eventos. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.partitionKey	string		Clave o columna que se usa para determinar en qué partición se van a enviar datos de eventos.
properties.propertyColumns	string[]		Las propiedades asociadas a esta salida del centro de eventos.
serviceBusNamespace	string		Espacio de nombres asociado al centro de eventos deseado, cola de Service Bus, tema de Service Bus, etc. Obligatorio en las solicitudes PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Clave de directiva de acceso compartido para la directiva de acceso compartido especificada. Obligatorio en las solicitudes PUT (CreateOrReplace).
sharedAccessPolicyName	string		El nombre de la directiva de acceso compartido para el centro de eventos, la cola de Service Bus, el tema de Service Bus, etc. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indica el tipo de salida del origen de datos en el que se escribirá. Se requiere en las solicitudes PUT (CreateOrReplace).

EventHubStreamInputDataSource

Describe un origen de datos de entrada del centro de eventos que contiene datos de flujo.

Nombre	Tipo	Valor predeterminado	Description
authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.consumerGroupName	string		Nombre de un grupo de consumidores del centro de eventos que se debe usar para leer eventos del centro de eventos. Especificar nombres de grupo de consumidores distintos para varias entradas permite que cada una de esas entradas reciba los mismos eventos del centro de eventos. Si no se especifica, la entrada usa el grupo de consumidores predeterminado del centro de eventos.
properties.eventHubName	string		Nombre del centro de eventos. Se requiere en las solicitudes PUT (CreateOrReplace).
serviceBusNamespace	string		Espacio de nombres asociado al centro de eventos deseado, cola de Service Bus, tema de Service Bus, etc. Se requiere en las solicitudes PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Clave de directiva de acceso compartido para la directiva de acceso compartido especificada. Se requiere en las solicitudes PUT (CreateOrReplace).
sharedAccessPolicyName	string		El nombre de la directiva de acceso compartido para el centro de eventos, la cola de Service Bus, el tema de Service Bus, etc. Se requiere en las solicitudes PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indica el tipo de origen de datos de entrada que contiene datos de flujo. Se requiere en las solicitudes PUT (CreateOrReplace).

EventHubV2OutputDataSource

Describe un origen de datos de salida del centro de eventos.

Nombre	Tipo	Valor predeterminado	Description
authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.eventHubName	string		Nombre del centro de eventos. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.partitionKey	string		Clave o columna que se usa para determinar a qué partición se van a enviar datos de eventos.
properties.propertyColumns	string[]		Propiedades asociadas a esta salida del centro de eventos.
serviceBusNamespace	string		Espacio de nombres asociado al centro de eventos deseado, cola de Service Bus, tema de Service Bus, etc. Obligatorio en las solicitudes PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Clave de directiva de acceso compartido para la directiva de acceso compartido especificada. Obligatorio en las solicitudes PUT (CreateOrReplace).
sharedAccessPolicyName	string		El nombre de la directiva de acceso compartido para el centro de eventos, la cola de Service Bus, el tema de Service Bus, etc. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indica el tipo de salida del origen de datos en el que se escribirá. Obligatorio en las solicitudes PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Describe un origen de datos de entrada del centro de eventos que contiene datos de flujo.

Nombre	Tipo	Valor predeterminado	Description
authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.consumerGroupName	string		Nombre de un grupo de consumidores del centro de eventos que se debe usar para leer eventos del centro de eventos. Especificar nombres de grupo de consumidores distintos para varias entradas permite que cada una de esas entradas reciba los mismos eventos del centro de eventos. Si no se especifica, la entrada usa el grupo de consumidores predeterminado del centro de eventos.
properties.eventHubName	string		Nombre del centro de eventos. Se requiere en las solicitudes PUT (CreateOrReplace).
serviceBusNamespace	string		Espacio de nombres asociado al centro de eventos deseado, cola de Service Bus, tema de Service Bus, etc. Se requiere en las solicitudes PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Clave de directiva de acceso compartido para la directiva de acceso compartido especificada. Se requiere en las solicitudes PUT (CreateOrReplace).
sharedAccessPolicyName	string		El nombre de la directiva de acceso compartido para el centro de eventos, la cola de Service Bus, el tema de Service Bus, etc. Se requiere en las solicitudes PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indica el tipo de origen de datos de entrada que contiene datos de flujo. Se requiere en las solicitudes PUT (CreateOrReplace).

EventSerializationType

Indica el tipo de serialización que usa la entrada o salida. Se requiere en las solicitudes PUT (CreateOrReplace).

Nombre	Tipo	Description
Avro	string
Csv	string
Json	string
Parquet	string

EventsOutOfOrderPolicy

Indica la directiva que aplicar a los eventos que llegan desordenados en el flujo de eventos de entrada.

Nombre	Tipo	Description
Adjust	string
Drop	string

FileReferenceInputDataSource

Describe un origen de datos de entrada de archivo que contiene datos de referencia.

Nombre	Tipo	Description
properties.path	string	Ruta de acceso del archivo.
type	string: File	Indica el tipo de origen de datos de entrada que contiene datos de referencia. Se requiere en las solicitudes PUT (CreateOrReplace).

Function

Objeto de función que contiene toda la información asociada a la función con nombre. Todas las funciones están contenidas en un trabajo de streaming.

Nombre	Tipo	Description
id	string	Id. de recurso
name	string	Nombre del recurso
properties	FunctionProperties: AggregateFunctionProperties ScalarFunctionProperties	Propiedades asociadas a una función.
type	string	Tipo de recurso

FunctionInput

Describe un parámetro de entrada de una función.

Nombre	Tipo	Description
dataType	string	Tipo de datos (compatible con Azure Stream Analytics) del parámetro de entrada de función. Se describe una lista de tipos de datos válidos de Azure Stream Analytics en . https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	Marca que indica si el parámetro es un parámetro de configuración. True si se espera que este parámetro de entrada sea una constante. El valor predeterminado es False.

FunctionOutput

Describe la salida de una función.

Nombre	Tipo	Description
dataType	string	Tipo de datos (compatible con Azure Stream Analytics) de la salida de la función. Se describe una lista de tipos de datos válidos de Azure Stream Analytics en . https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

Describe un origen de datos de salida de Gateway Message Bus.

Nombre	Tipo	Description
properties.topic	string	Nombre del tema de Service Bus.
type	string: GatewayMessageBus	Indica el tipo de salida del origen de datos en el que se escribirá. Obligatorio en las solicitudes PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Describe un origen de datos de entrada de blobs que contiene datos de flujo.

Nombre	Tipo	Description
properties.topic	string	Nombre del tema de Service Bus.
type	string: GatewayMessageBus	Indica el tipo de origen de datos de entrada que contiene datos de flujo. Se requiere en las solicitudes PUT (CreateOrReplace).

Identity

Describe cómo se comprueba la identidad.

Nombre	Tipo	Description
principalId	string	Identificador de entidad de seguridad de identidad
tenantId	string	Id. de inquilino de identidad
type	string	Tipo de identidad

Input

Objeto de entrada que contiene toda la información asociada a la entrada con nombre. Todas las entradas están contenidas en un trabajo de streaming.

Nombre	Tipo	Description
id	string	Id. de recurso
name	string	Nombre del recurso
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Propiedades asociadas a una entrada. Se requiere en las solicitudes PUT (CreateOrReplace).
type	string	Tipo de recurso

IoTHubStreamInputDataSource

Describe un origen de datos de entrada IoT Hub que contiene datos de flujo.

Nombre	Tipo	Description
properties.consumerGroupName	string	Nombre de un grupo de consumidores de IoT Hub que se debe usar para leer eventos del IoT Hub. Si no se especifica, la entrada usa el grupo de consumidores predeterminado de Iot Hub.
properties.endpoint	string	El punto de conexión IoT Hub al que conectarse (es decir, mensajes/eventos, messages/operationsMonitoringEvents, etc.).
properties.iotHubNamespace	string	Nombre o URI del IoT Hub. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Clave de directiva de acceso compartido para la directiva de acceso compartido especificada. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Nombre de la directiva de acceso compartido para el IoT Hub. Esta directiva debe contener al menos el permiso De conexión de servicio. Se requiere en las solicitudes PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Indica el tipo de origen de datos de entrada que contiene datos de flujo. Se requiere en las solicitudes PUT (CreateOrReplace).

JavaScriptFunctionBinding

Enlace a una función de JavaScript.

Nombre	Tipo	Description
properties.script	string	Código JavaScript que contiene una única definición de función. Por ejemplo: 'function (x, y) { return x + y; }'
type	string: Microsoft.StreamAnalytics/JavascriptUdf	Indica el tipo de enlace de función.

JobStorageAccount

Propiedades asociadas a una cuenta de Azure Storage con MSI

Nombre	Tipo	Valor predeterminado	Description
accountKey	string		Clave de cuenta de la cuenta de Azure Storage. Se requiere en las solicitudes PUT (CreateOrReplace).
accountName	string		nombre de la cuenta de Azure Storage. Se requiere en las solicitudes PUT (CreateOrReplace).
authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.

JobType

Describe el tipo del trabajo. Los modos válidos son Cloud y "Edge".

Nombre	Tipo	Description
Cloud	string
Edge	string

JsonOutputSerializationFormat

Especifica el formato del JSON en el que se escribirá la salida. Los valores admitidos actualmente son "lineSeparated" que indican que la salida tendrá el formato de cada objeto JSON separado por una nueva línea y "matriz" que indica que la salida se formateará como una matriz de objetos JSON.

Nombre	Tipo	Description
Array	string
LineSeparated	string

JsonSerialization

Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato JSON.

Nombre	Tipo	Description
properties.encoding	Encoding	Especifica la codificación de los datos entrantes en el caso de la entrada y la codificación de los datos salientes en el caso de la salida. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Esta propiedad solo se aplica a la serialización JSON de salidas. No es aplicable a las entradas. Esta propiedad especifica el formato json en el que se escribirá la salida. Los valores admitidos actualmente son "lineSeparated" que indican que la salida se dará formato al tener cada objeto JSON separado por una nueva línea y "matriz" que indica que la salida se dará formato como una matriz de objetos JSON. El valor predeterminado es "lineSeparated" si se deja null.
type	string: Json	Indica el tipo de serialización que usa la entrada o salida. Obligatorio en las solicitudes PUT (CreateOrReplace).

Output

Objeto de salida que contiene toda la información asociada a la salida con nombre. Todas las salidas están contenidas en un trabajo de streaming.

Nombre	Tipo	Description
id	string	Id. de recurso
name	string	Nombre del recurso
properties.datasource	OutputDataSource: AzureDataLakeStoreOutputDataSource AzureFunctionOutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource AzureTableOutputDataSource BlobOutputDataSource DocumentDbOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource GatewayMessageBusOutputDataSource PowerBIOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource	Describe el origen de datos en el que se escribirá la salida. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.diagnostics	Diagnostics	Describe las condiciones aplicables a la entrada, la salida o el trabajo en general, que garantizan la atención al cliente.
properties.etag	string	Etiqueta de entidad actual para la salida. Se trata de una cadena opaca. Puede usarlo para detectar si el recurso ha cambiado entre solicitudes. También puede usarlo en los encabezados If-Match o If-None-Match para operaciones de escritura para simultaneidad optimista.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.sizeWindow	integer	Ventana de tamaño a la que se va a restringir una salida de Stream Analytics.
properties.timeWindow	string	Período de tiempo para filtrar las salidas del trabajo de Stream Analytics.
type	string	Tipo de recurso

OutputErrorPolicy

Indica la directiva que se aplica a los eventos que llegan a la salida y no se pueden escribir en el almacenamiento externo porque están mal formados (faltan valores de las columnas o el tamaño o tipo de los valores de las columnas no son correctos).

Nombre	Tipo	Description
Drop	string
Stop	string

OutputStartMode

El valor puede ser JobStartTime, CustomTime o LastOutputEventTime para indicar si el punto inicial del flujo de eventos de salida debe iniciarse cada vez que se inicia el trabajo, empezar en una marca de tiempo de usuario personalizada especificada a través de la propiedad outputStartTime o comenzar desde la última hora de salida del evento.

Nombre	Tipo	Description
CustomTime	string
JobStartTime	string
LastOutputEventTime	string

ParquetSerialization

Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato Parquet.

Nombre	Tipo	Description
type	string: Parquet	Indica el tipo de serialización que usa la entrada o salida. Obligatorio en las solicitudes PUT (CreateOrReplace).

PowerBIOutputDataSource

Describe un origen de datos de salida de Power BI.

Nombre	Tipo	Valor predeterminado	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.dataset	string		Nombre del conjunto de datos de Power BI. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.groupId	string		Identificador del grupo de Power BI.
properties.groupName	string		Nombre del grupo de Power BI. Use esta propiedad para recordar qué identificador de grupo de Power BI específico se usó.
properties.refreshToken	string		Token de actualización que se puede usar para obtener un token de acceso válido que se puede usar para autenticarse con el origen de datos. Actualmente, solo se puede obtener un token de actualización válido a través de Azure Portal. Se recomienda colocar aquí un valor ficticio de cadena al crear el origen de datos y, a continuación, ir a Azure Portal para autenticar el origen de datos que actualizará esta propiedad con un token de actualización válido. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.table	string		Nombre de la tabla de Power BI en el conjunto de datos especificado. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.tokenUserDisplayName	string		Nombre para mostrar del usuario que se usó para obtener el token de actualización. Use esta propiedad para ayudar a recordar qué usuario se usó para obtener el token de actualización.
properties.tokenUserPrincipalName	string		El nombre principal de usuario (UPN) del usuario que se usó para obtener el token de actualización. Use esta propiedad para ayudar a recordar qué usuario se usó para obtener el token de actualización.
type	string: PowerBI		Indica el tipo de salida del origen de datos en el que se escribirá. Obligatorio en las solicitudes PUT (CreateOrReplace).

ReferenceInputProperties

Propiedades asociadas a una entrada que contiene datos de referencia.

Nombre	Tipo	Description
compression	Compression	Describe cómo se comprimen los datos de entrada.
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Describe un origen de datos de entrada que contiene datos de referencia. Se requiere en las solicitudes PUT (CreateOrReplace).
diagnostics	Diagnostics	Describe las condiciones aplicables a la entrada, la salida o el trabajo en general, que garantizan la atención al cliente.
etag	string	Etiqueta de entidad actual para la entrada. Se trata de una cadena opaca. Puede usarlo para detectar si el recurso ha cambiado entre solicitudes. También puede usarlo en los encabezados If-Match o If-None-Match para operaciones de escritura para simultaneidad optimista.
partitionKey	string	partitionKey Describe una clave en los datos de entrada que se usan para crear particiones de los datos de entrada.
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida. Se requiere en las solicitudes PUT (CreateOrReplace).
type	string: Reference	Indica si la entrada es un origen de datos de referencia o datos de flujo. Se requiere en las solicitudes PUT (CreateOrReplace).

RefreshType

Indica el tipo de opción de actualización de datos.

Nombre	Tipo	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

ScalarFunctionProperties

Propiedades asociadas a una función escalar.

Nombre	Tipo	Description
etag	string	Etiqueta de entidad actual para la función. Se trata de una cadena opaca. Puede usarlo para detectar si el recurso ha cambiado entre solicitudes. También puede usarlo en los encabezados If-Match o If-None-Match para operaciones de escritura para la simultaneidad optimista.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Enlace físico de la función. Por ejemplo, en el caso del servicio web Azure Machine Learning, se describe el punto de conexión.
properties.inputs	FunctionInput[]	Describe un parámetro de entrada de una función.
properties.output	FunctionOutput	Describe la salida de una función.
type	string: Scalar	Indica el tipo de función.

ServiceBusQueueOutputDataSource

Describe un origen de datos de salida de cola de Service Bus.

Nombre	Tipo	Valor predeterminado	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.propertyColumns	string[]		Matriz de cadenas de los nombres de las columnas de salida que se van a adjuntar a los mensajes de Service Bus como propiedades personalizadas.
properties.queueName	string		El nombre de la cola de Service Bus Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.serviceBusNamespace	string		Espacio de nombres asociado al centro de eventos deseado, cola de Service Bus, tema de Service Bus, etc. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Clave de directiva de acceso compartido para la directiva de acceso compartido especificada. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		El nombre de la directiva de acceso compartido para el centro de eventos, la cola de Service Bus, el tema de Service Bus, etc. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.systemPropertyColumns	object		Las propiedades del sistema asociadas a la cola de Service Bus. Se admiten las siguientes propiedades del sistema: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
type	string: Microsoft.ServiceBus/Queue		Indica el tipo de salida del origen de datos en el que se escribirá. Obligatorio en las solicitudes PUT (CreateOrReplace).

ServiceBusTopicOutputDataSource

Describe un origen de datos de salida del tema de Service Bus.

Nombre	Tipo	Valor predeterminado	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.propertyColumns	string[]		Matriz de cadenas de los nombres de las columnas de salida que se van a adjuntar a los mensajes de Service Bus como propiedades personalizadas.
properties.serviceBusNamespace	string		Espacio de nombres asociado al centro de eventos deseado, cola de Service Bus, tema de Service Bus, etc. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Clave de directiva de acceso compartido para la directiva de acceso compartido especificada. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		El nombre de la directiva de acceso compartido para el centro de eventos, la cola de Service Bus, el tema de Service Bus, etc. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.systemPropertyColumns	object		Las propiedades del sistema asociadas a la salida del tema de Service Bus. Se admiten las siguientes propiedades del sistema: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
properties.topicName	string		Nombre del tema de Service Bus. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/Topic		Indica el tipo de salida del origen de datos en el que se escribirá. Obligatorio en las solicitudes PUT (CreateOrReplace).

Sku

Propiedades asociadas a una SKU.

Nombre	Tipo	Description
name	SkuName	El nombre de la SKU. Se requiere en las solicitudes PUT (CreateOrReplace).

SkuName

El nombre de la SKU. Se requiere en las solicitudes PUT (CreateOrReplace).

Nombre	Tipo	Description
Standard	string

StorageAccount

Propiedades asociadas a una cuenta de Azure Storage

Nombre	Tipo	Description
accountKey	string	Clave de cuenta de la cuenta de Azure Storage. Se requiere en las solicitudes PUT (CreateOrReplace).
accountName	string	nombre de la cuenta de Azure Storage. Se requiere en las solicitudes PUT (CreateOrReplace).

StreamingJob

Objeto de trabajo de streaming que contiene toda la información asociada al trabajo de streaming con nombre.

Nombre	Tipo	Description
id	string	Identificador de recurso completo para el recurso. Por ejemplo: /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Describe la identidad administrada asignada por el sistema asignada a este trabajo que se puede usar para autenticarse con entradas y salidas.
location	string	Ubicación geográfica donde reside el recurso
name	string	Nombre del recurso.
properties.cluster	ClusterInfo	Clúster en el que se ejecutarán los trabajos de streaming.
properties.compatibilityLevel	CompatibilityLevel	Controla ciertos comportamientos del runtime del trabajo de streaming.
properties.contentStoragePolicy	ContentStoragePolicy	Los valores válidos son JobStorageAccount y SystemAccount. Si se establece en JobStorageAccount, esto requiere que el usuario especifique también la propiedad jobStorageAccount. .
properties.createdDate	string	El valor es una marca de tiempo UTC con formato ISO-8601 que indica cuándo se creó el trabajo de streaming.
properties.dataLocale	string	La configuración regional de los datos del trabajo de análisis del flujo de datos. El valor debe ser el nombre de una referencia cultural de .NET admitida del conjunto https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. El valor predeterminado es "en-US" si no se ha especificado ninguno.
properties.etag	string	Etiqueta de entidad actual para el trabajo de streaming. Se trata de una cadena opaca. Puede usarlo para detectar si el recurso ha cambiado entre solicitudes. También puede usarlo en los encabezados If-Match o If-None-Match para operaciones de escritura para simultaneidad optimista.
properties.eventsLateArrivalMaxDelayInSeconds	integer	El retraso tolerable máximo, en segundos, que pueden tener los eventos que llegan tarde para ser incluidos. El rango admitido es -1 a 1814399 (20.23:59:59 días) y-1 se usa para especificar que la espera es indefinida. Si la propiedad no está presente, se interpreta que tiene el valor -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	El retraso máximo tolerable, en segundos, en que se pueden ajustar los eventos que no funcionan para que vuelvan a estar en orden.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Indica la directiva que aplicar a los eventos que llegan desordenados en el flujo de eventos de entrada.
properties.functions	Function[]	Lista de una o varias funciones para el trabajo de streaming. La propiedad name de cada función es necesaria al especificar esta propiedad en una solicitud PUT. Esta propiedad no se puede modificar a través de una operación PATCH. Debe usar la API PATCH disponible para la transformación individual.
properties.inputs	Input[]	Lista de una o varias entradas para el trabajo de streaming. La propiedad name para cada entrada es necesaria al especificar esta propiedad en una solicitud PUT. Esta propiedad no se puede modificar a través de una operación PATCH. Debe usar la API PATCH disponible para la entrada individual.
properties.jobId	string	Guid que identifica de forma única el trabajo de streaming. Este GUID se genera al crear el trabajo de streaming.
properties.jobState	string	Describe el estado del trabajo de streaming.
properties.jobStorageAccount	JobStorageAccount	Propiedades asociadas a una cuenta de Azure Storage con MSI
properties.jobType	JobType	Describe el tipo del trabajo. Los modos válidos son Cloud y "Edge".
properties.lastOutputEventTime	string	El valor es una marca de tiempo con formato ISO-8601 que indica la última hora del evento de salida del trabajo de streaming o null que indica que la salida aún no se ha generado. En el caso de varias salidas o varias secuencias, esto muestra el valor más reciente de ese conjunto.
properties.outputErrorPolicy	OutputErrorPolicy	Indica la directiva que se aplica a los eventos que llegan a la salida y no se pueden escribir en el almacenamiento externo porque están mal formados (faltan valores de las columnas o el tamaño o tipo de los valores de las columnas no son correctos).
properties.outputStartMode	OutputStartMode	Esta propiedad solo debe utilizarse cuando se desee que el trabajo se inicie inmediatamente después de la creación. El valor puede ser JobStartTime, CustomTime o LastOutputEventTime para indicar si el punto inicial del flujo de eventos de salida debe iniciarse cada vez que se inicia el trabajo, empezar en una marca de tiempo de usuario personalizada especificada a través de la propiedad outputStartTime o comenzar desde la última hora de salida del evento.
properties.outputStartTime	string	El valor es una marca de tiempo con formato ISO-8601 que indica el punto inicial de la secuencia de eventos de salida o NULL para indicar que la secuencia de eventos de salida empezará cuando se inicie el trabajo de transmisión. Esta propiedad debe tener un valor si outputStartMode está establecido en CustomTime.
properties.outputs	Output[]	Lista de una o varias salidas para el trabajo de streaming. La propiedad name de cada salida es necesaria al especificar esta propiedad en una solicitud PUT. Esta propiedad no se puede modificar a través de una operación PATCH. Debe usar la API PATCH disponible para la salida individual.
properties.provisioningState	string	Describe el estado de aprovisionamiento del trabajo de streaming.
properties.sku	Sku	Describe la SKU del trabajo de streaming. Se requiere en las solicitudes PUT (CreateOrReplace).
properties.transformation	Transformation	Indica la consulta y el número de unidades de streaming que se van a usar para el trabajo de streaming. La propiedad name de la transformación es necesaria al especificar esta propiedad en una solicitud PUT. Esta propiedad no se puede modificar a través de una operación PATCH. Debe usar la API PATCH disponible para la transformación individual.
tags	object	Etiquetas del recurso.
type	string	Tipo de recurso. Por ejemplo, Microsoft.Compute/virtualMachines o Microsoft.Storage/storageAccounts.

StreamInputProperties

Propiedades asociadas a una entrada que contiene datos de flujo.

Nombre	Tipo	Description
compression	Compression	Describe cómo se comprimen los datos de entrada.
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Describe un origen de datos de entrada que contiene datos de flujo. Se requiere en las solicitudes PUT (CreateOrReplace).
diagnostics	Diagnostics	Describe las condiciones aplicables a la entrada, la salida o el trabajo en general, que garantizan la atención al cliente.
etag	string	Etiqueta de entidad actual para la entrada. Se trata de una cadena opaca. Puede usarlo para detectar si el recurso ha cambiado entre solicitudes. También puede usarlo en los encabezados If-Match o If-None-Match para operaciones de escritura para simultaneidad optimista.
partitionKey	string	partitionKey Describe una clave en los datos de entrada que se usan para crear particiones de los datos de entrada.
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida. Se requiere en las solicitudes PUT (CreateOrReplace).
type	string: Stream	Indica si la entrada es un origen de datos de referencia o datos de flujo. Se requiere en las solicitudes PUT (CreateOrReplace).

Transformation

Objeto de transformación que contiene toda la información asociada a la transformación con nombre. Todas las transformaciones están contenidas en un trabajo de streaming.

Nombre	Tipo	Valor predeterminado	Description
id	string		Id. de recurso
name	string		Nombre del recurso
properties.etag	string		Etiqueta de entidad actual para la transformación. Se trata de una cadena opaca. Puede usarlo para detectar si el recurso ha cambiado entre solicitudes. También puede usarlo en los encabezados If-Match o If-None-Match para operaciones de escritura para simultaneidad optimista.
properties.query	string		Especifica la consulta que se ejecutará en el trabajo de streaming. Puede obtener más información sobre el lenguaje de consulta de Stream Analytics (SAQL) aquí: https://msdn.microsoft.com/library/azure/dn834998 . Se requiere en las solicitudes PUT (CreateOrReplace).
properties.streamingUnits	integer	3	Especifica el número de unidades de streaming que utiliza el trabajo de streaming.
properties.validStreamingUnits	integer[]		Especifica las unidades de streaming válidas a las que puede escalar un trabajo de streaming.
type	string		Tipo de recurso