Streaming Jobs - Create Or Replace

Servizio:

Stream Analytics

Versione API:

2020-03-01

Crea un processo di streaming o sostituisce un processo di streaming già esistente.

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

Parametri dell'URI

Nome	In	Necessario	Tipo	Descrizione
jobName	path	True	string	Nome del processo di streaming.
resourceGroupName	path	True	string	Nome del gruppo di risorse. Per il nome non viene fatta distinzione tra maiuscole e minuscole. Criterio di espressione regolare: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	ID della sottoscrizione di destinazione.
api-version	query	True	string	Versione dell'API da usare per questa operazione.

Intestazione della richiesta

Nome	Necessario	Tipo	Descrizione
If-Match		string	ETag del processo di streaming. Omettere questo valore per sovrascrivere sempre il set di record corrente. Specificare il valore ETag visualizzato per evitare di sovrascrivere accidentalmente le modifiche simultanee.
If-None-Match		string	Impostare su "*" per consentire la creazione di un nuovo processo di streaming, ma per impedire l'aggiornamento di un set di record esistente. Altri valori generano una risposta di pre-condizione 412 Non riuscita.

Corpo della richiesta

Nome	Tipo	Descrizione
identity	Identity	Descrive l'identità gestita assegnata dal sistema assegnata a questo processo che può essere usata per eseguire l'autenticazione con input e output.
location	string	Posizione geografica in cui risiede la risorsa
properties.cluster	ClusterInfo	Cluster in cui verranno eseguiti i processi di streaming.
properties.compatibilityLevel	CompatibilityLevel	Controlla determinati comportamenti di runtime del processo di streaming.
properties.contentStoragePolicy	ContentStoragePolicy	I valori validi sono JobStorageAccount e SystemAccount. Se impostato su JobStorageAccount, è necessario che l'utente specifichi anche la proprietà jobStorageAccount. .
properties.dataLocale	string	Impostazioni locali dei dati del processo di analisi di flusso. Il valore deve essere il nome di impostazioni cultura .NET supportate dal set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Il valore predefinito è "en-US" se non è specificato alcun valore.
properties.eventsLateArrivalMaxDelayInSeconds	integer	Ritardo massimo tollerabile in secondi in cui potrebbero essere inclusi gli eventi che arrivano in ritardo. L'intervallo supportato è da -1 a 1814399 (20.23:59:59 giorni) e -1 viene usato per specificare l'attesa per un periodo illimitato. Se la proprietà è assente, viene interpretata per avere un valore pari a -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	Ritardo massimo tollerabile in secondi in cui è possibile regolare gli eventi non in ordine.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Indica il criterio da applicare agli eventi che arrivano non in ordine nel flusso di eventi di input.
properties.functions	Function[]	Elenco di una o più funzioni per il processo di streaming. La proprietà name per ogni funzione è necessaria quando si specifica questa proprietà in una richiesta PUT. Questa proprietà non può essere modificata tramite un'operazione PATCH. È necessario usare l'API PATCH disponibile per la singola trasformazione.
properties.inputs	Input[]	Elenco di uno o più input per il processo di streaming. La proprietà name per ogni input è necessaria quando si specifica questa proprietà in una richiesta PUT. Questa proprietà non può essere modificata tramite un'operazione PATCH. È necessario usare l'API PATCH disponibile per il singolo input.
properties.jobStorageAccount	JobStorageAccount	Proprietà associate a un account di archiviazione di Azure con l'identità del servizio gestito
properties.jobType	JobType	Descrive il tipo di processo. Le modalità valide sono Cloud e 'Edge'.
properties.outputErrorPolicy	OutputErrorPolicy	Indica il criterio da applicare agli eventi che arrivano all'output e non possono essere scritti nella risorsa di archiviazione esterna a causa di un formato non valido (valori di colonna mancanti, valori di colonna di tipo o dimensioni errati).
properties.outputStartMode	OutputStartMode	Questa proprietà deve essere utilizzata solo quando si desidera che il processo venga avviato immediatamente al momento della creazione. Il valore può essere JobStartTime, CustomTime o LastOutputEventTime per indicare se il punto iniziale del flusso di eventi di output deve essere avviato ogni volta che il processo viene avviato, iniziare a un timestamp utente personalizzato specificato tramite la proprietà outputStartTime o iniziare dall'ora dell'ultimo output dell'evento.
properties.outputStartTime	string	Il valore è un timestamp in formato ISO-8601 che specifica il punto di partenza del flusso di eventi di output oppure null, a indicare che il flusso di eventi di output inizierà ogni volta che viene avviato il processo di streaming. Questa proprietà deve avere un valore se outputStartMode è impostato su CustomTime.
properties.outputs	Output[]	Elenco di uno o più output per il processo di streaming. La proprietà name per ogni output è necessaria quando si specifica questa proprietà in una richiesta PUT. Questa proprietà non può essere modificata tramite un'operazione PATCH. È necessario usare l'API PATCH disponibile per il singolo output.
properties.sku	Sku	Descrive lo SKU del processo di streaming. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.transformation	Transformation	Indica la query e il numero di unità di streaming da usare per il processo di streaming. La proprietà name della trasformazione è necessaria quando si specifica questa proprietà in una richiesta PUT. Questa proprietà non può essere modificata tramite un'operazione PATCH. È necessario usare l'API PATCH disponibile per la singola trasformazione.
tags	object	Tag delle risorse.

Risposte

Nome	Tipo	Descrizione
200 OK	StreamingJob	Il processo di streaming è stato creato o sostituito correttamente. Intestazioni ETag: string
201 Created	StreamingJob	Il processo di streaming è stato creato o sostituito correttamente. Intestazioni ETag: string
Other Status Codes	Error	Errore.

Sicurezza

azure_auth

Flusso OAuth2 di Azure Active Directory

Tipo: oauth2
Flow: implicit
URL di autorizzazione: https://login.microsoftonline.com/common/oauth2/authorize

Ambiti

Nome	Descrizione
user_impersonation	rappresentare l'account utente

Esempio

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)

Esempio di richiesta

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

Risposta di esempio

Codice di stato:

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

Codice di stato:

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)

Esempio di richiesta

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

Risposta di esempio

Codice di stato:

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

Codice di stato:

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

Definizioni

