Streaming Jobs - Create Or Replace

Service:

Stream Analytics

Version d'API:

2020-03-01

Crée un travail de streaming ou remplace un travail de diffusion en continu existant.

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

Paramètres URI

Nom	Dans	Obligatoire	Type	Description
jobName	path	True	string	Nom du travail de streaming.
resourceGroupName	path	True	string	Nom du groupe de ressources. Le nom ne respecte pas la casse. Modèle d’expression régulière: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	ID de l’abonnement cible.
api-version	query	True	string	Version de l’API à utiliser pour cette opération.

En-tête de la demande

Nom	Obligatoire	Type	Description
If-Match		string	ETag du travail de streaming. Omettez cette valeur pour toujours remplacer le jeu d’enregistrements actif. Spécifiez la dernière valeur ETag vue pour empêcher le remplacement accidentel des modifications simultanées.
If-None-Match		string	Définissez sur « * » pour autoriser la création d’un travail de streaming, mais pour empêcher la mise à jour d’un jeu d’enregistrements existant. D’autres valeurs entraînent une réponse 412 Pré-condition Failed.

Corps de la demande

Nom	Type	Description
identity	Identity	Décrit l’identité managée affectée par le système affectée à ce travail qui peut être utilisée pour s’authentifier avec des entrées et des sorties.
location	string	Emplacement géographique où réside la ressource
properties.cluster	ClusterInfo	Cluster sur lequel les travaux de streaming s’exécuteront.
properties.compatibilityLevel	CompatibilityLevel	Contrôle certains comportements d’exécution de la tâche de streaming.
properties.contentStoragePolicy	ContentStoragePolicy	Les valeurs valides sont JobStorageAccount et SystemAccount. Si la valeur est JobStorageAccount, l’utilisateur doit également spécifier la propriété jobStorageAccount. .
properties.dataLocale	string	Paramètres régionaux des données de la tâche Stream Analytics. La valeur doit être le nom d’une culture .NET prise en charge à partir de l’ensemble https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. La valeur par défaut est « en-US » si aucune n’est spécifiée.
properties.eventsLateArrivalMaxDelayInSeconds	integer	Délai maximal acceptable en secondes pendant lequel les événements arrivant en retard peuvent être inclus. La plage prise en charge est comprise entre -1 et 1814399 (20.23:59:59 jours) et -1 est utilisé pour spécifier d’attendre indéfiniment. Si la propriété est absente, elle est interprétée comme ayant la valeur -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	Délai maximal acceptable en secondes pendant lequel les événements en désordre peuvent être ajustés pour être restaurés dans l’ordre.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Indique la stratégie à appliquer aux événements qui arrivent en désordre dans le flux d’événements d’entrée.
properties.functions	Function[]	Liste d’une ou plusieurs fonctions pour le travail de streaming. La propriété name de chaque fonction est requise lors de la spécification de cette propriété dans une requête PUT. Cette propriété ne peut pas être modifié via une opération PATCH. Vous devez utiliser l’API PATCH disponible pour la transformation individuelle.
properties.inputs	Input[]	Liste d’une ou plusieurs entrées pour le travail de streaming. La propriété name pour chaque entrée est requise lors de la spécification de cette propriété dans une requête PUT. Cette propriété ne peut pas être modifié via une opération PATCH. Vous devez utiliser l’API PATCH disponible pour l’entrée individuelle.
properties.jobStorageAccount	JobStorageAccount	Propriétés associées à un compte de stockage Azure avec MSI
properties.jobType	JobType	Décrit le type du travail. Les modes valides sont Cloud et « Edge ».
properties.outputErrorPolicy	OutputErrorPolicy	Indique la stratégie à appliquer aux événements qui arrivent à la sortie et qui ne peuvent pas être écrits dans le stockage externe en raison d’une constitution inappropriée (valeurs de colonne manquantes ou avec une taille ou un type incorrect).
properties.outputStartMode	OutputStartMode	Cette propriété ne doit être utilisée que lorsqu’il est souhaité que le travail soit démarré immédiatement lors de la création. La valeur peut être JobStartTime, CustomTime ou LastOutputEventTime pour indiquer si le point de départ du flux d’événements de sortie doit démarrer chaque fois que le travail est démarré, démarrer à un horodatage utilisateur personnalisé spécifié via la propriété outputStartTime ou démarrer à partir de l’heure de sortie du dernier événement.
properties.outputStartTime	string	La valeur est soit un horodatage au format ISO 8601, indiquant le point de départ du flux d'événements de sortie, soit null pour indiquer que le flux d'événements de sortie démarre à chaque démarrage du travail de diffusion en continu. Cette propriété doit avoir une valeur si outputStartMode est défini sur CustomTime.
properties.outputs	Output[]	Liste d’une ou plusieurs sorties pour le travail de streaming. La propriété name pour chaque sortie est requise lors de la spécification de cette propriété dans une requête PUT. Cette propriété ne peut pas être modifié via une opération PATCH. Vous devez utiliser l’API PATCH disponible pour la sortie individuelle.
properties.sku	Sku	Décrit la référence SKU du travail de streaming. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.transformation	Transformation	Indique la requête et le nombre d’unités de streaming à utiliser pour le travail de streaming. La propriété name de la transformation est requise lors de la spécification de cette propriété dans une requête PUT. Cette propriété ne peut pas être modifié via une opération PATCH. Vous devez utiliser l’API PATCH disponible pour la transformation individuelle.
tags	object	Balises de ressource.

Réponses

Nom	Type	Description
200 OK	StreamingJob	Le travail de diffusion en continu a été créé ou remplacé. En-têtes ETag: string
201 Created	StreamingJob	Le travail de diffusion en continu a été créé ou remplacé. En-têtes ETag: string
Other Status Codes	Error	Erreur.

Sécurité

azure_auth

Flux OAuth2 Azure Active Directory

Type: oauth2
Flux: implicit
URL d’autorisation: https://login.microsoftonline.com/common/oauth2/authorize

Étendues

Nom	Description
user_impersonation	Emprunter l’identité de votre compte d’utilisateur

Exemples

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)

Exemple de requête

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

Exemple de réponse

Code d’état:

201

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

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

Code d’état:

200

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

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

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

Exemple de requête

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

Exemple de réponse

Code d’état:

201

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

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

Code d’état:

200

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

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

Définitions

