Streaming Jobs - Create Or Replace

Service:

Stream Analytics

Version d'API:

2020-03-01

Crée un travail de diffusion en continu ou remplace un travail de diffusion en continu déjà 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 diffusion en continu.
resourceGroupName	path	True	string minLength: 1 maxLength: 90 pattern: ^[-\w\._\(\)]+$	Nom du groupe de ressources. Le nom ne respecte pas la casse.
subscriptionId	path	True	string minLength: 1	ID de l’abonnement cible.
api-version	query	True	string minLength: 1	Version de l’API à utiliser pour cette opération.

En-tête de la demande

Nom	Obligatoire	Type	Description
If-Match		string	ETag de la tâche de diffusion en continu. 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 la valeur « * » pour autoriser la création d’un nouveau 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 en cas d’échec de la condition.

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 diffusion en continu s’exécutent.
properties.compatibilityLevel	CompatibilityLevel	Contrôle certains comportements d’exécution du travail 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 de données du travail 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 valeur n’est spécifiée.
properties.eventsLateArrivalMaxDelayInSeconds	integer (int32)	Délai maximal tolérable en secondes où les événements arrivant en retard peuvent être inclus. La plage prise en charge est -1 à 1814399 (20.23:59:59:59 jours) et -1 est utilisée pour spécifier l’attente indéfiniment. Si la propriété est absente, elle est interprétée comme ayant la valeur -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer (int32)	Délai maximal tolérable en secondes où les événements hors ordre peuvent être ajustés pour être de retour dans l’ordre.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Indique la stratégie à appliquer aux événements qui arrivent dans le flux d’événements d’entrée.
properties.functions	Function[]	Liste d’une ou de plusieurs fonctions pour la tâche de diffusion en continu. 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 modifiable via une opération PATCH. Vous devez utiliser l’API PATCH disponible pour la transformation individuelle.
properties.inputs	Input[]	Liste d’une ou de plusieurs entrées dans la tâche de diffusion en continu. 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 modifiable 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 ne peuvent pas être écrits dans le stockage externe en raison d’une mauvaise forme (valeurs de colonne manquantes, valeurs de colonne de type ou de taille incorrectes).
properties.outputStartMode	OutputStartMode	Cette propriété ne doit être utilisée que lorsque vous souhaitez 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 la dernière heure de sortie de l’événement.
properties.outputStartTime	string (date-time)	La valeur est soit un horodatage au format ISO-8601 qui indique 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 fois que la tâche de diffusion en continu est démarrée. Cette propriété doit avoir une valeur si outputStartMode est défini sur CustomTime.
properties.outputs	Output[]	Liste d’une ou de plusieurs sorties pour la tâche de diffusion en continu. 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 modifiable 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 requêtes PUT (CreateOrReplace).
properties.transformation	Transformation	Indique la requête et le nombre d’unités de diffusion en continu à utiliser pour la tâche de diffusion en continu. 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 modifiable 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é correctement créé ou remplacé. En-têtes ETag: string
201 Created	StreamingJob	Le travail de diffusion en continu a été correctement 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", "fakeTokenPlaceholder", "key3", "fakeTokenPlaceholder", "randomKey",
                "fakeTokenPlaceholder"))
            .withSku(new Sku().withName(SkuName.STANDARD)).withEventsOutOfOrderPolicy(EventsOutOfOrderPolicy.DROP)
            .withOutputErrorPolicy(OutputErrorPolicy.DROP).withEventsOutOfOrderMaxDelayInSeconds(0)
            .withEventsLateArrivalMaxDelayInSeconds(5).withDataLocale(
                "en-US")
            .withCompatibilityLevel(CompatibilityLevel.ONE_ZERO)
            .withInputs(Arrays.asList(new InputInner().withProperties(new StreamInputProperties()
                .withSerialization(new JsonSerialization().withEncoding(Encoding.UTF8))
                .withDatasource(new BlobStreamInputDataSource()
                    .withStorageAccounts(Arrays.asList(
                        new StorageAccount().withAccountName("yourAccountName").withAccountKey("fakeTokenPlaceholder")))
                    .withContainer("containerName").withPathPattern("")))
                .withName("inputtest")))
            .withTransformation(new TransformationInner().withName("transformationtest").withStreamingUnits(1)
                .withQuery("Select Id, Name from inputtest"))
            .withOutputs(Arrays.asList(new OutputInner().withName("outputtest").withDatasource(
                new AzureSqlDatabaseOutputDataSource().withServer("serverName").withDatabase("databaseName")
                    .withUser("<user>").withPassword("fakeTokenPlaceholder").withTable("tableName"))))
            .withFunctions(Arrays.asList()).create();
    }

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

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

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", "fakeTokenPlaceholder", "key3", "fakeTokenPlaceholder", "randomKey",
                "fakeTokenPlaceholder"))
            .withSku(new Sku().withName(SkuName.STANDARD)).withEventsOutOfOrderPolicy(EventsOutOfOrderPolicy.DROP)
            .withOutputErrorPolicy(OutputErrorPolicy.DROP).withEventsOutOfOrderMaxDelayInSeconds(5)
            .withEventsLateArrivalMaxDelayInSeconds(16).withDataLocale("en-US")
            .withCompatibilityLevel(CompatibilityLevel.ONE_ZERO).withInputs(Arrays.asList())
            .withOutputs(Arrays.asList()).withFunctions(Arrays.asList()).create();
    }

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

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

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 du 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 du 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 de 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 du travail 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 requêtes 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 justifient l’attention du client.
Diagnostics	Décrit les conditions applicables à l’entrée, à la sortie ou au travail global, 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 d’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 requêtes PUT (CreateOrReplace).
EventsOutOfOrderPolicy	Indique la stratégie à appliquer aux événements qui arrivent 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 Message Bus 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 » indiquant que la sortie sera mise en forme en ayant chaque objet JSON séparé par une nouvelle ligne et « array » 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 ne peuvent pas être écrits dans le stockage externe en raison d’une mauvaise forme (valeurs de colonne manquantes, valeurs de colonne de type ou de taille incorrectes).
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 la dernière heure de sortie de l’é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 requêtes 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 à la tâche de diffusion en continu nommée.
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