Nome	Descrizione
AggregateFunctionProperties	Proprietà associate a una funzione di aggregazione.
AuthenticationMode	Modalità di autenticazione. Le modalità valide sono ConnectionString, Msi e 'UserToken'.
AvroSerialization	Viene descritto come serializzare i dati di un input o come serializzare i dati quando vengono scritti in un output in formato Avro.
AzureDataLakeStoreOutputDataSource	Descrive un'origine dati di output di Azure Data Lake Store.
AzureFunctionOutputDataSource	Definisce i metadati di AzureFunctionOutputDataSource
AzureMachineLearningWebServiceFunctionBinding	Associazione a un servizio Web di Azure Machine Learning.
AzureMachineLearningWebServiceInputColumn	Descrive una colonna di input per l'endpoint del servizio Web di Azure Machine Learning.
AzureMachineLearningWebServiceInputs	Input per l'endpoint del servizio Web di Azure Machine Learning.
AzureMachineLearningWebServiceOutputColumn	Descrive una colonna di output per l'endpoint del servizio Web di Azure Machine Learning.
AzureSqlDatabaseOutputDataSource	Descrive un'origine dati di output del database Azure SQL.
AzureSqlReferenceInputDataSource	Descrive un'origine dati di input di riferimento al database di Azure SQL.
AzureSynapseOutputDataSource	Descrive un'origine dati di output Azure Synapse.
AzureTableOutputDataSource	Descrive un'origine dati di output tabella di Azure.
BlobOutputDataSource	Descrive un'origine dati di output BLOB.
BlobReferenceInputDataSource	Descrive un'origine dati di input BLOB contenente i dati di riferimento.
BlobStreamInputDataSource	Descrive un'origine dati di input BLOB contenente i dati di flusso.
ClusterInfo	Proprietà associate a un cluster di Analisi di flusso.
CompatibilityLevel	Controlla determinati comportamenti di runtime del processo di streaming.
Compression	Descrive il modo in cui i dati di input vengono compressi
CompressionType	Indica il tipo di compressione usato dall'input. Obbligatorio nelle richieste PUT (CreateOrReplace).
ContentStoragePolicy	I valori validi sono JobStorageAccount e SystemAccount. Se impostato su JobStorageAccount, è necessario che l'utente specifichi anche la proprietà jobStorageAccount. .
CsvSerialization	Viene descritto come serializzare i dati di un input o come serializzare i dati quando vengono scritti in un output in formato CSV.
DiagnosticCondition	Condizione applicabile alla risorsa o al processo in generale, che garantisce l'attenzione del cliente.
Diagnostics	Descrive le condizioni applicabili all'input, all'output o al processo in generale, che garantiscono l'attenzione del cliente.
DocumentDbOutputDataSource	Descrive un'origine dati di output di DocumentDB.
Encoding	Specifica la codifica dei dati in ingresso nel caso di input e la codifica dei dati in uscita nel caso di output.
Error	Rappresentazione di errore comune.
EventHubOutputDataSource	Descrive un'origine dati di output dell'hub eventi.
EventHubStreamInputDataSource	Descrive un'origine dati di input dell'hub eventi che contiene dati di flusso.
EventHubV2OutputDataSource	Descrive un'origine dati di output dell'hub eventi.
EventHubV2StreamInputDataSource	Descrive un'origine dati di input dell'hub eventi che contiene dati di flusso.
EventSerializationType	Indica il tipo di serializzazione usato dall'input o dall'output. Obbligatorio nelle richieste PUT (CreateOrReplace).
EventsOutOfOrderPolicy	Indica il criterio da applicare agli eventi che arrivano non in ordine nel flusso di eventi di input.
FileReferenceInputDataSource	Descrive un'origine dati di input file contenente i dati di riferimento.
Function	Oggetto funzione contenente tutte le informazioni associate alla funzione denominata. Tutte le funzioni sono contenute in un processo di streaming.
FunctionInput	Descrive un parametro di input di una funzione.
FunctionOutput	Descrive l'output di una funzione.
GatewayMessageBusOutputDataSource	Descrive un'origine dati di output del bus di messaggi del gateway.
GatewayMessageBusStreamInputDataSource	Descrive un'origine dati di input BLOB contenente i dati di flusso.
Identity	Descrive la modalità di verifica dell'identità
Input	Oggetto di input contenente tutte le informazioni associate all'input denominato. Tutti gli input sono contenuti in un processo di streaming.
IoTHubStreamInputDataSource	Descrive un'origine dati di input hub IoT che contiene dati di flusso.
JavaScriptFunctionBinding	Associazione a una funzione JavaScript.
JobStorageAccount	Proprietà associate a un account di archiviazione di Azure con msi
JobType	Descrive il tipo di processo. Le modalità valide sono Cloud e 'Edge'.
JsonOutputSerializationFormat	Specifica il formato dell'output JSON in cui verrà scritto. I valori attualmente supportati sono "lineSeparated" che indicano che l'output verrà formattato con ogni oggetto JSON separato da una nuova riga e "array" che indica che l'output verrà formattato come matrice di oggetti JSON.
JsonSerialization	Viene descritto come serializzare i dati di un input o come serializzare i dati quando vengono scritti in un output in formato JSON.
Output	Oggetto di output contenente tutte le informazioni associate all'output denominato. Tutti gli output sono contenuti in un processo di streaming.
OutputErrorPolicy	Indica il criterio da applicare agli eventi che arrivano all'output e non possono essere scritti nella risorsa di archiviazione esterna a causa di un formato non valido (valori di colonna mancanti, valori di colonna di tipo o dimensioni errati).
OutputStartMode	Il valore può essere JobStartTime, CustomTime o LastOutputEventTime per indicare se il punto iniziale del flusso di eventi di output deve essere avviato ogni volta che il processo viene avviato, iniziare a un timestamp utente personalizzato specificato tramite la proprietà outputStartTime o iniziare dall'ora dell'ultimo output dell'evento.
ParquetSerialization	Viene descritto come serializzare i dati di un input o come serializzare i dati quando vengono scritti in un output in formato Parquet.
PowerBIOutputDataSource	Descrive un'origine dati di output di Power BI.
ReferenceInputProperties	Proprietà associate a un input contenente dati di riferimento.
RefreshType	Indica il tipo di opzione di aggiornamento dati.
ScalarFunctionProperties	Proprietà associate a una funzione scalare.
ServiceBusQueueOutputDataSource	Descrive un'origine dati di output della coda del bus di servizio.
ServiceBusTopicOutputDataSource	Descrive un'origine dati di output dell'argomento del bus di servizio.
Sku	Proprietà associate a uno SKU.
SkuName	Il nome della SKU. Obbligatorio nelle richieste PUT (CreateOrReplace).
StorageAccount	Proprietà associate a un account di archiviazione di Azure
StreamingJob	Oggetto processo di streaming contenente tutte le informazioni associate al processo di streaming denominato.
StreamInputProperties	Proprietà associate a un input contenente i dati del flusso.
Transformation	Oggetto trasformazione contenente tutte le informazioni associate alla trasformazione denominata. Tutte le trasformazioni sono contenute in un processo di streaming.

AggregateFunctionProperties

Proprietà associate a una funzione di aggregazione.

Nome	Tipo	Descrizione
etag	string	Tag di entità corrente per la funzione. Si tratta di una stringa opaca. È possibile usarlo per rilevare se la risorsa è cambiata tra le richieste. È anche possibile usarlo nelle intestazioni If-Match o If-None-Match per le operazioni di scrittura per la concorrenza ottimistica.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Associazione fisica della funzione. Ad esempio, nel caso del servizio Web di Azure Machine Learning, questo descrive l'endpoint.
properties.inputs	FunctionInput[]	Descrive un parametro di input di una funzione.
properties.output	FunctionOutput	Descrive l'output di una funzione.
type	string: Aggregate	Indica il tipo di funzione.

AuthenticationMode

Modalità di autenticazione. Le modalità valide sono ConnectionString, Msi e 'UserToken'.