Nom	Description
AggregateFunctionProperties	Propriétés associées à une fonction d’agrégation.
AuthenticationMode	Mode d’authentification. Les modes valides sont ConnectionString, Msi et « UserToken ».
AvroSerialization	Décrit comment les données d’une entrée sont sérialisées ou comment les données sont sérialisées lorsqu’elles sont écrites dans une sortie au format Avro.
AzureDataLakeStoreOutputDataSource	Décrit une source de données de sortie Azure Data Lake Store.
AzureFunctionOutputDataSource	Définit les métadonnées d’AzureFunctionOutputDataSource
AzureMachineLearningWebServiceFunctionBinding	Liaison à un service web Azure Machine Learning.
AzureMachineLearningWebServiceInputColumn	Décrit une colonne d’entrée pour le point de terminaison de service web Azure Machine Learning.
AzureMachineLearningWebServiceInputs	Entrées pour le point de terminaison du service web Azure Machine Learning.
AzureMachineLearningWebServiceOutputColumn	Décrit une colonne de sortie pour le point de terminaison de service web Azure Machine Learning.
AzureSqlDatabaseOutputDataSource	Décrit une source de données de sortie de base de données Azure SQL.
AzureSqlReferenceInputDataSource	Décrit une source de données d’entrée de référence de base de données Azure SQL.
AzureSynapseOutputDataSource	Décrit une source de données de sortie Azure Synapse.
AzureTableOutputDataSource	Décrit une source de données de sortie Table Azure.
BlobOutputDataSource	Décrit une source de données de sortie d’objet blob.
BlobReferenceInputDataSource	Décrit une source de données d’entrée d’objet blob qui contient des données de référence.
BlobStreamInputDataSource	Décrit une source de données d’entrée d’objet blob qui contient des données de flux.
ClusterInfo	Propriétés associées à un cluster Stream Analytics.
CompatibilityLevel	Contrôle certains comportements d’exécution de la tâche de streaming.
Compression	Décrit comment les données d’entrée sont compressées
CompressionType	Indique le type de compression utilisé par l’entrée. Obligatoire sur les demandes PUT (CreateOrReplace).
ContentStoragePolicy	Les valeurs valides sont JobStorageAccount et SystemAccount. Si la valeur est JobStorageAccount, l’utilisateur doit également spécifier la propriété jobStorageAccount. .
CsvSerialization	Décrit comment les données d’une entrée sont sérialisées ou comment les données sont sérialisées lorsqu’elles sont écrites dans une sortie au format CSV.
DiagnosticCondition	Condition applicable à la ressource, ou à l’ensemble du travail, qui justifie l’attention du client.
Diagnostics	Décrit les conditions applicables à l’entrée, à la sortie ou à l’ensemble du travail qui justifient l’attention du client.
DocumentDbOutputDataSource	Décrit une source de données de sortie DocumentDB.
Encoding	Spécifie l’encodage des données entrantes dans le cas de l’entrée et l’encodage des données sortantes dans le cas de la sortie.
Error	Représentation d’erreur courante.
EventHubOutputDataSource	Décrit une source de données de sortie Event Hub.
EventHubStreamInputDataSource	Décrit une source de données d’entrée Event Hub qui contient des données de flux.
EventHubV2OutputDataSource	Décrit une source de données de sortie Event Hub.
EventHubV2StreamInputDataSource	Décrit une source de données d’entrée Event Hub qui contient des données de flux.
EventSerializationType	Indique le type de sérialisation utilisé par l’entrée ou la sortie. Obligatoire sur les demandes PUT (CreateOrReplace).
EventsOutOfOrderPolicy	Indique la stratégie à appliquer aux événements qui arrivent en désordre dans le flux d’événements d’entrée.
FileReferenceInputDataSource	Décrit une source de données d’entrée de fichier qui contient des données de référence.
Function	Objet de fonction, contenant toutes les informations associées à la fonction nommée. Toutes les fonctions sont contenues dans un travail de streaming.
FunctionInput	Décrit un paramètre d’entrée d’une fonction.
FunctionOutput	Décrit la sortie d’une fonction.
GatewayMessageBusOutputDataSource	Décrit une source de données de sortie du bus de message de passerelle.
GatewayMessageBusStreamInputDataSource	Décrit une source de données d’entrée d’objet blob qui contient des données de flux.
Identity	Décrit comment l’identité est vérifiée
Input	Objet d’entrée, contenant toutes les informations associées à l’entrée nommée. Toutes les entrées sont contenues dans un travail de streaming.
IoTHubStreamInputDataSource	Décrit une source de données d’entrée IoT Hub qui contient des données de flux.
JavaScriptFunctionBinding	Liaison à une fonction JavaScript.
JobStorageAccount	Propriétés associées à un compte de stockage Azure avec MSI
JobType	Décrit le type du travail. Les modes valides sont Cloud et « Edge ».
JsonOutputSerializationFormat	Spécifie le format du json dans lequel la sortie sera écrite. Les valeurs actuellement prises en charge sont « lineSeparated », ce qui indique que la sortie sera mise en forme en ayant chaque objet JSON séparé par une nouvelle ligne et « tableau » indiquant que la sortie sera mise en forme en tant que tableau d’objets JSON.
JsonSerialization	Décrit comment les données d’une entrée sont sérialisées ou comment les données sont sérialisées lorsqu’elles sont écrites dans une sortie au format JSON.
Output	Objet de sortie, contenant toutes les informations associées à la sortie nommée. Toutes les sorties sont contenues dans un travail de streaming.
OutputErrorPolicy	Indique la stratégie à appliquer aux événements qui arrivent à la sortie et qui ne peuvent pas être écrits dans le stockage externe en raison d’une constitution inappropriée (valeurs de colonne manquantes ou avec une taille ou un type incorrect).
OutputStartMode	La valeur peut être JobStartTime, CustomTime ou LastOutputEventTime pour indiquer si le point de départ du flux d’événements de sortie doit démarrer chaque fois que le travail est démarré, démarrer à un horodatage utilisateur personnalisé spécifié via la propriété outputStartTime ou démarrer à partir de l’heure de sortie du dernier événement.
ParquetSerialization	Décrit comment les données d’une entrée sont sérialisées ou comment les données sont sérialisées lorsqu’elles sont écrites dans une sortie au format Parquet.
PowerBIOutputDataSource	Décrit une source de données de sortie Power BI.
ReferenceInputProperties	Propriétés associées à une entrée contenant des données de référence.
RefreshType	Indique le type d’option d’actualisation des données.
ScalarFunctionProperties	Propriétés associées à une fonction scalaire.
ServiceBusQueueOutputDataSource	Décrit une source de données de sortie de file d’attente Service Bus.
ServiceBusTopicOutputDataSource	Décrit une source de données de sortie de rubrique Service Bus.
Sku	Propriétés associées à une référence SKU.
SkuName	Nom de la référence SKU. Obligatoire sur les demandes PUT (CreateOrReplace).
StorageAccount	Propriétés associées à un compte de stockage Azure
StreamingJob	Objet de travail de diffusion en continu, contenant toutes les informations associées au travail de diffusion en continu nommé.
StreamInputProperties	Propriétés associées à une entrée contenant des données de flux.
Transformation	Objet de transformation, contenant toutes les informations associées à la transformation nommée. Toutes les transformations sont contenues dans un travail de streaming.

AggregateFunctionProperties

Propriétés associées à une fonction d’agrégation.

Nom	Type	Description
etag	string	Balise d’entité actuelle pour la fonction. Il s’agit d’une chaîne opaque. Vous pouvez l’utiliser pour détecter si la ressource a changé entre les requêtes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour une concurrence optimiste.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Liaison physique de la fonction. Par exemple, dans le cas du service web Azure Machine Learning, cela décrit le point de terminaison.
properties.inputs	FunctionInput[]	Décrit un paramètre d’entrée d’une fonction.
properties.output	FunctionOutput	Décrit la sortie d’une fonction.
type	string: Aggregate	Indique le type de fonction.

AuthenticationMode