Object

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 demandes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour l’accès concurrentiel 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

Énumération

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

Valeur	Description
ConnectionString
Msi
UserToken

AvroSerialization

Object

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 requêtes PUT (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Object

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 requêtes PUT (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.
properties.dateFormat	string		Format de date. Chaque fois que {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 requêtes 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 est actuellement disponible uniquement 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’accéder au portail Azure pour authentifier la source de données qui mettra à jour cette propriété avec un jeton d’actualisation valide. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.tenantId	string		ID de locataire de l’utilisateur utilisé pour obtenir le jeton d’actualisation. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.timeFormat	string		Format d’heure. Chaque fois que {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 souvenir de l’utilisateur 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 souvenir de l’utilisateur utilisé pour obtenir le jeton d’actualisation.
type	string: Microsoft.DataLake/Accounts		Indique que le type de sortie de la source de données est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

AzureFunctionOutputDataSource

Object

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é pour 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 vous permet de définir la taille maximale de chaque lot de sortie envoyé à votre fonction Azure. L’unité d’entrée est en octets. Par défaut, cette valeur est de 262 144 octets (256 Ko).
type	string: Microsoft.AzureFunction	Indique que le type de sortie de la source de données est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

Object

Liaison à un service web Azure Machine Learning.

Nom	Type	Description
properties.apiKey	string	Clé API utilisée pour s’authentifier avec Request-Response point de terminaison.
properties.batchSize	integer (int32)	Nombre compris entre 1 et 1 0000 décrivant le nombre maximal de lignes pour chaque requête d’exécution Azure ML RRS. La valeur par défaut est 1 000.
properties.endpoint	string	Le Request-Response exécuter le point de terminaison du service web Azure Machine Learning. En savoir plus 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 du service web Azure Machine Learning.
type	string: Microsoft.MachineLearning/WebService	Indique le type de liaison de fonction.

AzureMachineLearningWebServiceInputColumn

Object

Décrit une colonne d’entrée pour le point de terminaison du 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 de types de données Azure Machine Learning valides est décrite à https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
mapTo	integer (int32)	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

Object

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

Object

Décrit une colonne de sortie pour le point de terminaison du 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 de types de données Azure Machine Learning valides est décrite à https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
name	string	Nom de la colonne de sortie.

AzureSqlDatabaseOutputDataSource

Object

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 requêtes 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 seulement 1(enregistreur unique) et 0(basé sur 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 requêtes PUT (CreateOrReplace).
properties.server	string		Nom du serveur SQL contenant la base de données Azure SQL. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.table	string		Nom de la table dans la base de données Azure SQL. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.user	string		Nom d’utilisateur qui sera utilisé pour se connecter à la base de données Azure SQL. Obligatoire sur les requêtes PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/Database		Indique que le type de sortie de la source de données est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Object

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 de source de données. Il s’agit du nom de la base de données dans laquelle la sortie sera écrite.
properties.deltaSnapshotQuery	string	Cet élément est associé à l’élément de source de données. 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 de source de données. 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 de source de données. Il s’agit du mot de passe qui sera utilisé pour se connecter à l’instance sql Database.
properties.refreshRate	string	Cet élément est associé à l’élément de source de données. Cela indique la fréquence à laquelle les données seront extraites de la base de données. Il s’agit du 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 de source de données. Il s’agit du nom du serveur qui contient la base de données dans laquelle il sera écrit.
properties.table	string	Cet élément est associé à l’élément de source de données. Nom de la table dans la base de données Azure SQL..
properties.user	string	Cet élément est associé à l’élément de source de données. Il s’agit du nom d’utilisateur qui sera utilisé pour se connecter à l’instance sql Database.
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 requêtes PUT (CreateOrReplace).

AzureSynapseOutputDataSource

Object

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 requêtes PUT (CreateOrReplace).
properties.password	string	Mot de passe qui sera utilisé pour se connecter à la base de données Azure SQL. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.server	string	Nom du serveur SQL contenant la base de données Azure SQL. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.table	string	Nom de la table dans la base de données Azure SQL. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.user	string	Nom d’utilisateur qui sera utilisé pour se connecter à la base de données Azure SQL. Obligatoire sur les requêtes PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/DataWarehouse	Indique que le type de sortie de la source de données est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

AzureTableOutputDataSource

Object

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

Nom	Type	Description
properties.accountKey	string	Clé de compte pour le compte stockage Azure. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.accountName	string	Nom du compte stockage Azure. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.batchSize	integer (int32)	Nombre de lignes à écrire dans la table Azure à la fois.
properties.columnsToRemove	string[]	Si spécifié, 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 requêtes 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 requêtes PUT (CreateOrReplace).
properties.table	string	Nom de la table Azure. Obligatoire sur les requêtes PUT (CreateOrReplace).
type	string: Microsoft.Storage/Table	Indique que le type de sortie de la source de données est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

BlobOutputDataSource

Object

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’accès d’objet blob.
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 requêtes PUT (CreateOrReplace).
properties.dateFormat	string		Format de date. Chaque fois que {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 comme 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 de plusieurs comptes de stockage Azure. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.timeFormat	string		Format d’heure. Chaque fois que {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 est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

BlobReferenceInputDataSource

Object

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 requêtes PUT (CreateOrReplace).
properties.dateFormat	string		Format de date. Chaque fois que {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 comme 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 de plusieurs comptes de stockage Azure. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.timeFormat	string		Format d’heure. Chaque fois que {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 requêtes PUT (CreateOrReplace).

BlobStreamInputDataSource

Object

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 requêtes PUT (CreateOrReplace).
properties.dateFormat	string		Format de date. Chaque fois que {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 comme 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 (int32)		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 de plusieurs comptes de stockage Azure. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.timeFormat	string		Format d’heure. Chaque fois que {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 requêtes PUT (CreateOrReplace).

ClusterInfo

Object

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

Nom	Type	Description
id	string	ID de ressource du cluster.

CompatibilityLevel

Énumération

Contrôle certains comportements d’exécution du travail de streaming.

Valeur	Description
1.0
1.2

Compression

Object

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 requêtes PUT (CreateOrReplace).

CompressionType

Énumération

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

Valeur	Description
Deflate
GZip
None

ContentStoragePolicy

Énumération

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

Valeur	Description
JobStorageAccount
SystemAccount

CsvSerialization

Object

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 d’entrée et l’encodage des données sortantes dans le cas de la sortie. Obligatoire sur les requêtes 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 requêtes PUT (CreateOrReplace).
type	string: Csv	Indique le type de sérialisation utilisé par l’entrée ou la sortie. Obligatoire sur les requêtes PUT (CreateOrReplace).

DiagnosticCondition

Object

Condition applicable à la ressource, ou à l’ensemble du travail, qui justifient 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 la Accept-Language de la requête cliente.
since	string	Horodatage UTC du démarrage de la condition. Les clients doivent être en mesure de trouver un événement correspondant dans le journal des opérations à ce stade.

Diagnostics

Object

Décrit les conditions applicables à l’entrée, à la sortie ou au travail global, 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

Object

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 requêtes PUT (CreateOrReplace).
properties.accountKey	string	Clé de compte pour le compte DocumentDB. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.collectionNamePattern	string	Modèle de nom de collection pour les collections à utiliser. Le format du nom de collection peut être construit à l’aide du jeton {partition} facultatif, où les partitions commencent à partir de 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 requêtes PUT (CreateOrReplace).
properties.database	string	Nom de la base de données DocumentDB. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.documentId	string	Nom du champ dans les événements de sortie utilisés pour spécifier la clé primaire sur laquelle les opérations d’insertion ou de mise à jour sont basées.
properties.partitionKey	string	Nom du champ dans les événements de sortie utilisés pour spécifier la clé de partitionnement de la sortie entre 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 est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

Encoding

Énumération

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

Valeur	Description
UTF8

Error

Object

Représentation d’erreur courante.

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

EventHubOutputDataSource

Object

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 requêtes PUT (CreateOrReplace).
properties.partitionKey	string		Clé/colonne utilisée pour déterminer la partition à laquelle 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 requêtes 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 requêtes 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 requêtes PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indique que le type de sortie de la source de données est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

EventHubStreamInputDataSource

Object

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 à partir du hub d’événements. Si elle n’est pas spécifiée, l’entrée utilise le groupe de consommateurs par défaut du hub d’événements.
properties.eventHubName	string		Nom du hub d’événements. Obligatoire sur les requêtes 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 requêtes 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 requêtes 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 requêtes 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 requêtes PUT (CreateOrReplace).

EventHubV2OutputDataSource

Object

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 requêtes PUT (CreateOrReplace).
properties.partitionKey	string		Clé/colonne utilisée pour déterminer la partition à laquelle 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 requêtes 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 requêtes 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 requêtes PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indique que le type de sortie de la source de données est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Object

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 à partir du hub d’événements. Si elle n’est pas spécifiée, l’entrée utilise le groupe de consommateurs par défaut du hub d’événements.
properties.eventHubName	string		Nom du hub d’événements. Obligatoire sur les requêtes 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 requêtes 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 requêtes 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 requêtes 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 requêtes PUT (CreateOrReplace).

EventSerializationType

Énumération

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

Valeur	Description
Avro
Csv
Json
Parquet

EventsOutOfOrderPolicy

Énumération

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

Valeur	Description
Adjust
Drop

FileReferenceInputDataSource

Object

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 du 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 requêtes PUT (CreateOrReplace).

Function

Object

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

Object

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

Nom	Type	Description
dataType	string	Type de données (pris en charge par Azure Stream Analytics) du paramètre d’entrée de fonction. Une liste de types de données Azure Stream Analytics valides est décrite à 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

Object

Décrit la sortie d’une fonction.

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

GatewayMessageBusOutputDataSource

Object

Décrit une source de données de sortie Message Bus 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 est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Object

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 requêtes PUT (CreateOrReplace).

Identity

Object

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

Nom	Type	Description
principalId	string	ID du principal d’identité
tenantId	string	Id de locataire d’identité
type	string	Type d’identité

Input

Object

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 requêtes PUT (CreateOrReplace).
type	string	Type de ressource

IoTHubStreamInputDataSource

Object

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 groupe de consommateurs IoT Hub qui doit être utilisé pour lire des événements à partir de l’IoT Hub. Si elle n’est pas spécifiée, l’entrée utilise le groupe de consommateurs par défaut du hub Iot.
properties.endpoint	string	Point de terminaison IoT Hub auquel se connecter (par exemple, messages/événements, messages/operationsMonitoringEvents, etc.).
properties.iotHubNamespace	string	Nom ou URI du hub IoT. Obligatoire sur les requêtes 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 requêtes PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Nom de la stratégie d’accès partagé pour IoT Hub. Cette stratégie doit contenir au moins l’autorisation de connexion au service. Obligatoire sur les requêtes 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 requêtes PUT (CreateOrReplace).

JavaScriptFunctionBinding

Object

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

Object

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 stockage Azure. Obligatoire sur les requêtes PUT (CreateOrReplace).
accountName	string		Nom du compte stockage Azure. Obligatoire sur les requêtes PUT (CreateOrReplace).
authenticationMode	AuthenticationMode	ConnectionString	Mode d’authentification.

JobType

Énumération

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

Valeur	Description
Cloud
Edge

JsonOutputSerializationFormat

Énumération

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

Valeur	Description
Array
LineSeparated

JsonSerialization

Object

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 d’entrée et l’encodage des données sortantes dans le cas de la sortie. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Cette propriété s’applique uniquement à la sérialisation JSON des sorties uniquement. Il n’est pas applicable 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 » indiquant que la sortie sera mise en forme en ayant chaque objet JSON séparé par une nouvelle ligne et « array » 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 null gauche.
type	string: Json	Indique le type de sérialisation utilisé par l’entrée ou la sortie. Obligatoire sur les requêtes PUT (CreateOrReplace).

Output

Object

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 requêtes PUT (CreateOrReplace).
properties.diagnostics	Diagnostics	Décrit les conditions applicables à l’entrée, à la sortie ou au travail global, 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 demandes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour l’accès concurrentiel 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 requêtes PUT (CreateOrReplace).
properties.sizeWindow	integer (int32)	Fenêtre de taille à laquelle limiter une sortie Stream Analytics.
properties.timeWindow	string	Délai de filtrage des sorties de travail Stream Analytics.
type	string	Type de ressource

OutputErrorPolicy

Énumération

Indique la stratégie à appliquer aux événements qui arrivent à la sortie et ne peuvent pas être écrits dans le stockage externe en raison d’une mauvaise forme (valeurs de colonne manquantes, valeurs de colonne de type ou de taille incorrectes).

Valeur	Description
Drop
Stop

OutputStartMode

Énumération

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 la dernière heure de sortie de l’événement.

Valeur	Description
CustomTime
JobStartTime
LastOutputEventTime

ParquetSerialization

Object

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 requêtes PUT (CreateOrReplace).

PowerBIOutputDataSource

Object

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 requêtes PUT (CreateOrReplace).
properties.groupId	string		ID du groupe Power BI.
properties.groupName	string		Nom du groupe Power BI. Utilisez cette propriété pour vous rappeler l’ID de groupe Power BI spécifique 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 est actuellement disponible uniquement 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’accéder au portail Azure pour authentifier la source de données qui mettra à jour cette propriété avec un jeton d’actualisation valide. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.table	string		Nom de la table Power BI sous le jeu de données spécifié. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.tokenUserDisplayName	string		Nom d’affichage de l’utilisateur utilisé pour obtenir le jeton d’actualisation. Utilisez cette propriété pour vous souvenir de l’utilisateur 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 souvenir de l’utilisateur utilisé pour obtenir le jeton d’actualisation.
type	string: PowerBI		Indique que le type de sortie de la source de données est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

ReferenceInputProperties

Object

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 requêtes PUT (CreateOrReplace).
diagnostics	Diagnostics	Décrit les conditions applicables à l’entrée, à la sortie ou au travail global, 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 demandes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour l’accès concurrentiel optimiste.
partitionKey	string	partitionKey Décrit une clé dans les données d’entrée utilisées 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 requêtes 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 requêtes PUT (CreateOrReplace).

RefreshType

Énumération

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

Valeur	Description
RefreshPeriodicallyWithDelta
RefreshPeriodicallyWithFull
Static

ScalarFunctionProperties

Object

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 demandes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour l’accès concurrentiel 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

Object

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 requêtes 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 requêtes 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 requêtes 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 requêtes 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 est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

ServiceBusTopicOutputDataSource

Object

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 requêtes 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 requêtes 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 requêtes 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 requêtes PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/Topic		Indique que le type de sortie de la source de données est écrit. Obligatoire sur les requêtes PUT (CreateOrReplace).

Sku

Object

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 requêtes PUT (CreateOrReplace).

SkuName

Énumération

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

Valeur	Description
Standard

StorageAccount

Object

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

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

StreamingJob

Object

Objet de travail de diffusion en continu contenant toutes les informations associées à la tâche de diffusion en continu nommée.

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 diffusion en continu s’exécutent.
properties.compatibilityLevel	CompatibilityLevel	Contrôle certains comportements d’exécution du travail 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 (date-time)	La valeur est un horodatage UTC au format ISO-8601 indiquant quand la tâche de diffusion en continu a été créée.
properties.dataLocale	string	Paramètres régionaux de données du travail 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 valeur n’est spécifiée.
properties.etag	string	Balise d’entité actuelle pour la tâche de diffusion en continu. Il s’agit d’une chaîne opaque. Vous pouvez l’utiliser pour détecter si la ressource a changé entre les demandes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour l’accès concurrentiel optimiste.
properties.eventsLateArrivalMaxDelayInSeconds	integer (int32)	Délai maximal tolérable en secondes où les événements arrivant en retard peuvent être inclus. La plage prise en charge est -1 à 1814399 (20.23:59:59:59 jours) et -1 est utilisée pour spécifier l’attente indéfiniment. Si la propriété est absente, elle est interprétée comme ayant la valeur -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer (int32)	Délai maximal tolérable en secondes où les événements hors ordre peuvent être ajustés pour être de retour dans l’ordre.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Indique la stratégie à appliquer aux événements qui arrivent dans le flux d’événements d’entrée.
properties.functions	Function[]	Liste d’une ou de plusieurs fonctions pour la tâche de diffusion en continu. 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 modifiable via une opération PATCH. Vous devez utiliser l’API PATCH disponible pour la transformation individuelle.
properties.inputs	Input[]	Liste d’une ou de plusieurs entrées dans la tâche de diffusion en continu. 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 modifiable 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 la tâche de diffusion en continu. Ce GUID est généré lors de la création du travail de diffusion en continu.
properties.jobState	string	Décrit l’état du travail de diffusion en continu.
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.lastOutputEventTime	string (date-time)	La valeur est un horodatage au format ISO-8601 indiquant l’heure de la dernière sortie du travail de diffusion en continu ou null indiquant que la sortie n’a pas encore été produite. En cas de sorties multiples ou de flux multiples, cela affiche la valeur la plus récente de cet ensemble.
properties.outputErrorPolicy	OutputErrorPolicy	Indique la stratégie à appliquer aux événements qui arrivent à la sortie et ne peuvent pas être écrits dans le stockage externe en raison d’une mauvaise forme (valeurs de colonne manquantes, valeurs de colonne de type ou de taille incorrectes).
properties.outputStartMode	OutputStartMode	Cette propriété ne doit être utilisée que lorsque vous souhaitez 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 la dernière heure de sortie de l’événement.
properties.outputStartTime	string (date-time)	La valeur est soit un horodatage au format ISO-8601 qui indique 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 fois que la tâche de diffusion en continu est démarrée. Cette propriété doit avoir une valeur si outputStartMode est défini sur CustomTime.
properties.outputs	Output[]	Liste d’une ou de plusieurs sorties pour la tâche de diffusion en continu. 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 modifiable via une opération PATCH. Vous devez utiliser l’API PATCH disponible pour la sortie individuelle.
properties.provisioningState	string	Décrit l’état d’approvisionnement du travail de diffusion en continu.
properties.sku	Sku	Décrit la référence SKU du travail de streaming. Obligatoire sur les requêtes PUT (CreateOrReplace).
properties.transformation	Transformation	Indique la requête et le nombre d’unités de diffusion en continu à utiliser pour la tâche de diffusion en continu. 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 modifiable 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

Object

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 requêtes PUT (CreateOrReplace).
diagnostics	Diagnostics	Décrit les conditions applicables à l’entrée, à la sortie ou au travail global, 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 demandes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour l’accès concurrentiel optimiste.
partitionKey	string	partitionKey Décrit une clé dans les données d’entrée utilisées 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 requêtes 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 requêtes PUT (CreateOrReplace).

Transformation

Object

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 demandes. Vous pouvez également l’utiliser dans les en-têtes If-Match ou If-None-Match pour les opérations d’écriture pour l’accès concurrentiel optimiste.
properties.query	string		Spécifie la requête qui sera exécutée dans la tâche de diffusion en continu. 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 requêtes PUT (CreateOrReplace).
properties.streamingUnits	integer (int32)	3	Spécifie le nombre d’unités de diffusion en continu que la tâche de diffusion en continu utilise.
properties.validStreamingUnits	integer[] (int32)		Spécifie les unités de diffusion en continu valides vers laquelle un travail de diffusion en continu peut être mis à l’échelle.
type	string		Type de ressource