Nome	Tipo	Descrizione
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Viene descritto come serializzare i dati di un input o come serializzare i dati quando vengono scritti in un output in formato Avro.

Nome	Tipo	Descrizione
type	string: Avro	Indica il tipo di serializzazione utilizzato dall'input o dall'output. Obbligatorio nelle richieste PUT (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Descrive un'origine dati di output di Azure Data Lake Store.

Nome	Tipo	Valore predefinito	Descrizione
properties.accountName	string		Nome dell'account Azure Data Lake Store. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.dateFormat	string		Formato della data. Ovunque venga visualizzato {date} in filePathPrefix, il valore di questa proprietà viene usato invece come formato di data.
properties.filePathPrefix	string		Percorso del file in cui scrivere l'output. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.refreshToken	string		Token di aggiornamento che può essere usato per ottenere un token di accesso valido che può quindi essere usato per eseguire l'autenticazione con l'origine dati. Un token di aggiornamento valido è attualmente disponibile solo tramite il portale di Azure. È consigliabile inserire qui un valore fittizio stringa durante la creazione dell'origine dati e quindi passare al portale di Azure per autenticare l'origine dati che aggiornerà questa proprietà con un token di aggiornamento valido. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.tenantId	string		ID tenant dell'utente usato per ottenere il token di aggiornamento. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.timeFormat	string		Formato dell'ora. Ovunque venga visualizzato {time} in filePathPrefix, il valore di questa proprietà viene usato invece come formato ora.
properties.tokenUserDisplayName	string		Nome visualizzato dell'utente utilizzato per ottenere il token di aggiornamento. Usare questa proprietà per ricordare quale utente è stato usato per ottenere il token di aggiornamento.
properties.tokenUserPrincipalName	string		Nome dell'entità utente (UPN) dell'utente usato per ottenere il token di aggiornamento. Usare questa proprietà per ricordare quale utente è stato usato per ottenere il token di aggiornamento.
type	string: Microsoft.DataLake/Accounts		Indica il tipo di output dell'origine dati in cui verrà scritto. Obbligatorio nelle richieste PUT (CreateOrReplace).

AzureFunctionOutputDataSource

Definisce i metadati di AzureFunctionOutputDataSource

Nome	Tipo	Descrizione
properties.apiKey	string	Per usare una funzione di Azure da un'altra sottoscrizione, è necessario fornire la chiave per accedere alla funzione.
properties.functionAppName	string	Nome dell'app Funzioni di Azure.
properties.functionName	string	Nome della funzione nell'app Funzioni di Azure.
properties.maxBatchCount	number	Proprietà che consente di specificare il numero massimo di eventi in ogni batch che vengono inviati a Funzioni di Azure. Il valore predefinito è 100.
properties.maxBatchSize	number	Proprietà che consente di impostare le dimensioni massime per ogni batch di output inviato a Funzioni di Azure. L'unità di input è espressa in byte. Per impostazione predefinita, questo valore è 262.144 byte (256 KB).
type	string: Microsoft.AzureFunction	Indica che il tipo di output dell'origine dati verrà scritto in. Obbligatorio nelle richieste PUT (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

Associazione a un servizio Web di Azure Machine Learning.

Nome	Tipo	Descrizione
properties.apiKey	string	Chiave API usata per l'autenticazione con Request-Response endpoint.
properties.batchSize	integer	Numero compreso tra 1 e 10000 che descrive il numero massimo di righe per ogni richiesta di esecuzione RRS di Azure ML. Il valore predefinito è 1000.
properties.endpoint	string	Il Request-Response eseguire l'endpoint del servizio Web di Azure Machine Learning. Per altre informazioni, vedere: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
properties.inputs	AzureMachineLearningWebServiceInputs	Input per l'endpoint del servizio Web di Azure Machine Learning.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Elenco di output dall'esecuzione dell'endpoint del servizio Web di Azure Machine Learning.
type	string: Microsoft.MachineLearning/WebService	Indica il tipo di associazione della funzione.

AzureMachineLearningWebServiceInputColumn

Descrive una colonna di input per l'endpoint del servizio Web di Azure Machine Learning.

Nome	Tipo	Descrizione
dataType	string	Tipo di dati (supportato da Azure Machine Learning) della colonna di input. Un elenco dei tipi di dati validi di Azure Machine Learning è descritto in https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
mapTo	integer	Indice in base zero del parametro della funzione a cui viene mappato questo input.
name	string	Nome della colonna di input.

AzureMachineLearningWebServiceInputs

Input per l'endpoint del servizio Web di Azure Machine Learning.

Nome	Tipo	Descrizione
columnNames	AzureMachineLearningWebServiceInputColumn[]	Elenco di colonne di input per l'endpoint del servizio Web di Azure Machine Learning.
name	string	Nome dell'input. Si tratta del nome specificato durante la creazione dell'endpoint.

AzureMachineLearningWebServiceOutputColumn

Descrive una colonna di output per l'endpoint del servizio Web di Azure Machine Learning.

Nome	Tipo	Descrizione
dataType	string	Tipo di dati (supportato da Azure Machine Learning) della colonna di output. Un elenco dei tipi di dati validi di Azure Machine Learning è descritto in https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
name	string	Nome della colonna di output.

AzureSqlDatabaseOutputDataSource

Descrive un'origine dati di output del database Azure SQL.

Nome	Tipo	Valore predefinito	Descrizione
properties.authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.database	string		Nome del database Azure SQL. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.maxBatchCount	number		Numero massimo di batch per la scrittura nel database Sql, il valore predefinito è 10.000. Facoltativo nelle richieste PUT.
properties.maxWriterCount	number		Numero massimo di writer, attualmente sono disponibili solo 1(writer singolo) e 0(in base alla partizione di query). Facoltativo nelle richieste PUT.
properties.password	string		Password che verrà usata per connettersi al database Azure SQL. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.server	string		Nome del server SQL contenente il database Azure SQL. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.table	string		Nome della tabella nel database Azure SQL. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.user	string		Nome utente che verrà usato per connettersi al database Azure SQL. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/Database		Indica che il tipo di output dell'origine dati verrà scritto in. Obbligatorio nelle richieste PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Descrive un'origine dati di input di riferimento al database di Azure SQL.

Nome	Tipo	Descrizione
properties.database	string	Questo elemento viene associato all'elemento datasource. Nome del database in cui verrà scritto l'output.
properties.deltaSnapshotQuery	string	Questo elemento viene associato all'elemento datasource. Questa query viene usata per recuperare le modifiche incrementali dal database SQL. Per usare questa opzione, è consigliabile usare tabelle temporali in Azure SQL Database.
properties.fullSnapshotQuery	string	Questo elemento viene associato all'elemento datasource. Questa query viene usata per recuperare i dati dal database SQL.
properties.password	string	Questo elemento viene associato all'elemento datasource. Password che verrà usata per connettersi all'istanza di database SQL.
properties.refreshRate	string	Questo elemento viene associato all'elemento datasource. Indica la frequenza con cui i dati verranno recuperati dal database. È di formato DateTime.
properties.refreshType	RefreshType	Indica il tipo di opzione di aggiornamento dati.
properties.server	string	Questo elemento viene associato all'elemento datasource. Nome del server che contiene il database in cui verranno scritti i dati.
properties.table	string	Questo elemento viene associato all'elemento datasource. Nome della tabella nel database Azure SQL.
properties.user	string	Questo elemento viene associato all'elemento datasource. Nome utente che verrà usato per connettersi all'istanza di database SQL.
type	string: Microsoft.Sql/Server/Database	Indica il tipo di origine dati di input contenente i dati di riferimento. Obbligatorio nelle richieste PUT (CreateOrReplace).

AzureSynapseOutputDataSource

Descrive un'origine dati di output Azure Synapse.

Nome	Tipo	Descrizione
properties.database	string	Nome del database Azure SQL. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.password	string	Password che verrà usata per connettersi al database Azure SQL. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.server	string	Nome del server SQL contenente il database Azure SQL. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.table	string	Nome della tabella nel database Azure SQL. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.user	string	Nome utente che verrà usato per connettersi al database Azure SQL. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/DataWarehouse	Indica che il tipo di output dell'origine dati verrà scritto in. Obbligatorio nelle richieste PUT (CreateOrReplace).

AzureTableOutputDataSource

Descrive un'origine dati di output tabella di Azure.

Nome	Tipo	Descrizione
properties.accountKey	string	Chiave dell'account per l'account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.accountName	string	il nome dell'account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.batchSize	integer	Numero di righe da scrivere nella tabella di Azure alla volta.
properties.columnsToRemove	string[]	Se specificato, ogni elemento nella matrice corrisponde al nome di una colonna da rimuovere (se presente) dalle entità dell'evento output.
properties.partitionKey	string	Questo elemento indica il nome di una colonna dell'istruzione SELECT nella query che verrà usata come chiave di partizione per la tabella di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.rowKey	string	Questo elemento indica il nome di una colonna dell'istruzione SELECT nella query che verrà usata come chiave di riga per la tabella di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.table	string	Nome della tabella di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Microsoft.Storage/Table	Indica il tipo di output dell'origine dati in cui verrà scritto. Obbligatorio nelle richieste PUT (CreateOrReplace).

BlobOutputDataSource

Descrive un'origine dati di output BLOB.

Nome	Tipo	Valore predefinito	Descrizione
properties.authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.blobPathPrefix	string		Prefisso del percorso BLOB.
properties.container	string		Nome di un contenitore all'interno dell'account di archiviazione associato. Questo contenitore contiene i BLOB da cui leggere o scrivere. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.dateFormat	string		Formato della data. Ovunque venga visualizzato {date} in pathPattern, il valore di questa proprietà viene usato invece come formato data.
properties.pathPattern	string		Modello di percorso DEL BLOB. Non un'espressione regolare. Rappresenta un modello in base al quale i nomi dei BLOB verranno confrontati per determinare se devono essere inclusi o meno come input o output nel processo. Vedere https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input o https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output per una spiegazione più dettagliata ed esempio.
properties.storageAccounts	StorageAccount[]		Elenco di uno o più account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.timeFormat	string		Formato dell'ora. Ovunque venga visualizzato {time} in pathPattern, il valore di questa proprietà viene usato come formato ora.
type	string: Microsoft.Storage/Blob		Indica il tipo di output dell'origine dati in cui verrà scritto. Obbligatorio nelle richieste PUT (CreateOrReplace).

BlobReferenceInputDataSource

Descrive un'origine dati di input BLOB contenente i dati di riferimento.

Nome	Tipo	Valore predefinito	Descrizione
properties.authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.container	string		Nome di un contenitore all'interno dell'account di archiviazione associato. Questo contenitore contiene i BLOB da leggere o scrivere in. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.dateFormat	string		Formato della data. Ovunque venga visualizzato {date} in pathPattern, il valore di questa proprietà viene usato invece come formato data.
properties.pathPattern	string		Modello di percorso BLOB. Non un'espressione regolare. Rappresenta un modello rispetto al quale i nomi BLOB verranno corrispondenti per determinare se devono essere inclusi come input o output al processo. Vedere https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input o https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output per una spiegazione più dettagliata ed esempio.
properties.storageAccounts	StorageAccount[]		Elenco di uno o più account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.timeFormat	string		Formato dell'ora. Ovunque venga visualizzato {time} in pathPattern, il valore di questa proprietà viene usato come formato ora.
type	string: Microsoft.Storage/Blob		Indica il tipo di origine dati di input contenente i dati di riferimento. Obbligatorio nelle richieste PUT (CreateOrReplace).

BlobStreamInputDataSource

Descrive un'origine dati di input BLOB contenente i dati di flusso.

Nome	Tipo	Valore predefinito	Descrizione
properties.authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.container	string		Nome di un contenitore all'interno dell'account di archiviazione associato. Questo contenitore contiene i BLOB da leggere o scrivere in. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.dateFormat	string		Formato della data. Ovunque {date} venga visualizzato in pathPattern, il valore di questa proprietà viene usato come formato data.
properties.pathPattern	string		Modello di percorso BLOB. Non un'espressione regolare. Rappresenta un modello rispetto al quale i nomi BLOB verranno corrispondenti per determinare se devono essere inclusi come input o output al processo. Vedere https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input o https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output per una spiegazione più dettagliata ed esempio.
properties.sourcePartitionCount	integer		Numero di partizioni dell'origine dati di input BLOB. Intervallo 1 - 1024.
properties.storageAccounts	StorageAccount[]		Elenco di uno o più account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.timeFormat	string		Formato ora. Ovunque {time} venga visualizzato in pathPattern, il valore di questa proprietà viene usato come formato ora.
type	string: Microsoft.Storage/Blob		Indica il tipo di origine dati di input contenente i dati di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

ClusterInfo

Proprietà associate a un cluster di Analisi di flusso.

Nome	Tipo	Descrizione
id	string	ID risorsa del cluster.

CompatibilityLevel

Controlla determinati comportamenti di runtime del processo di streaming.

Nome	Tipo	Descrizione
1.0	string
1.2	string

Compression

Descrive il modo in cui i dati di input vengono compressi

Nome	Tipo	Valore predefinito	Descrizione
type	CompressionType	None	Indica il tipo di compressione utilizzato dall'input. Obbligatorio nelle richieste PUT (CreateOrReplace).

CompressionType

Indica il tipo di compressione usato dall'input. Obbligatorio nelle richieste PUT (CreateOrReplace).

Nome	Tipo	Descrizione
Deflate	string
GZip	string
None	string

ContentStoragePolicy

I valori validi sono JobStorageAccount e SystemAccount. Se impostato su JobStorageAccount, è necessario che l'utente specifichi anche la proprietà jobStorageAccount. .

Nome	Tipo	Descrizione
JobStorageAccount	string
SystemAccount	string

CsvSerialization

Viene descritto come serializzare i dati di un input o come serializzare i dati quando vengono scritti in un output in formato CSV.

Nome	Tipo	Descrizione
properties.encoding	Encoding	Specifica la codifica dei dati in ingresso in caso di input e la codifica dei dati in uscita nel caso dell'output. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.fieldDelimiter	string	Specifica il delimitatore che verrà utilizzato per separare i record con valori delimitati da virgole (CSV). Vedere https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input o https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output per un elenco di valori supportati. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Csv	Indica il tipo di serializzazione utilizzato dall'input o dall'output. Obbligatorio nelle richieste PUT (CreateOrReplace).

DiagnosticCondition

Condizione applicabile alla risorsa o al processo in generale, che garantisce l'attenzione del cliente.

Nome	Tipo	Descrizione
code	string	Codice di diagnostica opaco.
message	string	Messaggio leggibile che descrive in dettaglio la condizione. Localizzato nella Accept-Language della richiesta client.
since	string	Timestamp UTC di all'avvio della condizione. I clienti dovrebbero essere in grado di trovare un evento corrispondente nel log delle operazioni in questo momento.

Diagnostics

Descrive le condizioni applicabili all'input, all'output o al processo in generale, che garantiscono l'attenzione del cliente.

Nome	Tipo	Descrizione
conditions	DiagnosticCondition[]	Una raccolta di zero o più condizioni applicabili alla risorsa o al processo in generale, che garantiscono l'attenzione del cliente.

DocumentDbOutputDataSource

Descrive un'origine dati di output di DocumentDB.

Nome	Tipo	Descrizione
properties.accountId	string	Nome o ID dell'account DocumentDB. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.accountKey	string	Chiave dell'account per l'account DocumentDB. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.collectionNamePattern	string	Il modello del nome di raccolta per le raccolte da utilizzare. Il formato del nome di raccolta può essere costruito utilizzando il token {partizione} facoltativo, dove le partizioni iniziano da 0. Per altre informazioni, vedere la sezione https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output DocumentDB. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.database	string	Nome del database DocumentDB. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.documentId	string	Il nome del campo negli eventi di output utilizzato per specificare la chiave primaria su cui si basano le operazioni di inserimento o aggiornamento.
properties.partitionKey	string	Il nome del campo negli eventi di output utilizzato per specificare la chiave per il partizionamento di output nelle raccolte. Se 'collectionNamePattern' contiene il token {partition}, questa proprietà deve essere specificata.
type	string: Microsoft.Storage/DocumentDB	Indica che il tipo di output dell'origine dati verrà scritto in. Obbligatorio nelle richieste PUT (CreateOrReplace).

Encoding

Specifica la codifica dei dati in ingresso nel caso di input e la codifica dei dati in uscita nel caso di output.

Nome	Tipo	Descrizione
UTF8	string

Error

Rappresentazione di errore comune.

Nome	Tipo	Descrizione
error	Error	Proprietà di definizione degli errori.

EventHubOutputDataSource

Descrive un'origine dati di output dell'hub eventi.

Nome	Tipo	Valore predefinito	Descrizione
authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.eventHubName	string		Nome dell'hub eventi. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.partitionKey	string		Chiave/colonna utilizzata per determinare la partizione in cui inviare i dati dell'evento.
properties.propertyColumns	string[]		Proprietà associate all'output dell'hub eventi.
serviceBusNamespace	string		Spazio dei nomi associato all'hub eventi desiderato, coda del bus di servizio, argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Chiave dei criteri di accesso condiviso per i criteri di accesso condiviso specificati. Obbligatorio nelle richieste PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nome dei criteri di accesso condiviso per l'hub eventi, la coda del bus di servizio, l'argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indica il tipo di output dell'origine dati in cui verrà scritto. Obbligatorio nelle richieste PUT (CreateOrReplace).

EventHubStreamInputDataSource

Descrive un'origine dati di input dell'hub eventi che contiene dati di flusso.

Nome	Tipo	Valore predefinito	Descrizione
authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.consumerGroupName	string		Nome di un gruppo di consumer dell'hub eventi che deve essere usato per leggere gli eventi dall'hub eventi. Specificando nomi di gruppi di consumer distinti per più input, ognuno di questi input può ricevere gli stessi eventi dall'hub eventi. Se non specificato, l'input usa il gruppo consumer predefinito dell'hub eventi.
properties.eventHubName	string		Nome dell'hub eventi. Obbligatorio nelle richieste PUT (CreateOrReplace).
serviceBusNamespace	string		Spazio dei nomi associato all'hub eventi desiderato, coda del bus di servizio, argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Chiave dei criteri di accesso condiviso per i criteri di accesso condiviso specificati. Obbligatorio nelle richieste PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nome dei criteri di accesso condiviso per l'hub eventi, la coda del bus di servizio, l'argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indica il tipo di origine dati di input contenente i dati di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

EventHubV2OutputDataSource

Descrive un'origine dati di output dell'hub eventi.

Nome	Tipo	Valore predefinito	Descrizione
authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.eventHubName	string		Nome dell'hub eventi. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.partitionKey	string		Chiave/colonna utilizzata per determinare la partizione da inviare dati dell'evento.
properties.propertyColumns	string[]		Proprietà associate all'output dell'hub eventi.
serviceBusNamespace	string		Spazio dei nomi associato all'hub eventi desiderato, coda del bus di servizio, argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Chiave dei criteri di accesso condiviso per i criteri di accesso condiviso specificati. Obbligatorio nelle richieste PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nome dei criteri di accesso condiviso per l'hub eventi, la coda del bus di servizio, l'argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indica che il tipo di output dell'origine dati verrà scritto in. Obbligatorio nelle richieste PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Descrive un'origine dati di input dell'hub eventi che contiene dati di flusso.

Nome	Tipo	Valore predefinito	Descrizione
authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.consumerGroupName	string		Nome di un gruppo di consumer dell'hub eventi che deve essere usato per leggere gli eventi dall'hub eventi. Specificando nomi di gruppi di consumer distinti per più input, ognuno di questi input può ricevere gli stessi eventi dall'hub eventi. Se non specificato, l'input usa il gruppo consumer predefinito dell'hub eventi.
properties.eventHubName	string		Nome dell'hub eventi. Obbligatorio nelle richieste PUT (CreateOrReplace).
serviceBusNamespace	string		Spazio dei nomi associato all'hub eventi desiderato, coda del bus di servizio, argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Chiave dei criteri di accesso condiviso per i criteri di accesso condiviso specificati. Obbligatorio nelle richieste PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nome dei criteri di accesso condiviso per l'hub eventi, la coda del bus di servizio, l'argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indica il tipo di origine dati di input contenente i dati di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

EventSerializationType

Indica il tipo di serializzazione usato dall'input o dall'output. Obbligatorio nelle richieste PUT (CreateOrReplace).

Nome	Tipo	Descrizione
Avro	string
Csv	string
Json	string
Parquet	string

EventsOutOfOrderPolicy

Indica il criterio da applicare agli eventi che arrivano non in ordine nel flusso di eventi di input.

Nome	Tipo	Descrizione
Adjust	string
Drop	string

FileReferenceInputDataSource

Descrive un'origine dati di input file contenente i dati di riferimento.

Nome	Tipo	Descrizione
properties.path	string	Percorso del file.
type	string: File	Indica il tipo di origine dati di input contenente i dati di riferimento. Obbligatorio nelle richieste PUT (CreateOrReplace).

Function

Oggetto funzione contenente tutte le informazioni associate alla funzione denominata. Tutte le funzioni sono contenute in un processo di streaming.

Nome	Tipo	Descrizione
id	string	ID risorsa
name	string	Nome risorsa
properties	FunctionProperties: AggregateFunctionProperties ScalarFunctionProperties	Proprietà associate a una funzione.
type	string	Tipo di risorsa

FunctionInput

Descrive un parametro di input di una funzione.

Nome	Tipo	Descrizione
dataType	string	Tipo di dati (Azure Stream Analytics supportato) del parametro di input della funzione. Un elenco dei tipi di dati di Analisi di flusso di Azure validi è descritto in https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	Flag che indica se il parametro è un parametro di configurazione. True se questo parametro di input deve essere una costante. L'impostazione predefinita è false.

FunctionOutput

Descrive l'output di una funzione.

Nome	Tipo	Descrizione
dataType	string	Tipo di dati (Azure Stream Analytics supportato) dell'output della funzione. Un elenco dei tipi di dati di Analisi di flusso di Azure validi è descritto in https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

Descrive un'origine dati di output del bus di messaggi del gateway.

Nome	Tipo	Descrizione
properties.topic	string	Nome dell'argomento del bus di servizio.
type	string: GatewayMessageBus	Indica il tipo di output dell'origine dati in cui verrà scritto. Obbligatorio nelle richieste PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Descrive un'origine dati di input BLOB contenente i dati di flusso.

Nome	Tipo	Descrizione
properties.topic	string	Nome dell'argomento del bus di servizio.
type	string: GatewayMessageBus	Indica il tipo di origine dati di input contenente i dati di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

Identity

Descrive la modalità di verifica dell'identità

Nome	Tipo	Descrizione
principalId	string	ID dell'entità identità
tenantId	string	Identity tenantId
type	string	Tipo di identità

Input

Oggetto di input contenente tutte le informazioni associate all'input denominato. Tutti gli input sono contenuti in un processo di streaming.

Nome	Tipo	Descrizione
id	string	ID risorsa
name	string	Nome risorsa
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Proprietà associate a un input. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string	Tipo di risorsa

IoTHubStreamInputDataSource

Descrive un'origine dati di input hub IoT che contiene dati di flusso.

Nome	Tipo	Descrizione
properties.consumerGroupName	string	Nome di un gruppo di consumer di hub IoT che deve essere usato per leggere gli eventi dall'hub IoT. Se non specificato, l'input usa il gruppo consumer predefinito di Iot Hub.
properties.endpoint	string	Endpoint hub IoT da connettersi (ad esempio messaggi/eventi, messaggi/operazioniMonitoringEvents e così via).
properties.iotHubNamespace	string	Nome o URI dell'hub IoT. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Chiave dei criteri di accesso condiviso per i criteri di accesso condiviso specificati. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Nome dei criteri di accesso condiviso per il hub IoT. Questo criterio deve contenere almeno l'autorizzazione di connessione del servizio. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Indica il tipo di origine dati di input contenente i dati di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

JavaScriptFunctionBinding

Associazione a una funzione JavaScript.

Nome	Tipo	Descrizione
properties.script	string	Codice JavaScript contenente una singola definizione di funzione. Ad esempio: 'function (x, y) { return x + y; }'
type	string: Microsoft.StreamAnalytics/JavascriptUdf	Indica il tipo di associazione della funzione.

JobStorageAccount

Proprietà associate a un account di archiviazione di Azure con msi

Nome	Tipo	Valore predefinito	Descrizione
accountKey	string		Chiave dell'account per l'account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
accountName	string		il nome dell'account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.

JobType

Descrive il tipo di processo. Le modalità valide sono Cloud e 'Edge'.

Nome	Tipo	Descrizione
Cloud	string
Edge	string

JsonOutputSerializationFormat

Specifica il formato dell'output JSON in cui verrà scritto. I valori attualmente supportati sono "lineSeparated" che indicano che l'output verrà formattato con ogni oggetto JSON separato da una nuova riga e "array" che indica che l'output verrà formattato come matrice di oggetti JSON.

Nome	Tipo	Descrizione
Array	string
LineSeparated	string

JsonSerialization

Viene descritto come serializzare i dati di un input o come serializzare i dati quando vengono scritti in un output in formato JSON.

Nome	Tipo	Descrizione
properties.encoding	Encoding	Specifica la codifica dei dati in ingresso in caso di input e la codifica dei dati in uscita nel caso dell'output. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Questa proprietà si applica solo alla serializzazione JSON degli output. Non è applicabile agli input. Questa proprietà specifica il formato del codice JSON in cui verrà scritto l'output. I valori attualmente supportati sono "lineSeparated" che indicano che l'output verrà formattato con ogni oggetto JSON separato da una nuova riga e 'matrice' che indica che l'output verrà formattato come matrice di oggetti JSON. Il valore predefinito è 'lineSeparated' se viene lasciato null.
type	string: Json	Indica il tipo di serializzazione utilizzato dall'input o dall'output. Obbligatorio nelle richieste PUT (CreateOrReplace).

Output

Oggetto di output contenente tutte le informazioni associate all'output denominato. Tutti gli output sono contenuti in un processo di streaming.

Nome	Tipo	Descrizione
id	string	ID risorsa
name	string	Nome risorsa
properties.datasource	OutputDataSource: AzureDataLakeStoreOutputDataSource AzureFunctionOutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource AzureTableOutputDataSource BlobOutputDataSource DocumentDbOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource GatewayMessageBusOutputDataSource PowerBIOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource	Descrive l'origine dati a cui verrà scritto l'output. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.diagnostics	Diagnostics	Descrive le condizioni applicabili all'input, all'output o al processo complessivo, che garantiscono l'attenzione dei clienti.
properties.etag	string	Tag di entità corrente per l'output. Si tratta di una stringa opaca. È possibile usarlo per rilevare se la risorsa è cambiata tra le richieste. È anche possibile usarlo nelle intestazioni di If-Match o If-None-Match per le operazioni di scrittura per la concorrenza ottimistica.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Descrive la serializzazione dei dati da un input o la serializzazione dei dati quando vengono scritti in un output. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.sizeWindow	integer	Finestra delle dimensioni per limitare l'output di Analisi di flusso a.
properties.timeWindow	string	Intervallo di tempo per filtrare gli output dei processi di Analisi di flusso.
type	string	Tipo di risorsa

OutputErrorPolicy

Indica il criterio da applicare agli eventi che arrivano all'output e non possono essere scritti nella risorsa di archiviazione esterna a causa di un formato non valido (valori di colonna mancanti, valori di colonna di tipo o dimensioni errati).

Nome	Tipo	Descrizione
Drop	string
Stop	string

OutputStartMode

Il valore può essere JobStartTime, CustomTime o LastOutputEventTime per indicare se il punto iniziale del flusso di eventi di output deve essere avviato ogni volta che il processo viene avviato, iniziare a un timestamp utente personalizzato specificato tramite la proprietà outputStartTime o iniziare dall'ora dell'ultimo output dell'evento.

Nome	Tipo	Descrizione
CustomTime	string
JobStartTime	string
LastOutputEventTime	string

ParquetSerialization

Viene descritto come serializzare i dati di un input o come serializzare i dati quando vengono scritti in un output in formato Parquet.

Nome	Tipo	Descrizione
type	string: Parquet	Indica il tipo di serializzazione utilizzato dall'input o dall'output. Obbligatorio nelle richieste PUT (CreateOrReplace).

PowerBIOutputDataSource

Descrive un'origine dati di output di Power BI.

Nome	Tipo	Valore predefinito	Descrizione
properties.authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.dataset	string		Nome del set di dati di Power BI. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.groupId	string		ID del gruppo di Power BI.
properties.groupName	string		Nome del gruppo di Power BI. Usare questa proprietà per ricordare quale ID gruppo di Power BI specifico è stato usato.
properties.refreshToken	string		Token di aggiornamento che può essere usato per ottenere un token di accesso valido che può quindi essere usato per eseguire l'autenticazione con l'origine dati. Un token di aggiornamento valido è attualmente disponibile solo tramite il portale di Azure. È consigliabile inserire qui un valore fittizio stringa durante la creazione dell'origine dati e quindi passare al portale di Azure per autenticare l'origine dati che aggiornerà questa proprietà con un token di aggiornamento valido. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.table	string		Nome della tabella di Power BI nel set di dati specificato. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.tokenUserDisplayName	string		Nome visualizzato dell'utente utilizzato per ottenere il token di aggiornamento. Usare questa proprietà per ricordare quale utente è stato usato per ottenere il token di aggiornamento.
properties.tokenUserPrincipalName	string		Nome dell'entità utente (UPN) dell'utente usato per ottenere il token di aggiornamento. Usare questa proprietà per ricordare quale utente è stato usato per ottenere il token di aggiornamento.
type	string: PowerBI		Indica il tipo di output dell'origine dati in cui verrà scritto. Obbligatorio nelle richieste PUT (CreateOrReplace).

ReferenceInputProperties

Proprietà associate a un input contenente dati di riferimento.

Nome	Tipo	Descrizione
compression	Compression	Descrive il modo in cui i dati di input vengono compressi
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Descrive un'origine dati di input che contiene dati di riferimento. Obbligatorio nelle richieste PUT (CreateOrReplace).
diagnostics	Diagnostics	Descrive le condizioni applicabili all'input, all'output o al processo in generale, che garantiscono l'attenzione del cliente.
etag	string	Tag di entità corrente per l'input. Si tratta di una stringa opaca. È possibile usarlo per rilevare se la risorsa è cambiata tra le richieste. È anche possibile usarlo nelle intestazioni If-Match o If-None-Match per le operazioni di scrittura per la concorrenza ottimistica.
partitionKey	string	partitionKey Descrive una chiave nei dati di input usati per partizionare i dati di input
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Viene descritto come serializzare i dati di un input o come serializzare i dati quando vengono scritti in un output. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Reference	Indica se l'input è un'origine di dati di riferimento o di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

RefreshType

Indica il tipo di opzione di aggiornamento dati.

Nome	Tipo	Descrizione
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

ScalarFunctionProperties

Proprietà associate a una funzione scalare.

Nome	Tipo	Descrizione
etag	string	Tag di entità corrente per la funzione. Si tratta di una stringa opaca. È possibile usarlo per rilevare se la risorsa è cambiata tra le richieste. È anche possibile usarlo nelle intestazioni If-Match o If-None-Match per le operazioni di scrittura per la concorrenza ottimistica.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Associazione fisica della funzione. Ad esempio, nel caso del servizio Web di Azure Machine Learning, questo descrive l'endpoint.
properties.inputs	FunctionInput[]	Descrive un parametro di input di una funzione.
properties.output	FunctionOutput	Descrive l'output di una funzione.
type	string: Scalar	Indica il tipo di funzione.

ServiceBusQueueOutputDataSource

Descrive un'origine dati di output della coda del bus di servizio.

Nome	Tipo	Valore predefinito	Descrizione
properties.authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.propertyColumns	string[]		Matrice di stringhe dei nomi delle colonne di output da collegare ai messaggi del bus di servizio come proprietà personalizzate.
properties.queueName	string		Nome della coda del bus di servizio. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.serviceBusNamespace	string		Spazio dei nomi associato all'hub eventi desiderato, coda del bus di servizio, argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Chiave dei criteri di accesso condiviso per i criteri di accesso condiviso specificati. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		Nome dei criteri di accesso condiviso per l'hub eventi, la coda del bus di servizio, l'argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.systemPropertyColumns	object		Proprietà di sistema associate alla coda del bus di servizio. Le proprietà di sistema seguenti sono supportate: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
type	string: Microsoft.ServiceBus/Queue		Indica che il tipo di output dell'origine dati verrà scritto in. Obbligatorio nelle richieste PUT (CreateOrReplace).

ServiceBusTopicOutputDataSource

Descrive un'origine dati di output dell'argomento del bus di servizio.

Nome	Tipo	Valore predefinito	Descrizione
properties.authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.propertyColumns	string[]		Matrice di stringhe dei nomi delle colonne di output da collegare ai messaggi del bus di servizio come proprietà personalizzate.
properties.serviceBusNamespace	string		Spazio dei nomi associato all'hub eventi desiderato, coda del bus di servizio, argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Chiave dei criteri di accesso condiviso per i criteri di accesso condiviso specificati. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		Nome dei criteri di accesso condiviso per l'hub eventi, la coda del bus di servizio, l'argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.systemPropertyColumns	object		Proprietà di sistema associate all'output dell'argomento del bus di servizio. Le proprietà di sistema seguenti sono supportate: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
properties.topicName	string		Nome dell'argomento del bus di servizio. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/Topic		Indica che il tipo di output dell'origine dati verrà scritto in. Obbligatorio nelle richieste PUT (CreateOrReplace).

Sku

Proprietà associate a uno SKU.

Nome	Tipo	Descrizione
name	SkuName	Il nome della SKU. Obbligatorio nelle richieste PUT (CreateOrReplace).

SkuName

Il nome della SKU. Obbligatorio nelle richieste PUT (CreateOrReplace).

Nome	Tipo	Descrizione
Standard	string

StorageAccount

Proprietà associate a un account di archiviazione di Azure

Nome	Tipo	Descrizione
accountKey	string	Chiave dell'account per l'account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
accountName	string	il nome dell'account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).

StreamingJob

Oggetto processo di streaming contenente tutte le informazioni associate al processo di streaming denominato.

Nome	Tipo	Descrizione
id	string	ID risorsa completo per la risorsa. Ad esempio - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Descrive l'identità gestita assegnata dal sistema assegnata a questo processo che può essere usata per eseguire l'autenticazione con input e output.
location	string	Posizione geografica in cui risiede la risorsa
name	string	nome della risorsa.
properties.cluster	ClusterInfo	Cluster in cui verranno eseguiti i processi di streaming.
properties.compatibilityLevel	CompatibilityLevel	Controlla determinati comportamenti di runtime del processo di streaming.
properties.contentStoragePolicy	ContentStoragePolicy	I valori validi sono JobStorageAccount e SystemAccount. Se impostato su JobStorageAccount, è necessario che l'utente specifichi anche la proprietà jobStorageAccount. .
properties.createdDate	string	Il valore è un timestamp UTC formattato ISO-8601 che indica quando è stato creato il processo di streaming.
properties.dataLocale	string	Impostazioni locali dei dati del processo di analisi di flusso. Il valore deve essere il nome di una cultura .NET supportata dal set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Impostazione predefinita su 'en-US' se non è specificato alcun valore.
properties.etag	string	Tag di entità corrente per il processo di streaming. Si tratta di una stringa opaca. È possibile usarlo per rilevare se la risorsa è cambiata tra le richieste. È anche possibile usarlo nelle intestazioni If-Match o If-None-Match per le operazioni di scrittura per la concorrenza ottimistica.
properties.eventsLateArrivalMaxDelayInSeconds	integer	Il ritardo massimo tolerabile in secondi in cui gli eventi che arrivano in ritardo potrebbero essere inclusi. L'intervallo supportato è -1 a 1814399 (20,23:59:59 giorni) e -1 viene usato per specificare l'attesa indefinita. Se la proprietà è assente, viene interpretata per avere un valore pari a -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	Ritardo massimo tolerabile in secondi in cui gli eventi non ordinati possono essere modificati in ordine.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Indica i criteri da applicare agli eventi che arrivano fuori ordine nel flusso di eventi di input.
properties.functions	Function[]	Elenco di una o più funzioni per il processo di streaming. La proprietà name per ogni funzione è necessaria quando si specifica questa proprietà in una richiesta PUT. Questa proprietà non può essere modificata tramite un'operazione PATCH. È necessario usare l'API PATCH disponibile per la singola trasformazione.
properties.inputs	Input[]	Elenco di uno o più input per il processo di streaming. La proprietà name per ogni input è necessaria quando si specifica questa proprietà in una richiesta PUT. Questa proprietà non può essere modificata tramite un'operazione PATCH. È necessario usare l'API PATCH disponibile per l'input singolo.
properties.jobId	string	GUID che identifica in modo univoco il processo di streaming. Questo GUID viene generato al momento della creazione del processo di streaming.
properties.jobState	string	Descrive lo stato del processo di streaming.
properties.jobStorageAccount	JobStorageAccount	Proprietà associate a un account di archiviazione di Azure con l'identità del servizio gestito
properties.jobType	JobType	Descrive il tipo del processo. Le modalità valide sono Cloud e 'Edge'.
properties.lastOutputEventTime	string	Il valore è un timestamp formattato ISO-8601 che indica l'ora dell'ultimo evento di output del processo di streaming o null che indica che l'output non è ancora stato prodotto. In caso di più output o più flussi, questo mostra il valore più recente in tale set.
properties.outputErrorPolicy	OutputErrorPolicy	Indica i criteri da applicare agli eventi che arrivano all'output e non possono essere scritti nell'archiviazione esterna a causa della mancata configurazione (valori di colonna mancanti, valori di colonna di tipo o dimensioni errati).
properties.outputStartMode	OutputStartMode	Questa proprietà deve essere usata solo quando si desidera che il processo venga avviato immediatamente al momento della creazione. Il valore può essere JobStartTime, CustomTime o LastOutputEventTime per indicare se il punto iniziale del flusso di eventi di output deve iniziare ogni volta che il processo viene avviato, iniziare a un timestamp utente personalizzato specificato tramite la proprietà outputStartTime o iniziare dall'ora di output dell'ultimo evento.
properties.outputStartTime	string	Il valore è un timestamp in formato ISO-8601 che specifica il punto di partenza del flusso di eventi di output oppure null, a indicare che il flusso di eventi di output inizierà ogni volta che viene avviato il processo di streaming. Questa proprietà deve avere un valore se outputStartMode è impostato su CustomTime.
properties.outputs	Output[]	Elenco di uno o più output per il processo di streaming. La proprietà name per ogni output è necessaria quando si specifica questa proprietà in una richiesta PUT. Questa proprietà non può essere modificata tramite un'operazione PATCH. È necessario usare l'API PATCH disponibile per l'output singolo.
properties.provisioningState	string	Descrive lo stato di provisioning del processo di streaming.
properties.sku	Sku	Descrive lo SKU del processo di streaming. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.transformation	Transformation	Indica la query e il numero di unità di streaming da usare per il processo di streaming. La proprietà name della trasformazione è necessaria quando si specifica questa proprietà in una richiesta PUT. Questa proprietà non può essere modificata tramite un'operazione PATCH. È necessario usare l'API PATCH disponibile per la singola trasformazione.
tags	object	Tag delle risorse.
type	string	Tipo di risorsa. Ad esempio Microsoft.Compute/virtualMachines o Microsoft.Storage/storageAccounts.

StreamInputProperties

Proprietà associate a un input contenente i dati del flusso.

Nome	Tipo	Descrizione
compression	Compression	Descrive il modo in cui i dati di input vengono compressi
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Descrive un'origine dati di input che contiene dati di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).
diagnostics	Diagnostics	Descrive le condizioni applicabili all'input, all'output o al processo in generale, che garantiscono l'attenzione del cliente.
etag	string	Tag di entità corrente per l'input. Si tratta di una stringa opaca. È possibile usarlo per rilevare se la risorsa è cambiata tra le richieste. È anche possibile usarlo nelle intestazioni If-Match o If-None-Match per le operazioni di scrittura per la concorrenza ottimistica.
partitionKey	string	partitionKey Descrive una chiave nei dati di input usati per partizionare i dati di input
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Viene descritto come serializzare i dati di un input o come serializzare i dati quando vengono scritti in un output. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Stream	Indica se l'input è un'origine di dati di riferimento o di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

Transformation

Oggetto trasformazione contenente tutte le informazioni associate alla trasformazione denominata. Tutte le trasformazioni sono contenute in un processo di streaming.

Nome	Tipo	Valore predefinito	Descrizione
id	string		ID risorsa
name	string		Nome risorsa
properties.etag	string		Tag di entità corrente per la trasformazione. Si tratta di una stringa opaca. È possibile usarlo per rilevare se la risorsa è cambiata tra le richieste. È anche possibile usarlo nelle intestazioni di If-Match o If-None-Match per le operazioni di scrittura per la concorrenza ottimistica.
properties.query	string		Specifica la query che verrà eseguita nel processo di streaming. Altre informazioni sul linguaggio di query di Analisi di flusso (SAQL) sono disponibili qui: https://msdn.microsoft.com/library/azure/dn834998 . Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.streamingUnits	integer	3	Specifica il numero di unità di streaming usate dal processo di streaming.
properties.validStreamingUnits	integer[]		Specifica le unità di streaming valide a cui è possibile ridimensionare un processo di streaming.
type	string		Tipo di risorsa