Mode d’authentification. Les modes valides sont ConnectionString, Msi et « UserToken ».

Nom	Type	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Décrit comment les données d’une entrée sont sérialisées ou comment les données sont sérialisées lorsqu’elles sont écrites dans une sortie au format Avro.

Nom	Type	Description
type	string: Avro	Indique le type de sérialisation utilisé par l’entrée ou la sortie. Obligatoire sur les demandes PUT (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Décrit une source de données de sortie Azure Data Lake Store.

Nom	Type	Valeur par défaut	Description
properties.accountName	string		Nom du compte Azure Data Lake Store. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.dateFormat	string		Format de date. Partout où {date} apparaît dans filePathPrefix, la valeur de cette propriété est utilisée comme format de date à la place.
properties.filePathPrefix	string		Emplacement du fichier dans lequel la sortie doit être écrite. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.refreshToken	string		Jeton d’actualisation qui peut être utilisé pour obtenir un jeton d’accès valide qui peut ensuite être utilisé pour s’authentifier auprès de la source de données. Un jeton d’actualisation valide n’est actuellement disponible que via le portail Azure. Il est recommandé de placer une valeur de chaîne factice ici lors de la création de la source de données, puis d’aller sur le portail Azure pour authentifier la source de données qui mettra à jour cette propriété avec un jeton d’actualisation valide. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.tenantId	string		ID de locataire de l’utilisateur utilisé pour obtenir le jeton d’actualisation. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.timeFormat	string		Format d’heure. Partout où {time} apparaît dans filePathPrefix, la valeur de cette propriété est utilisée comme format d’heure à la place.
properties.tokenUserDisplayName	string		Nom d’affichage de l’utilisateur utilisé pour obtenir le jeton d’actualisation. Utilisez cette propriété pour vous rappeler quel utilisateur a été utilisé pour obtenir le jeton d’actualisation.
properties.tokenUserPrincipalName	string		Nom d’utilisateur principal (UPN) de l’utilisateur utilisé pour obtenir le jeton d’actualisation. Utilisez cette propriété pour vous rappeler quel utilisateur a été utilisé pour obtenir le jeton d’actualisation.
type	string: Microsoft.DataLake/Accounts		Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

AzureFunctionOutputDataSource

Définit les métadonnées d’AzureFunctionOutputDataSource

Nom	Type	Description
properties.apiKey	string	Si vous souhaitez utiliser une fonction Azure à partir d’un autre abonnement, vous pouvez le faire en fournissant la clé permettant d’accéder à votre fonction.
properties.functionAppName	string	Nom de votre application Azure Functions.
properties.functionName	string	Nom de la fonction dans votre application Azure Functions.
properties.maxBatchCount	number	Propriété qui vous permet de spécifier le nombre maximal d’événements dans chaque lot envoyé à Azure Functions. La valeur par défaut est 100.
properties.maxBatchSize	number	Propriété qui peut être utilisée pour définir la taille maximale de chaque lot de sortie qui est envoyé à votre fonction Azure. L’unité d’entrée est exprimée en octets. Par défaut, cette valeur est définie sur 262 144 Ko (256 Ko).
type	string: Microsoft.AzureFunction	Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

Liaison à un service web Azure Machine Learning.

Nom	Type	Description
properties.apiKey	string	Clé API utilisée pour l’authentification avec Request-Response point de terminaison.
properties.batchSize	integer	Nombre compris entre 1 et 10 000 décrivant le nombre maximal de lignes pour chaque demande d’exécution Azure ML RRS. La valeur par défaut est 1000.
properties.endpoint	string	Le Request-Response exécuter le point de terminaison du service web Azure Machine Learning. Pour plus d’informations, cliquez ici : https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
properties.inputs	AzureMachineLearningWebServiceInputs	Entrées pour le point de terminaison du service web Azure Machine Learning.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Liste des sorties de l’exécution du point de terminaison de service web Azure Machine Learning.
type	string: Microsoft.MachineLearning/WebService	Indique le type de liaison de fonction.

AzureMachineLearningWebServiceInputColumn

Décrit une colonne d’entrée pour le point de terminaison de service web Azure Machine Learning.

Nom	Type	Description
dataType	string	Type de données (Pris en charge par Azure Machine Learning) de la colonne d’entrée. Une liste des types de données Azure Machine Learning valides est décrite à l’adresse https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
mapTo	integer	Index de base zéro du paramètre de fonction auquel cette entrée est mappée.
name	string	Nom de la colonne d'entrée.

AzureMachineLearningWebServiceInputs

Entrées pour le point de terminaison du service web Azure Machine Learning.

Nom	Type	Description
columnNames	AzureMachineLearningWebServiceInputColumn[]	Liste des colonnes d’entrée pour le point de terminaison du service web Azure Machine Learning.
name	string	Nom de l'entrée. Il s’agit du nom fourni lors de la création du point de terminaison.

AzureMachineLearningWebServiceOutputColumn

Décrit une colonne de sortie pour le point de terminaison de service web Azure Machine Learning.

Nom	Type	Description
dataType	string	Type de données (Pris en charge par Azure Machine Learning) de la colonne de sortie. Une liste des types de données Azure Machine Learning valides est décrite à l’adresse https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
name	string	Nom de la colonne de sortie.

AzureSqlDatabaseOutputDataSource

Décrit une source de données de sortie de base de données Azure SQL.

Nom	Type	Valeur par défaut	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.database	string		Nom de la base de données Azure SQL. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.maxBatchCount	number		Nombre maximal de lots pour l’écriture dans la base de données Sql, la valeur par défaut est 10 000. Facultatif sur les demandes PUT.
properties.maxWriterCount	number		Nombre maximal d’enregistreurs, actuellement, seuls 1 (enregistreur unique) et 0 (en fonction de la partition de requête) sont disponibles. Facultatif sur les demandes PUT.
properties.password	string		Mot de passe qui sera utilisé pour se connecter à la base de données Azure SQL. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.server	string		Nom du serveur SQL contenant la base de données Azure SQL. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.table	string		Nom de la table dans la base de données Azure SQL. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.user	string		Nom d’utilisateur qui sera utilisé pour se connecter à la base de données Azure SQL. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/Database		Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Décrit une source de données d’entrée de référence de base de données Azure SQL.

Nom	Type	Description
properties.database	string	Cet élément est associé à l'élément datasource. Il s'agit du nom de la base de données dans laquelle écrire la sortie.
properties.deltaSnapshotQuery	string	Cet élément est associé à l'élément datasource. Cette requête est utilisée pour extraire les modifications incrémentielles de la base de données SQL. Pour utiliser cette option, nous vous recommandons d’utiliser des tables temporelles dans Azure SQL Database.
properties.fullSnapshotQuery	string	Cet élément est associé à l'élément datasource. Cette requête est utilisée pour extraire des données de la base de données SQL.
properties.password	string	Cet élément est associé à l'élément datasource. Il s'agit du mot de passe à utiliser pour se connecter à l'instance de Base de données SQL.
properties.refreshRate	string	Cet élément est associé à l'élément datasource. Cela indique la fréquence à laquelle les données seront extraites de la base de données. Il est au format DateTime.
properties.refreshType	RefreshType	Indique le type d’option d’actualisation des données.
properties.server	string	Cet élément est associé à l'élément datasource. Il s'agit du nom du serveur contenant la base de données dans laquelle écrire.
properties.table	string	Cet élément est associé à l'élément datasource. Nom de la table dans la base de données Azure SQL.
properties.user	string	Cet élément est associé à l'élément datasource. Il s'agit du nom d'utilisateur à utiliser pour se connecter à l'instance de Base de données SQL.
type	string: Microsoft.Sql/Server/Database	Indique le type de source de données d’entrée contenant des données de référence. Obligatoire sur les demandes PUT (CreateOrReplace).

AzureSynapseOutputDataSource

Décrit une source de données de sortie Azure Synapse.

Nom	Type	Description
properties.database	string	Nom de la base de données Azure SQL. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.password	string	Mot de passe qui sera utilisé pour se connecter à la base de données Azure SQL. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.server	string	Nom du serveur SQL contenant la base de données Azure SQL. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.table	string	Nom de la table dans la base de données Azure SQL. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.user	string	Nom d’utilisateur qui sera utilisé pour se connecter à la base de données Azure SQL. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/DataWarehouse	Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

AzureTableOutputDataSource

Décrit une source de données de sortie Table Azure.

Nom	Type	Description
properties.accountKey	string	Clé de compte pour le compte Stockage Azure. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.accountName	string	Nom du compte Stockage Azure. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.batchSize	integer	Nombre de lignes à écrire dans la table Azure à la fois.
properties.columnsToRemove	string[]	En cas de spécification, chaque élément du tableau est le nom d'une colonne à supprimer (le cas échéant) des entités d'événement de sortie.
properties.partitionKey	string	Cet élément indique le nom d’une colonne de l’instruction SELECT dans la requête qui sera utilisée comme clé de partition pour la table Azure. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.rowKey	string	Cet élément indique le nom d’une colonne de l’instruction SELECT dans la requête qui sera utilisée comme clé de ligne pour la table Azure. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.table	string	Nom de la table Azure. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string: Microsoft.Storage/Table	Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

BlobOutputDataSource

Décrit une source de données de sortie d’objet blob.

Nom	Type	Valeur par défaut	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.blobPathPrefix	string		Préfixe de chemin d’objet blob.
properties.container	string		Nom d’un conteneur dans le compte de stockage associé. Ce conteneur contient les objets blob à partir duquel lire ou écrire. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.dateFormat	string		Format de date. Partout où {date} apparaît dans pathPattern, la valeur de cette propriété est utilisée comme format de date à la place.
properties.pathPattern	string		Modèle de chemin d’objet blob. Pas une expression régulière. Il représente un modèle avec lequel les noms d’objets blob seront mis en correspondance pour déterminer s’ils doivent ou non être inclus en tant qu’entrée ou sortie dans le travail. Consultez https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input ou https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output pour obtenir une explication et un exemple plus détaillés.
properties.storageAccounts	StorageAccount[]		Liste d’un ou plusieurs comptes stockage Azure. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.timeFormat	string		Format d’heure. Partout où {time} apparaît dans pathPattern, la valeur de cette propriété est utilisée comme format d’heure à la place.
type	string: Microsoft.Storage/Blob		Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

BlobReferenceInputDataSource

Décrit une source de données d’entrée d’objet blob qui contient des données de référence.

Nom	Type	Valeur par défaut	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.container	string		Nom d’un conteneur dans le compte de stockage associé. Ce conteneur contient le ou les objets blob à lire ou à écrire. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.dateFormat	string		Format de date. Partout où {date} apparaît dans pathPattern, la valeur de cette propriété est utilisée comme format de date à la place.
properties.pathPattern	string		Modèle de chemin d’accès d’objet blob. Pas une expression régulière. Il représente un modèle par rapport auquel les noms d’objets blob seront mis en correspondance pour déterminer s’ils doivent être inclus en tant qu’entrée ou sortie dans le travail. Consultez https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input ou https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output pour obtenir une explication et un exemple plus détaillés.
properties.storageAccounts	StorageAccount[]		Liste d’un ou plusieurs comptes de stockage Azure. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.timeFormat	string		Format d’heure. Partout où {time} apparaît dans pathPattern, la valeur de cette propriété est utilisée comme format d’heure à la place.
type	string: Microsoft.Storage/Blob		Indique le type de source de données d’entrée contenant des données de référence. Obligatoire sur les demandes PUT (CreateOrReplace).

BlobStreamInputDataSource

Décrit une source de données d’entrée d’objet blob qui contient des données de flux.

Nom	Type	Valeur par défaut	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.container	string		Nom d’un conteneur dans le compte de stockage associé. Ce conteneur contient le ou les objets blob à lire ou à écrire. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.dateFormat	string		Format de date. Partout où {date} apparaît dans pathPattern, la valeur de cette propriété est utilisée comme format de date à la place.
properties.pathPattern	string		Modèle de chemin d’accès d’objet blob. Pas une expression régulière. Il représente un modèle par rapport auquel les noms d’objets blob seront mis en correspondance pour déterminer s’ils doivent être inclus en tant qu’entrée ou sortie dans le travail. Consultez https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input ou https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output pour obtenir une explication et un exemple plus détaillés.
properties.sourcePartitionCount	integer		Nombre de partitions de la source de données d’entrée d’objet blob. Plage 1 - 1024.
properties.storageAccounts	StorageAccount[]		Liste d’un ou plusieurs comptes de stockage Azure. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.timeFormat	string		Format d’heure. Partout où {time} apparaît dans pathPattern, la valeur de cette propriété est utilisée comme format d’heure à la place.
type	string: Microsoft.Storage/Blob		Indique le type de source de données d’entrée contenant des données de flux. Obligatoire sur les demandes PUT (CreateOrReplace).

ClusterInfo

Propriétés associées à un cluster Stream Analytics.

Nom	Type	Description
id	string	ID de ressource du cluster.

CompatibilityLevel

Contrôle certains comportements d’exécution de la tâche de streaming.

Nom	Type	Description
1.0	string
1.2	string

Compression

Décrit comment les données d’entrée sont compressées

Nom	Type	Valeur par défaut	Description
type	CompressionType	None	Indique le type de compression utilisé par l’entrée. Obligatoire sur les demandes PUT (CreateOrReplace).

CompressionType

Indique le type de compression utilisé par l’entrée. Obligatoire sur les demandes PUT (CreateOrReplace).

Nom	Type	Description
Deflate	string
GZip	string
None	string

ContentStoragePolicy

Les valeurs valides sont JobStorageAccount et SystemAccount. Si la valeur est JobStorageAccount, l’utilisateur doit également spécifier la propriété jobStorageAccount. .

Nom	Type	Description
JobStorageAccount	string
SystemAccount	string

CsvSerialization

Décrit comment les données d’une entrée sont sérialisées ou comment les données sont sérialisées lorsqu’elles sont écrites dans une sortie au format CSV.

Nom	Type	Description
properties.encoding	Encoding	Spécifie l’encodage des données entrantes dans le cas de l’entrée et l’encodage des données sortantes dans le cas de la sortie. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.fieldDelimiter	string	Spécifie le délimiteur qui sera utilisé pour séparer les enregistrements de valeurs séparées par des virgules (CSV). Consultez https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input ou https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output pour obtenir la liste des valeurs prises en charge. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string: Csv	Indique le type de sérialisation utilisé par l’entrée ou la sortie. Obligatoire sur les demandes PUT (CreateOrReplace).

DiagnosticCondition

Condition applicable à la ressource, ou à l’ensemble du travail, qui justifie l’attention du client.

Nom	Type	Description
code	string	Code de diagnostic opaque.
message	string	Message lisible par l’homme décrivant la condition en détail. Localisé dans le Accept-Language de la demande cliente.
since	string	Horodatage UTC du moment où la condition a démarré. Les clients doivent être en mesure de trouver un événement correspondant dans le journal des opérations à cette date.

Diagnostics

Décrit les conditions applicables à l’entrée, à la sortie ou à l’ensemble du travail qui justifient l’attention du client.

Nom	Type	Description
conditions	DiagnosticCondition[]	Collection de zéro ou plusieurs conditions applicables à la ressource, ou à l’ensemble du travail, qui justifient l’attention du client.

DocumentDbOutputDataSource

Décrit une source de données de sortie DocumentDB.

Nom	Type	Description
properties.accountId	string	Nom ou ID du compte DocumentDB. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.accountKey	string	Clé de compte pour le compte DocumentDB. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.collectionNamePattern	string	Modèle de nom de collection des collections à utiliser. Le format de nom de collection peut être construit à l’aide du jeton facultatif {partition}, où les partitions commencent à 0. Pour plus d’informations, consultez la section DocumentDB de https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output . Obligatoire sur les demandes PUT (CreateOrReplace).
properties.database	string	Nom de la base de données DocumentDB. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.documentId	string	Nom du champ dans les événements de sortie utilisé pour spécifier la clé primaire sur laquelle sont basées les opérations d’insertion ou de mise à jour.
properties.partitionKey	string	Nom du champ dans les événements de sortie utilisé pour spécifier la clé de partitionnement de sortie sur les collections. Si 'collectionNamePattern' contient le jeton {partition}, cette propriété doit être spécifiée.
type	string: Microsoft.Storage/DocumentDB	Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

Encoding

Spécifie l’encodage des données entrantes dans le cas de l’entrée et l’encodage des données sortantes dans le cas de la sortie.

Nom	Type	Description
UTF8	string

Error

Représentation d’erreur courante.

Nom	Type	Description
error	Error	Propriétés de définition d’erreur.

EventHubOutputDataSource

Décrit une source de données de sortie Event Hub.

Nom	Type	Valeur par défaut	Description
authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.eventHubName	string		Nom du hub d’événements. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.partitionKey	string		Clé/colonne utilisée pour déterminer à quelle partition envoyer des données d’événement.
properties.propertyColumns	string[]		Propriétés associées à cette sortie Event Hub.
serviceBusNamespace	string		Espace de noms associé au hub d’événements souhaité, à la file d’attente Service Bus, à la rubrique Service Bus, etc. Obligatoire sur les demandes PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Clé de stratégie d’accès partagé pour la stratégie d’accès partagé spécifiée. Obligatoire sur les demandes PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nom de la stratégie d’accès partagé pour event hub, file d’attente Service Bus, rubrique Service Bus, etc. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

EventHubStreamInputDataSource

Décrit une source de données d’entrée Event Hub qui contient des données de flux.

Nom	Type	Valeur par défaut	Description
authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.consumerGroupName	string		Nom d’un groupe de consommateurs Event Hub qui doit être utilisé pour lire les événements à partir du hub d’événements. La spécification de noms de groupes de consommateurs distincts pour plusieurs entrées permet à chacune de ces entrées de recevoir les mêmes événements du hub d’événements. Si elle n’est pas spécifiée, l’entrée utilise le groupe de consommateurs par défaut d’Event Hub.
properties.eventHubName	string		Nom du hub d’événements. Obligatoire sur les demandes PUT (CreateOrReplace).
serviceBusNamespace	string		Espace de noms associé au hub d’événements souhaité, à la file d’attente Service Bus, à la rubrique Service Bus, etc. Obligatoire sur les demandes PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Clé de stratégie d’accès partagé pour la stratégie d’accès partagé spécifiée. Obligatoire sur les demandes PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nom de la stratégie d’accès partagé pour event hub, file d’attente Service Bus, rubrique Service Bus, etc. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indique le type de source de données d’entrée contenant des données de flux. Obligatoire sur les demandes PUT (CreateOrReplace).

EventHubV2OutputDataSource

Décrit une source de données de sortie Event Hub.

Nom	Type	Valeur par défaut	Description
authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.eventHubName	string		Nom du hub d’événements. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.partitionKey	string		Clé/colonne utilisée pour déterminer à quelle partition envoyer des données d’événement.
properties.propertyColumns	string[]		Propriétés associées à cette sortie Event Hub.
serviceBusNamespace	string		Espace de noms associé au hub d’événements souhaité, à la file d’attente Service Bus, à la rubrique Service Bus, etc. Obligatoire sur les demandes PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Clé de stratégie d’accès partagé pour la stratégie d’accès partagé spécifiée. Obligatoire sur les demandes PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nom de la stratégie d’accès partagé pour event hub, file d’attente Service Bus, rubrique Service Bus, etc. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Décrit une source de données d’entrée Event Hub qui contient des données de flux.

Nom	Type	Valeur par défaut	Description
authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.consumerGroupName	string		Nom d’un groupe de consommateurs Event Hub qui doit être utilisé pour lire les événements à partir du hub d’événements. La spécification de noms de groupes de consommateurs distincts pour plusieurs entrées permet à chacune de ces entrées de recevoir les mêmes événements du hub d’événements. Si elle n’est pas spécifiée, l’entrée utilise le groupe de consommateurs par défaut d’Event Hub.
properties.eventHubName	string		Nom du hub d’événements. Obligatoire sur les demandes PUT (CreateOrReplace).
serviceBusNamespace	string		Espace de noms associé au hub d’événements souhaité, à la file d’attente Service Bus, à la rubrique Service Bus, etc. Obligatoire sur les demandes PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Clé de stratégie d’accès partagé pour la stratégie d’accès partagé spécifiée. Obligatoire sur les demandes PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nom de la stratégie d’accès partagé pour event hub, file d’attente Service Bus, rubrique Service Bus, etc. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indique le type de source de données d’entrée contenant des données de flux. Obligatoire sur les demandes PUT (CreateOrReplace).

EventSerializationType

Indique le type de sérialisation utilisé par l’entrée ou la sortie. Obligatoire sur les demandes PUT (CreateOrReplace).

Nom	Type	Description
Avro	string
Csv	string
Json	string
Parquet	string

EventsOutOfOrderPolicy

Indique la stratégie à appliquer aux événements qui arrivent en désordre dans le flux d’événements d’entrée.

Nom	Type	Description
Adjust	string
Drop	string

FileReferenceInputDataSource

Décrit une source de données d’entrée de fichier qui contient des données de référence.

Nom	Type	Description
properties.path	string	Chemin d’accès au fichier.
type	string: File	Indique le type de source de données d’entrée contenant des données de référence. Obligatoire sur les demandes PUT (CreateOrReplace).

Function

Objet de fonction, contenant toutes les informations associées à la fonction nommée. Toutes les fonctions sont contenues dans un travail de streaming.

Nom	Type	Description
id	string	ID de ressource
name	string	Nom de la ressource
properties	FunctionProperties: AggregateFunctionProperties ScalarFunctionProperties	Propriétés associées à une fonction.
type	string	Type de ressource

FunctionInput

Décrit un paramètre d’entrée d’une fonction.

Nom	Type	Description
dataType	string	Type de données (Azure Stream Analytics pris en charge) du paramètre d’entrée de fonction. Une liste des types de données Azure Stream Analytics valides est décrite à l’adresse https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	Indicateur indiquant si le paramètre est un paramètre de configuration. True si ce paramètre d’entrée est censé être une constante. La valeur par défaut est false.

FunctionOutput

Décrit la sortie d’une fonction.

Nom	Type	Description
dataType	string	Type de données (Azure Stream Analytics pris en charge) de la sortie de la fonction. Une liste des types de données Azure Stream Analytics valides est décrite à l’adresse https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

Décrit une source de données de sortie du bus de message de passerelle.

Nom	Type	Description
properties.topic	string	Nom de la rubrique Service Bus.
type	string: GatewayMessageBus	Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Décrit une source de données d’entrée d’objet blob qui contient des données de flux.

Nom	Type	Description
properties.topic	string	Nom de la rubrique Service Bus.
type	string: GatewayMessageBus	Indique le type de source de données d’entrée contenant des données de flux. Obligatoire sur les demandes PUT (CreateOrReplace).

Identity

Décrit comment l’identité est vérifiée

Nom	Type	Description
principalId	string	ID du principal d’identité
tenantId	string	TenantId de l’identité
type	string	Type d’identité

Input

Objet d’entrée, contenant toutes les informations associées à l’entrée nommée. Toutes les entrées sont contenues dans un travail de streaming.

Nom	Type	Description
id	string	ID de ressource
name	string	Nom de la ressource
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Propriétés associées à une entrée. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string	Type de ressource

IoTHubStreamInputDataSource

Décrit une source de données d’entrée IoT Hub qui contient des données de flux.

Nom	Type	Description
properties.consumerGroupName	string	Nom d’un IoT Hub groupe de consommateurs qui doit être utilisé pour lire les événements de l’IoT Hub. Si elle n’est pas spécifiée, l’entrée utilise le groupe de consommateurs par défaut d’Iot Hub.
properties.endpoint	string	Le IoT Hub point de terminaison auquel se connecter (par exemple, messages/événements, messages/opérationsMonitoringEvents, etc.).
properties.iotHubNamespace	string	Nom ou URI du IoT Hub. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Clé de stratégie d’accès partagé pour la stratégie d’accès partagé spécifiée. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Nom de la stratégie d’accès partagé pour le IoT Hub. Cette stratégie doit contenir au moins l’autorisation De connexion au service. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Indique le type de source de données d’entrée contenant des données de flux. Obligatoire sur les demandes PUT (CreateOrReplace).

JavaScriptFunctionBinding

Liaison à une fonction JavaScript.

Nom	Type	Description
properties.script	string	Code JavaScript contenant une définition de fonction unique. Par exemple : 'function (x, y) { return x + y ; }'
type	string: Microsoft.StreamAnalytics/JavascriptUdf	Indique le type de liaison de fonction.

JobStorageAccount

Propriétés associées à un compte de stockage Azure avec MSI

Nom	Type	Valeur par défaut	Description
accountKey	string		Clé de compte pour le compte de stockage Azure. Obligatoire sur les demandes PUT (CreateOrReplace).
accountName	string		Nom du compte Stockage Azure. Obligatoire sur les demandes PUT (CreateOrReplace).
authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.

JobType

Décrit le type du travail. Les modes valides sont Cloud et « Edge ».

Nom	Type	Description
Cloud	string
Edge	string

JsonOutputSerializationFormat

Spécifie le format du json dans lequel la sortie sera écrite. Les valeurs actuellement prises en charge sont « lineSeparated », ce qui indique que la sortie sera mise en forme en ayant chaque objet JSON séparé par une nouvelle ligne et « tableau » indiquant que la sortie sera mise en forme en tant que tableau d’objets JSON.

Nom	Type	Description
Array	string
LineSeparated	string

JsonSerialization

Décrit comment les données d’une entrée sont sérialisées ou comment les données sont sérialisées lorsqu’elles sont écrites dans une sortie au format JSON.

Nom	Type	Description
properties.encoding	Encoding	Spécifie l’encodage des données entrantes dans le cas de l’entrée et l’encodage des données sortantes dans le cas de la sortie. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Cette propriété s’applique uniquement à la sérialisation JSON des sorties uniquement. Elle ne s’applique pas aux entrées. Cette propriété spécifie le format du JSON dans lequel la sortie sera écrite. Les valeurs actuellement prises en charge sont « lineSeparated », ce qui indique que la sortie sera mise en forme en ayant chaque objet JSON séparé par une nouvelle ligne et « tableau », indiquant que la sortie sera mise en forme en tant que tableau d’objets JSON. La valeur par défaut est 'lineSeparated' si la valeur est laissée null.
type	string: Json	Indique le type de sérialisation utilisé par l’entrée ou la sortie. Obligatoire sur les demandes PUT (CreateOrReplace).

Output

Objet de sortie, contenant toutes les informations associées à la sortie nommée. Toutes les sorties sont contenues dans un travail de streaming.

Nom	Type	Description
id	string	ID de ressource
name	string	Nom de la ressource
properties.datasource	OutputDataSource: AzureDataLakeStoreOutputDataSource AzureFunctionOutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource AzureTableOutputDataSource BlobOutputDataSource DocumentDbOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource GatewayMessageBusOutputDataSource PowerBIOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource	Décrit la source de données dans laquelle la sortie sera écrite. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.diagnostics	Diagnostics	Décrit les conditions applicables à l’entrée, à la sortie ou à l’ensemble du travail, qui justifient l’attention du client.
properties.etag	string	Balise d’entité actuelle pour la sortie. Il s’agit d’une chaîne opaque. Vous pouvez l’utiliser pour détecter si la ressource a changé entre les requêtes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour une concurrence optimiste.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Décrit comment les données d’une entrée sont sérialisées ou comment les données sont sérialisées lorsqu’elles sont écrites dans une sortie. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.sizeWindow	integer	Fenêtre de taille à laquelle limiter une sortie Stream Analytics.
properties.timeWindow	string	Délai de filtrage des sorties de travaux Stream Analytics.
type	string	Type de ressource

OutputErrorPolicy

Indique la stratégie à appliquer aux événements qui arrivent à la sortie et qui ne peuvent pas être écrits dans le stockage externe en raison d’une constitution inappropriée (valeurs de colonne manquantes ou avec une taille ou un type incorrect).

Nom	Type	Description
Drop	string
Stop	string

OutputStartMode

La valeur peut être JobStartTime, CustomTime ou LastOutputEventTime pour indiquer si le point de départ du flux d’événements de sortie doit démarrer chaque fois que le travail est démarré, démarrer à un horodatage utilisateur personnalisé spécifié via la propriété outputStartTime ou démarrer à partir de l’heure de sortie du dernier événement.

Nom	Type	Description
CustomTime	string
JobStartTime	string
LastOutputEventTime	string

ParquetSerialization

Décrit comment les données d’une entrée sont sérialisées ou comment les données sont sérialisées lorsqu’elles sont écrites dans une sortie au format Parquet.

Nom	Type	Description
type	string: Parquet	Indique le type de sérialisation utilisé par l’entrée ou la sortie. Obligatoire sur les demandes PUT (CreateOrReplace).

PowerBIOutputDataSource

Décrit une source de données de sortie Power BI.

Nom	Type	Valeur par défaut	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.dataset	string		Nom du jeu de données Power BI. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.groupId	string		ID du groupe Power BI.
properties.groupName	string		Nom du groupe Power BI. Utilisez cette propriété pour vous aider à mémoriser l’ID de groupe Power BI spécifique qui a été utilisé.
properties.refreshToken	string		Jeton d’actualisation qui peut être utilisé pour obtenir un jeton d’accès valide qui peut ensuite être utilisé pour s’authentifier auprès de la source de données. Un jeton d’actualisation valide n’est actuellement disponible que via le portail Azure. Il est recommandé de placer une valeur de chaîne factice ici lors de la création de la source de données, puis d’aller sur le portail Azure pour authentifier la source de données qui mettra à jour cette propriété avec un jeton d’actualisation valide. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.table	string		Nom de la table Power BI sous le jeu de données spécifié. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.tokenUserDisplayName	string		Nom d’affichage de l’utilisateur utilisé pour obtenir le jeton d’actualisation. Utilisez cette propriété pour vous rappeler quel utilisateur a été utilisé pour obtenir le jeton d’actualisation.
properties.tokenUserPrincipalName	string		Nom d’utilisateur principal (UPN) de l’utilisateur utilisé pour obtenir le jeton d’actualisation. Utilisez cette propriété pour vous rappeler quel utilisateur a été utilisé pour obtenir le jeton d’actualisation.
type	string: PowerBI		Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

ReferenceInputProperties

Propriétés associées à une entrée contenant des données de référence.

Nom	Type	Description
compression	Compression	Décrit comment les données d’entrée sont compressées
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Décrit une source de données d’entrée qui contient des données de référence. Obligatoire sur les demandes PUT (CreateOrReplace).
diagnostics	Diagnostics	Décrit les conditions applicables à l’entrée, à la sortie ou à l’ensemble du travail qui justifient l’attention du client.
etag	string	Balise d’entité actuelle pour l’entrée. Il s’agit d’une chaîne opaque. Vous pouvez l’utiliser pour détecter si la ressource a changé entre les requêtes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour une concurrence optimiste.
partitionKey	string	partitionKey Décrit une clé dans les données d’entrée qui est utilisée pour partitionner les données d’entrée
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Décrit comment les données d’une entrée sont sérialisées ou comment les données sont sérialisées lorsqu’elles sont écrites dans une sortie. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string: Reference	Indique si l’entrée est une source de données de référence ou de données de flux. Obligatoire sur les demandes PUT (CreateOrReplace).

RefreshType

Indique le type d’option d’actualisation des données.

Nom	Type	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

ScalarFunctionProperties

Propriétés associées à une fonction scalaire.

Nom	Type	Description
etag	string	Balise d’entité actuelle pour la fonction. Il s’agit d’une chaîne opaque. Vous pouvez l’utiliser pour détecter si la ressource a changé entre les requêtes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour une concurrence optimiste.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Liaison physique de la fonction. Par exemple, dans le cas du service web Azure Machine Learning, cela décrit le point de terminaison.
properties.inputs	FunctionInput[]	Décrit un paramètre d’entrée d’une fonction.
properties.output	FunctionOutput	Décrit la sortie d’une fonction.
type	string: Scalar	Indique le type de fonction.

ServiceBusQueueOutputDataSource

Décrit une source de données de sortie de file d’attente Service Bus.

Nom	Type	Valeur par défaut	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.propertyColumns	string[]		Tableau de chaînes des noms des colonnes de sortie à attacher aux messages Service Bus en tant que propriétés personnalisées.
properties.queueName	string		Nom de la file d’attente Service Bus. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.serviceBusNamespace	string		Espace de noms associé au hub d’événements souhaité, à la file d’attente Service Bus, à la rubrique Service Bus, etc. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Clé de stratégie d’accès partagé pour la stratégie d’accès partagé spécifiée. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		Nom de la stratégie d’accès partagé pour event hub, file d’attente Service Bus, rubrique Service Bus, etc. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.systemPropertyColumns	object		Propriétés système associées à la file d’attente Service Bus. Les propriétés système suivantes sont prises en charge : ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
type	string: Microsoft.ServiceBus/Queue		Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

ServiceBusTopicOutputDataSource

Décrit une source de données de sortie de rubrique Service Bus.

Nom	Type	Valeur par défaut	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.propertyColumns	string[]		Tableau de chaînes des noms des colonnes de sortie à attacher aux messages Service Bus en tant que propriétés personnalisées.
properties.serviceBusNamespace	string		Espace de noms associé au hub d’événements souhaité, à la file d’attente Service Bus, à la rubrique Service Bus, etc. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Clé de stratégie d’accès partagé pour la stratégie d’accès partagé spécifiée. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		Nom de la stratégie d’accès partagé pour event hub, file d’attente Service Bus, rubrique Service Bus, etc. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.systemPropertyColumns	object		Propriétés système associées à la sortie de rubrique Service Bus. Les propriétés système suivantes sont prises en charge : ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
properties.topicName	string		Nom de la rubrique Service Bus. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/Topic		Indique que le type de sortie de la source de données sera écrit dans. Obligatoire sur les demandes PUT (CreateOrReplace).

Sku

Propriétés associées à une référence SKU.

Nom	Type	Description
name	SkuName	Nom de la référence SKU. Obligatoire sur les demandes PUT (CreateOrReplace).

SkuName

Nom de la référence SKU. Obligatoire sur les demandes PUT (CreateOrReplace).

Nom	Type	Description
Standard	string

StorageAccount

Propriétés associées à un compte de stockage Azure

Nom	Type	Description
accountKey	string	Clé de compte pour le compte de stockage Azure. Obligatoire sur les demandes PUT (CreateOrReplace).
accountName	string	Nom du compte Stockage Azure. Obligatoire sur les demandes PUT (CreateOrReplace).

StreamingJob

Objet de travail de diffusion en continu, contenant toutes les informations associées au travail de diffusion en continu nommé.

Nom	Type	Description
id	string	ID de ressource complet pour la ressource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Décrit l’identité managée affectée par le système affectée à ce travail qui peut être utilisée pour s’authentifier avec des entrées et des sorties.
location	string	Emplacement géographique où réside la ressource
name	string	nom de la ressource.
properties.cluster	ClusterInfo	Cluster sur lequel les travaux de streaming s’exécuteront.
properties.compatibilityLevel	CompatibilityLevel	Contrôle certains comportements d’exécution de la tâche de streaming.
properties.contentStoragePolicy	ContentStoragePolicy	Les valeurs valides sont JobStorageAccount et SystemAccount. Si la valeur est JobStorageAccount, l’utilisateur doit également spécifier la propriété jobStorageAccount. .
properties.createdDate	string	La valeur est un horodatage UTC au format ISO-8601 indiquant quand le travail de streaming a été créé.
properties.dataLocale	string	Paramètres régionaux des données de la tâche Stream Analytics. La valeur doit être le nom d’une culture .NET prise en charge à partir de l’ensemble https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. La valeur par défaut est « en-US » si aucune n’est spécifiée.
properties.etag	string	Balise d’entité actuelle pour le travail de streaming. Il s’agit d’une chaîne opaque. Vous pouvez l’utiliser pour détecter si la ressource a changé entre les requêtes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour une concurrence optimiste.
properties.eventsLateArrivalMaxDelayInSeconds	integer	Délai maximal acceptable en secondes pendant lequel les événements arrivant en retard peuvent être inclus. La plage prise en charge est comprise entre -1 et 1814399 (20.23:59:59 jours) et -1 est utilisé pour spécifier d’attendre indéfiniment. Si la propriété est absente, elle est interprétée comme ayant la valeur -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	Délai maximal acceptable en secondes pendant lequel les événements en désordre peuvent être ajustés pour être restaurés dans l’ordre.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Indique la stratégie à appliquer aux événements qui arrivent en désordre dans le flux d’événements d’entrée.
properties.functions	Function[]	Liste d’une ou plusieurs fonctions pour le travail de streaming. La propriété name de chaque fonction est requise lors de la spécification de cette propriété dans une requête PUT. Cette propriété ne peut pas être modifié via une opération PATCH. Vous devez utiliser l’API PATCH disponible pour la transformation individuelle.
properties.inputs	Input[]	Liste d’une ou plusieurs entrées pour le travail de streaming. La propriété name pour chaque entrée est requise lors de la spécification de cette propriété dans une requête PUT. Cette propriété ne peut pas être modifié via une opération PATCH. Vous devez utiliser l’API PATCH disponible pour l’entrée individuelle.
properties.jobId	string	GUID identifiant de manière unique le travail de streaming. Ce GUID est généré lors de la création du travail de streaming.
properties.jobState	string	Décrit l’état du travail de streaming.
properties.jobStorageAccount	JobStorageAccount	Propriétés associées à un compte stockage Azure avec MSI
properties.jobType	JobType	Décrit le type du travail. Les modes valides sont Cloud et « Edge ».
properties.lastOutputEventTime	string	La valeur est un horodatage au format ISO-8601 indiquant l’heure du dernier événement de sortie du travail de diffusion en continu ou null indiquant que la sortie n’a pas encore été produite. Dans le cas de plusieurs sorties ou de plusieurs flux, la valeur la plus récente de cet ensemble est affichée.
properties.outputErrorPolicy	OutputErrorPolicy	Indique la stratégie à appliquer aux événements qui arrivent à la sortie et qui ne peuvent pas être écrits dans le stockage externe en raison d’une constitution inappropriée (valeurs de colonne manquantes ou avec une taille ou un type incorrect).
properties.outputStartMode	OutputStartMode	Cette propriété ne doit être utilisée que lorsqu’il est souhaité que le travail soit démarré immédiatement lors de la création. La valeur peut être JobStartTime, CustomTime ou LastOutputEventTime pour indiquer si le point de départ du flux d’événements de sortie doit démarrer chaque fois que le travail est démarré, démarrer à un horodatage utilisateur personnalisé spécifié via la propriété outputStartTime ou démarrer à partir de l’heure de sortie du dernier événement.
properties.outputStartTime	string	La valeur est soit un horodatage au format ISO 8601, indiquant le point de départ du flux d'événements de sortie, soit null pour indiquer que le flux d'événements de sortie démarre à chaque démarrage du travail de diffusion en continu. Cette propriété doit avoir une valeur si outputStartMode est défini sur CustomTime.
properties.outputs	Output[]	Liste d’une ou plusieurs sorties pour le travail de streaming. La propriété name pour chaque sortie est requise lors de la spécification de cette propriété dans une requête PUT. Cette propriété ne peut pas être modifié via une opération PATCH. Vous devez utiliser l’API PATCH disponible pour la sortie individuelle.
properties.provisioningState	string	Décrit la status d’approvisionnement du travail de streaming.
properties.sku	Sku	Décrit la référence SKU du travail de streaming. Obligatoire sur les demandes PUT (CreateOrReplace).
properties.transformation	Transformation	Indique la requête et le nombre d’unités de streaming à utiliser pour le travail de streaming. La propriété name de la transformation est requise lors de la spécification de cette propriété dans une requête PUT. Cette propriété ne peut pas être modifié via une opération PATCH. Vous devez utiliser l’API PATCH disponible pour la transformation individuelle.
tags	object	Balises de ressource.
type	string	Type de la ressource. Ex- Microsoft.Compute/virtualMachines ou Microsoft.Storage/storageAccounts.

StreamInputProperties

Propriétés associées à une entrée contenant des données de flux.

Nom	Type	Description
compression	Compression	Décrit comment les données d’entrée sont compressées
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Décrit une source de données d’entrée qui contient des données de flux. Obligatoire sur les demandes PUT (CreateOrReplace).
diagnostics	Diagnostics	Décrit les conditions applicables à l’entrée, à la sortie ou à l’ensemble du travail qui justifient l’attention du client.
etag	string	Balise d’entité actuelle pour l’entrée. Il s’agit d’une chaîne opaque. Vous pouvez l’utiliser pour détecter si la ressource a changé entre les requêtes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour une concurrence optimiste.
partitionKey	string	partitionKey Décrit une clé dans les données d’entrée qui est utilisée pour partitionner les données d’entrée
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Décrit comment les données d’une entrée sont sérialisées ou comment les données sont sérialisées lorsqu’elles sont écrites dans une sortie. Obligatoire sur les demandes PUT (CreateOrReplace).
type	string: Stream	Indique si l’entrée est une source de données de référence ou de données de flux. Obligatoire sur les demandes PUT (CreateOrReplace).

Transformation

Objet de transformation, contenant toutes les informations associées à la transformation nommée. Toutes les transformations sont contenues dans un travail de streaming.

Nom	Type	Valeur par défaut	Description
id	string		ID de ressource
name	string		Nom de la ressource
properties.etag	string		Balise d’entité actuelle pour la transformation. Il s’agit d’une chaîne opaque. Vous pouvez l’utiliser pour détecter si la ressource a changé entre les requêtes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour une concurrence optimiste.
properties.query	string		Spécifie la requête qui sera exécutée dans le travail de streaming. Vous pouvez en savoir plus sur le langage de requête Stream Analytics (SAQL) ici : https://msdn.microsoft.com/library/azure/dn834998 . Obligatoire sur les demandes PUT (CreateOrReplace).
properties.streamingUnits	integer	3	Indique le nombre d’unités de streaming que la tâche de streaming utilise.
properties.validStreamingUnits	integer[]		Spécifie les unités de diffusion en continu valides qu’un travail de streaming peut mettre à l’échelle.
type	string		Type de ressource