Streaming Jobs - Create Or Replace

Referens

Tjänst:: Stream Analytics

API-version:: 2020-03-01

Skapar ett direktuppspelningsjobb eller ersätter ett redan befintligt strömningsjobb.

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

URI-parametrar

Name	I	Obligatorisk	Typ	Description
jobName	path	True	string	Namnet på strömningsjobbet.
resourceGroupName	path	True	string	Namnet på resursgruppen. Namnet är skiftlägesokänsligt. Reguljärt uttrycksmönster: `^[-\w\._]+$`
subscriptionId	path	True	string	ID för målprenumerationen.
api-version	query	True	string	Den API-version som ska användas för den här åtgärden.

Begärandehuvud

Name	Obligatorisk	Typ	Description
If-Match		string	ETag för strömningsjobbet. Utelämna det här värdet för att alltid skriva över den aktuella postuppsättningen. Ange det senast sedda ETag-värdet för att förhindra att samtidiga ändringar skrivs över av misstag.
If-None-Match		string	Ange till *för att tillåta att ett nytt direktuppspelningsjobb skapas, men för att förhindra uppdatering av en befintlig postuppsättning. Andra värden resulterar i ett 412-förvillkor misslyckades svar.

Begärandetext

Name	Typ	Description
identity	Identity	Beskriver den systemtilldelade hanterade identiteten som tilldelats det här jobbet och som kan användas för att autentisera med indata och utdata.
location	string	Den geo-plats där resursen finns
properties.cluster	ClusterInfo	Klustret som strömmande jobb ska köras på.
properties.compatibilityLevel	CompatibilityLevel	Styr vissa körningsbeteenden för strömningsjobbet.
properties.contentStoragePolicy	ContentStoragePolicy	Giltiga värden är JobStorageAccount och SystemAccount. Om värdet är JobStorageAccount kräver detta att användaren även anger egenskapen jobStorageAccount. .
properties.dataLocale	string	Dataspråket för stream analytics-jobbet. Värdet ska vara namnet på en .NET-kultur som stöds från uppsättningen https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Standardvärdet är "en-US" om inget anges.
properties.eventsLateArrivalMaxDelayInSeconds	integer	Den maximala tolerabla fördröjningen i sekunder där händelser som kommer sent kan inkluderas. Intervallet som stöds är -1 till 1814399 (20.23:59:59 dagar) och -1 används för att ange väntetid på obestämd tid. Om egenskapen saknas tolkas den som -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	Den maximala tolerabla fördröjningen i sekunder där out-of-order-händelser kan justeras för att vara tillbaka i ordning.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Anger vilken princip som ska tillämpas på händelser som tas emot i fel ordning i indatahändelseströmmen.
properties.functions	Function[]	En lista över en eller flera funktioner för strömningsjobbet. Namnegenskapen för varje funktion krävs när du anger den här egenskapen i en PUT-begäran. Det går inte att ändra den här egenskapen via en PATCH-åtgärd. Du måste använda PATCH-API:et som är tillgängligt för den enskilda omvandlingen.
properties.inputs	Input[]	En lista över en eller flera indata till strömningsjobbet. Namnegenskapen för varje indata krävs när du anger den här egenskapen i en PUT-begäran. Det går inte att ändra den här egenskapen via en PATCH-åtgärd. Du måste använda PATCH-API:et som är tillgängligt för enskilda indata.
properties.jobStorageAccount	JobStorageAccount	De egenskaper som är associerade med ett Azure Storage-konto med MSI
properties.jobType	JobType	Beskriver typen av jobb. Giltiga lägen är `Cloud` och "Edge".
properties.outputErrorPolicy	OutputErrorPolicy	Anger vilken princip som ska tillämpas på händelser som anländer till utdata och som inte kan skrivas till den externa lagringen på grund av att de är felaktiga (saknade kolumnvärden, kolumnvärden av fel typ eller storlek).
properties.outputStartMode	OutputStartMode	Den här egenskapen bör endast användas när du vill att jobbet ska startas omedelbart när du har skapat den. Värdet kan vara JobStartTime, CustomTime eller LastOutputEventTime för att ange om startpunkten för utdatahändelseströmmen ska starta när jobbet startas, starta vid en anpassad användartidsstämpel som anges via egenskapen outputStartTime eller starta från den senaste händelseutdatatiden.
properties.outputStartTime	string	Värdet är antingen en ISO-8601-formaterad tidsstämpel som anger startpunkten för utdatahändelseströmmen eller null för att indikera att utdatahändelseströmmen startar när direktuppspelningsjobbet startas. Den här egenskapen måste ha ett värde om outputStartMode är inställt på CustomTime.
properties.outputs	Output[]	En lista över en eller flera utdata för strömningsjobbet. Namnegenskapen för varje utdata krävs när du anger den här egenskapen i en PUT-begäran. Det går inte att ändra den här egenskapen via en PATCH-åtgärd. Du måste använda PATCH-API:et som är tillgängligt för enskilda utdata.
properties.sku	Sku	Beskriver SKU:n för strömningsjobbet. Krävs för PUT-begäranden (CreateOrReplace).
properties.transformation	Transformation	Anger frågan och antalet strömningsenheter som ska användas för strömningsjobbet. Namnegenskapen för omvandlingen krävs när du anger den här egenskapen i en PUT-begäran. Det går inte att ändra den här egenskapen via en PATCH-åtgärd. Du måste använda PATCH-API:et som är tillgängligt för den enskilda omvandlingen.
tags	object	Resurstaggar.

Svar

Name	Typ	Description
200 OK	StreamingJob	Direktuppspelningsjobbet har skapats eller ersatts. Sidhuvuden ETag: string
201 Created	StreamingJob	Direktuppspelningsjobbet har skapats eller ersatts. Sidhuvuden ETag: string
Other Status Codes	Error	Fel.

Name

Typ

Description

200 OK

StreamingJob

Direktuppspelningsjobbet har skapats eller ersatts.

Sidhuvuden

ETag: string

201 Created

StreamingJob

Direktuppspelningsjobbet har skapats eller ersatts.

Sidhuvuden

ETag: string

Other Status Codes

Error

Fel.

Säkerhet

azure_auth

Azure Active Directory OAuth2 Flow

Typ: oauth2
Flow: implicit
Auktoriseringswebbadress: https://login.microsoftonline.com/common/oauth2/authorize

Omfattningar

Name	Description
user_impersonation	personifiera ditt användarkonto

Exempel

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)

Exempelbegäran

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

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


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

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

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

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

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

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

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

createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output().catch(
  console.error
);

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

Exempelsvar

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

Statuskod:: 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)

Exempelbegäran

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

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


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

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

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

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

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

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

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

createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions().catch(
  console.error
);

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

Exempelsvar

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

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

Definitioner

Name	Description
AggregateFunctionProperties	De egenskaper som är associerade med en mängdfunktion.
AuthenticationMode	Autentiseringsläge. Giltiga lägen är `ConnectionString`, `Msi` och UserToken.
AvroSerialization	Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata i Avro-format.
AzureDataLakeStoreOutputDataSource	Beskriver en Azure Data Lake Store-utdatakälla.
AzureFunctionOutputDataSource	Definierar metadata för AzureFunctionOutputDataSource
AzureMachineLearningWebServiceFunctionBinding	Bindningen till en Azure Machine Learning-webbtjänst.
AzureMachineLearningWebServiceInputColumn	Beskriver en indatakolumn för Azure Machine Learning-webbtjänstslutpunkten.
AzureMachineLearningWebServiceInputs	Indata för Azure Machine Learning-webbtjänstslutpunkten.
AzureMachineLearningWebServiceOutputColumn	Beskriver en utdatakolumn för Azure Machine Learning-webbtjänstslutpunkten.
AzureSqlDatabaseOutputDataSource	Beskriver en Azure SQL utdatakälla för databasen.
AzureSqlReferenceInputDataSource	Beskriver en Azure SQL databasreferensens indatakälla.
AzureSynapseOutputDataSource	Beskriver en Azure Synapse utdatakälla.
AzureTableOutputDataSource	Beskriver en Azure Table-utdatakälla.
BlobOutputDataSource	Beskriver en blob-utdatakälla.
BlobReferenceInputDataSource	Beskriver en blobindatakälla som innehåller referensdata.
BlobStreamInputDataSource	Beskriver en blobindatakälla som innehåller dataströmmar.
ClusterInfo	Egenskaperna som är associerade med ett Stream Analytics-kluster.
CompatibilityLevel	Styr vissa körningsbeteenden för strömningsjobbet.
Compression	Beskriver hur indata komprimeras
CompressionType	Anger vilken typ av komprimering som indata använder. Krävs för PUT-begäranden (CreateOrReplace).
ContentStoragePolicy	Giltiga värden är JobStorageAccount och SystemAccount. Om värdet är JobStorageAccount kräver detta att användaren även anger egenskapen jobStorageAccount. .
CsvSerialization	Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata i CSV-format.
DiagnosticCondition	Villkor som gäller för resursen, eller för jobbet totalt sett, som motiverar kundernas uppmärksamhet.
Diagnostics	Beskriver de villkor som gäller för indata, utdata eller det övergripande jobbet som berättigar till kund uppmärksamhet.
DocumentDbOutputDataSource	Beskriver en DocumentDB-utdatakälla.
Encoding	Anger kodningen av inkommande data vid indata och kodning av utgående data när det gäller utdata.
Error	Vanlig felrepresentation.
EventHubOutputDataSource	Beskriver en händelsehubbs utdatakälla.
EventHubStreamInputDataSource	Beskriver en Händelsehubb-indatakälla som innehåller dataström.
EventHubV2OutputDataSource	Beskriver en händelsehubbs utdatakälla.
EventHubV2StreamInputDataSource	Beskriver en Händelsehubb-indatakälla som innehåller dataström.
EventSerializationType	Anger vilken typ av serialisering som indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).
EventsOutOfOrderPolicy	Anger principen som ska tillämpas på händelser som tas emot i fel ordning i indatahändelseströmmen.
FileReferenceInputDataSource	Beskriver en filindatakälla som innehåller referensdata.
Function	Ett funktionsobjekt som innehåller all information som är associerad med den namngivna funktionen. Alla funktioner finns under ett strömningsjobb.
FunctionInput	Beskriver en indataparameter för en funktion.
FunctionOutput	Beskriver utdata för en funktion.
GatewayMessageBusOutputDataSource	Beskriver en Gateway Message Bus-utdatakälla.
GatewayMessageBusStreamInputDataSource	Beskriver en blobindatakälla som innehåller dataströmmar.
Identity	Beskriver hur identitet verifieras
Input	Ett indataobjekt som innehåller all information som är associerad med de namngivna indata. Alla indata finns under ett strömningsjobb.
IoTHubStreamInputDataSource	Beskriver en IoT Hub indatakälla som innehåller dataström.
JavaScriptFunctionBinding	Bindningen till en JavaScript-funktion.
JobStorageAccount	De egenskaper som är associerade med ett Azure Storage-konto med MSI
JobType	Beskriver typen av jobb. Giltiga lägen är `Cloud` och "Edge".
JsonOutputSerializationFormat	Anger formatet för JSON som utdata ska skrivas i. De värden som stöds för närvarande är "lineSeparated" som anger att utdata kommer att formateras genom att varje JSON-objekt avgränsas med en ny rad och "matris" som anger att utdata kommer att formateras som en matris med JSON-objekt.
JsonSerialization	Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata i JSON-format.
Output	Ett utdataobjekt som innehåller all information som är associerad med de namngivna utdata. Alla utdata finns under ett strömningsjobb.
OutputErrorPolicy	Anger principen som ska tillämpas på händelser som kommer till utdata och inte kan skrivas till den externa lagringen på grund av att de är felaktiga (saknade kolumnvärden, kolumnvärden av fel typ eller storlek).
OutputStartMode	Värdet kan vara JobStartTime, CustomTime eller LastOutputEventTime för att ange om startpunkten för utdatahändelseströmmen ska starta när jobbet startas, starta vid en anpassad användartidsstämpel som anges via egenskapen outputStartTime eller starta från den senaste händelsens utdatatid.
ParquetSerialization	Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata i Parquet-format.
PowerBIOutputDataSource	Beskriver en Power BI-utdatakälla.
ReferenceInputProperties	De egenskaper som är associerade med indata som innehåller referensdata.
RefreshType	Anger typen av datauppdateringsalternativ.
ScalarFunctionProperties	De egenskaper som är associerade med en skalär funktion.
ServiceBusQueueOutputDataSource	Beskriver en utdatakälla för Service Bus-kön.
ServiceBusTopicOutputDataSource	Beskriver en utdatakälla för Service Bus-ämnet.
Sku	De egenskaper som är associerade med en SKU.
SkuName	Namnet på SKU:n. Krävs för PUT-begäranden (CreateOrReplace).
StorageAccount	De egenskaper som är associerade med ett Azure Storage-konto
StreamingJob	Ett direktuppspelningsjobbobjekt som innehåller all information som är associerad med det namngivna strömningsjobbet.
StreamInputProperties	De egenskaper som är associerade med indata som innehåller dataströmmen.
Transformation	Ett transformeringsobjekt som innehåller all information som är associerad med den namngivna omvandlingen. Alla transformeringar finns under ett strömningsjobb.

AggregateFunctionProperties

De egenskaper som är associerade med en mängdfunktion.

Name	Typ	Description
etag	string	Den aktuella entitetstaggen för funktionen. Det här är en täckande sträng. Du kan använda den för att identifiera om resursen har ändrats mellan begäranden. Du kan också använda den i rubrikerna If-Match eller If-None-Match för skrivåtgärder för optimistisk samtidighet.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Funktionens fysiska bindning. I Azure Machine Learning-webbtjänstens fall beskriver detta till exempel slutpunkten.
properties.inputs	FunctionInput[]	Beskriver en indataparameter för en funktion.
properties.output	FunctionOutput	Beskriver utdata från en funktion.
type	string: Aggregate	Anger typen av funktion.

AuthenticationMode

Autentiseringsläge. Giltiga lägen är ConnectionString, Msi och UserToken.

Name	Typ	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata i Avro-format.

Name	Typ	Description
type	string: Avro	Anger vilken typ av serialisering som används av indata eller utdata. Krävs för PUT-begäranden (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Beskriver en Azure Data Lake Store-utdatakälla.

Name	Typ	Standardvärde	Description
properties.accountName	string		Namnet på Azure Data Lake Store-kontot. Krävs för PUT-begäranden (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.dateFormat	string		Datumformatet. Oavsett var {date} visas i filePathPrefix används värdet för den här egenskapen som datumformat i stället.
properties.filePathPrefix	string		Platsen för filen som utdata ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).
properties.refreshToken	string		En uppdateringstoken som kan användas för att hämta en giltig åtkomsttoken som sedan kan användas för att autentisera med datakällan. En giltig uppdateringstoken kan för närvarande endast hämtas via Azure-portalen. Vi rekommenderar att du placerar ett dummy-strängvärde här när du skapar datakällan och sedan går till Azure-portalen för att autentisera datakällan som uppdaterar den här egenskapen med en giltig uppdateringstoken. Krävs för PUT-begäranden (CreateOrReplace).
properties.tenantId	string		Klient-ID:t för den användare som användes för att hämta uppdateringstoken. Krävs för PUT-begäranden (CreateOrReplace).
properties.timeFormat	string		Tidsformatet. Oavsett var {time} visas i filePathPrefix används värdet för den här egenskapen som tidsformat i stället.
properties.tokenUserDisplayName	string		Användarens visningsnamn för den användare som användes för att hämta uppdateringstoken. Använd den här egenskapen för att komma ihåg vilken användare som användes för att hämta uppdateringstoken.
properties.tokenUserPrincipalName	string		Användarens huvudnamn (UPN) för den användare som användes för att hämta uppdateringstoken. Använd den här egenskapen för att komma ihåg vilken användare som användes för att hämta uppdateringstoken.
type	string: Microsoft.DataLake/Accounts		Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

AzureFunctionOutputDataSource

Definierar metadata för AzureFunctionOutputDataSource

Name	Typ	Description
properties.apiKey	string	Om du vill använda en Azure-funktion från en annan prenumeration kan du göra det genom att ange nyckeln för att få åtkomst till din funktion.
properties.functionAppName	string	Namnet på din Azure Functions app.
properties.functionName	string	Namnet på funktionen i din Azure Functions-app.
properties.maxBatchCount	number	En egenskap som låter dig ange det maximala antalet händelser i varje batch som skickas till Azure Functions. Standardvärdet är 100.
properties.maxBatchSize	number	En egenskap som gör att du kan ange maximal storlek för varje utdatabatch som skickas till din Azure-funktion. Indataenheten är i byte. Som standard är det här värdet 262 144 byte (256 KB).
type	string: Microsoft.AzureFunction	Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

Bindningen till en Azure Machine Learning-webbtjänst.

Name	Typ	Description
properties.apiKey	string	API-nyckeln som används för att autentisera med Request-Response slutpunkt.
properties.batchSize	integer	Tal mellan 1 och 10000 som beskriver det maximala antalet rader för varje Azure ML RRS-körningsbegäran. Standardvärdet är 1 000.
properties.endpoint	string	Request-Response köra slutpunkten för Azure Machine Learning-webbtjänsten. Läs mer här: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
properties.inputs	AzureMachineLearningWebServiceInputs	Indata för Azure Machine Learning-webbtjänstslutpunkten.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	En lista över utdata från Azure Machine Learning-webbtjänstens slutpunktskörning.
type	string: Microsoft.MachineLearning/WebService	Anger funktionens bindningstyp.

AzureMachineLearningWebServiceInputColumn

Beskriver en indatakolumn för Azure Machine Learning-webbtjänstslutpunkten.

Name	Typ	Description
dataType	string	Datatypen (Azure Machine Learning stöds) för indatakolumnen. En lista över giltiga Azure Machine Learning-datatyper beskrivs i https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
mapTo	integer	Det nollbaserade indexet för funktionsparametern som den här indatan mappar till.
name	string	Namnet på indatakolumnen.

AzureMachineLearningWebServiceInputs

Indata för Azure Machine Learning-webbtjänstslutpunkten.

Name	Typ	Description
columnNames	AzureMachineLearningWebServiceInputColumn[]	En lista över indatakolumner för Azure Machine Learning-webbtjänstslutpunkten.
name	string	Namnet på indata. Det här är namnet som angavs när slutpunkten redigeras.

AzureMachineLearningWebServiceOutputColumn

Beskriver en utdatakolumn för Azure Machine Learning-webbtjänstslutpunkten.

Name	Typ	Description
dataType	string	Datatypen (Azure Machine Learning stöds) för utdatakolumnen. En lista över giltiga Azure Machine Learning-datatyper beskrivs i https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
name	string	Namnet på utdatakolumnen.

AzureSqlDatabaseOutputDataSource

Beskriver en Azure SQL utdatakälla för databasen.

Name	Typ	Standardvärde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.database	string		Namnet på den Azure SQL databasen. Krävs för PUT-begäranden (CreateOrReplace).
properties.maxBatchCount	number		Maximalt antal batchar för skrivning till Sql-databas. Standardvärdet är 10 000. Valfritt för PUT-begäranden.
properties.maxWriterCount	number		Maximalt antal skrivare, för närvarande är endast 1 (enskild skrivare) och 0 (baserat på frågepartition) tillgängliga. Valfritt för PUT-begäranden.
properties.password	string		Lösenordet som ska användas för att ansluta till Azure SQL-databasen. Krävs för PUT-begäranden (CreateOrReplace).
properties.server	string		Namnet på DEN SQL-server som innehåller Azure SQL-databasen. Krävs för PUT-begäranden (CreateOrReplace).
properties.table	string		Namnet på tabellen i Azure SQL-databasen. Krävs för PUT-begäranden (CreateOrReplace).
properties.user	string		Det användarnamn som ska användas för att ansluta till Azure SQL-databasen. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.Sql/Server/Database		Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

AzureSqlReferenceInputDataSource

Beskriver en Azure SQL databasreferensens indatakälla.

Name	Typ	Description
properties.database	string	Det här elementet är associerat med datakällans element. Det här är namnet på databasen som utdata skrivs till.
properties.deltaSnapshotQuery	string	Det här elementet är associerat med datakällans element. Den här frågan används för att hämta inkrementella ändringar från SQL-databasen. Om du vill använda det här alternativet rekommenderar vi att du använder temporala tabeller i Azure SQL Database.
properties.fullSnapshotQuery	string	Det här elementet är associerat med datakällans element. Den här frågan används för att hämta data från sql-databasen.
properties.password	string	Det här elementet är associerat med datakällans element. Det här är lösenordet som ska användas för att ansluta till SQL Database-instansen.
properties.refreshRate	string	Det här elementet är associerat med datakällans element. Detta anger hur ofta data hämtas från databasen. Det är i DateTime-format.
properties.refreshType	RefreshType	Anger typen av datauppdateringsalternativ.
properties.server	string	Det här elementet är associerat med datakällans element. Det här är namnet på den server som innehåller databasen som ska skrivas till.
properties.table	string	Det här elementet är associerat med datakällans element. Namnet på tabellen i Azure SQL-databasen..
properties.user	string	Det här elementet är associerat med datakällans element. Det här är användarnamnet som ska användas för att ansluta till SQL Database-instansen.
type	string: Microsoft.Sql/Server/Database	Anger vilken typ av indatakälla som innehåller referensdata. Krävs för PUT-begäranden (CreateOrReplace).

AzureSynapseOutputDataSource

Beskriver en Azure Synapse utdatakälla.

Name	Typ	Description
properties.database	string	Namnet på den Azure SQL databasen. Krävs för PUT-begäranden (CreateOrReplace).
properties.password	string	Lösenordet som ska användas för att ansluta till Azure SQL-databasen. Krävs för PUT-begäranden (CreateOrReplace).
properties.server	string	Namnet på DEN SQL-server som innehåller Azure SQL-databasen. Krävs för PUT-begäranden (CreateOrReplace).
properties.table	string	Namnet på tabellen i Azure SQL-databasen. Krävs för PUT-begäranden (CreateOrReplace).
properties.user	string	Det användarnamn som ska användas för att ansluta till Azure SQL-databasen. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.Sql/Server/DataWarehouse	Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

AzureTableOutputDataSource

Beskriver en Azure Table-utdatakälla.

Name	Typ	Description
properties.accountKey	string	Kontonyckeln för Azure Storage-kontot. Krävs för PUT-begäranden (CreateOrReplace).
properties.accountName	string	Namnet på Azure Storage-kontot. Krävs för PUT-begäranden (CreateOrReplace).
properties.batchSize	integer	Antalet rader som ska skrivas till Azure-tabellen åt gången.
properties.columnsToRemove	string[]	Om det anges är varje objekt i matrisen namnet på en kolumn som ska tas bort (om det finns) från utdatahändelseentiteter.
properties.partitionKey	string	Det här elementet anger namnet på en kolumn från SELECT-instruktionen i frågan som ska användas som partitionsnyckel för Azure-tabellen. Krävs för PUT-begäranden (CreateOrReplace).
properties.rowKey	string	Det här elementet anger namnet på en kolumn från SELECT-instruktionen i frågan som ska användas som radnyckel för Azure Table. Krävs för PUT-begäranden (CreateOrReplace).
properties.table	string	Namnet på Azure-tabellen. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.Storage/Table	Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

BlobOutputDataSource

Beskriver en blob-utdatakälla.

Name	Typ	Standardvärde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.blobPathPrefix	string		Prefix för blobsökväg.
properties.container	string		Namnet på en container i det associerade lagringskontot. Den här containern innehåller antingen de blobar som ska läsas från eller skrivas till. Krävs för PUT-begäranden (CreateOrReplace).
properties.dateFormat	string		Datumformatet. Oavsett var {date} visas i pathPattern används värdet för den här egenskapen som datumformat i stället.
properties.pathPattern	string		Mönstret för blobsökväg. Inte ett reguljärt uttryck. Den representerar ett mönster mot vilket blobnamn matchas för att avgöra om de ska inkluderas som indata eller utdata till jobbet. Se https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input eller https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output för en mer detaljerad förklaring och exempel.
properties.storageAccounts	StorageAccount[]		En lista över ett eller flera Azure Storage-konton. Krävs för PUT-begäranden (CreateOrReplace).
properties.timeFormat	string		Tidsformatet. Oavsett var {time} visas i pathPattern används värdet för den här egenskapen som tidsformat i stället.
type	string: Microsoft.Storage/Blob		Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

BlobReferenceInputDataSource

Beskriver en blobindatakälla som innehåller referensdata.

Name	Typ	Standardvärde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.container	string		Namnet på en container i det associerade lagringskontot. Den här containern innehåller antingen de blobar som ska läsas från eller skrivas till. Krävs för PUT-begäranden (CreateOrReplace).
properties.dateFormat	string		Datumformatet. Oavsett var {date} visas i pathPattern används värdet för den här egenskapen som datumformat i stället.
properties.pathPattern	string		Mönstret för blobsökväg. Inte ett reguljärt uttryck. Den representerar ett mönster som blobnamnen ska matchas mot för att avgöra om de ska inkluderas som indata eller utdata till jobbet eller inte. Se https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input eller https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output för en mer detaljerad förklaring och exempel.
properties.storageAccounts	StorageAccount[]		En lista över ett eller flera Azure Storage-konton. Krävs för PUT-begäranden (CreateOrReplace).
properties.timeFormat	string		Tidsformatet. Oavsett var {time} visas i pathPattern används värdet för den här egenskapen som tidsformat i stället.
type	string: Microsoft.Storage/Blob		Anger vilken typ av indatakälla som innehåller referensdata. Krävs för PUT-begäranden (CreateOrReplace).

BlobStreamInputDataSource

Beskriver en blobindatakälla som innehåller dataströmmar.

Name	Typ	Standardvärde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.container	string		Namnet på en container i det associerade lagringskontot. Den här containern innehåller antingen de blobar som ska läsas från eller skrivas till. Krävs för PUT-begäranden (CreateOrReplace).
properties.dateFormat	string		Datumformatet. Oavsett var {date} visas i pathPattern används värdet för den här egenskapen som datumformat i stället.
properties.pathPattern	string		Mönstret för blobsökväg. Inte ett reguljärt uttryck. Den representerar ett mönster som blobnamnen ska matchas mot för att avgöra om de ska inkluderas som indata eller utdata till jobbet eller inte. Se https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input eller https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output för en mer detaljerad förklaring och exempel.
properties.sourcePartitionCount	integer		Partitionsantalet för blobindatakällan. Intervall 1 – 1024.
properties.storageAccounts	StorageAccount[]		En lista över ett eller flera Azure Storage-konton. Krävs för PUT-begäranden (CreateOrReplace).
properties.timeFormat	string		Tidsformatet. Oavsett var {time} visas i pathPattern används värdet för den här egenskapen som tidsformat i stället.
type	string: Microsoft.Storage/Blob		Anger vilken typ av indatakälla som innehåller dataström. Krävs för PUT-begäranden (CreateOrReplace).

ClusterInfo

Egenskaperna som är associerade med ett Stream Analytics-kluster.

Name	Typ	Description
id	string	Resurs-ID för klustret.

CompatibilityLevel

Styr vissa körningsbeteenden för strömningsjobbet.

Name	Typ	Description
1.0	string
1.2	string

Compression

Beskriver hur indata komprimeras

Name	Typ	Standardvärde	Description
type	CompressionType	None	Anger vilken typ av komprimering som indata använder. Krävs för PUT-begäranden (CreateOrReplace).

CompressionType

Anger vilken typ av komprimering som indata använder. Krävs för PUT-begäranden (CreateOrReplace).

Name	Typ	Description
Deflate	string
GZip	string
None	string

ContentStoragePolicy

Giltiga värden är JobStorageAccount och SystemAccount. Om värdet är JobStorageAccount kräver detta att användaren även anger egenskapen jobStorageAccount. .

Name	Typ	Description
JobStorageAccount	string
SystemAccount	string

CsvSerialization

Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata i CSV-format.

Name	Typ	Description
properties.encoding	Encoding	Anger kodningen av inkommande data vid indata och kodning av utgående data vid utdata. Krävs för PUT-begäranden (CreateOrReplace).
properties.fieldDelimiter	string	Anger avgränsare som ska användas för att separera kommaavgränsade värdeposter (CSV). Se https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input eller https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output för en lista över värden som stöds. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Csv	Anger vilken typ av serialisering som används av indata eller utdata. Krävs för PUT-begäranden (CreateOrReplace).

DiagnosticCondition

Villkor som gäller för resursen, eller för jobbet totalt sett, som motiverar kundernas uppmärksamhet.

Name	Typ	Description
code	string	Den täckande diagnostikkoden.
message	string	Det läsbara meddelandet som beskriver villkoret i detalj. Lokaliserad i Accept-Language för klientbegäran.
since	string	UTC-tidsstämpeln för när villkoret startades. Kunder bör kunna hitta en motsvarande händelse i ops-loggen runt den här gången.

Diagnostics

Beskriver de villkor som gäller för indata, utdata eller det övergripande jobbet som berättigar till kund uppmärksamhet.

Name	Typ	Description
conditions	DiagnosticCondition[]	En samling med noll eller fler villkor som gäller för resursen, eller för jobbet som helhet, som motiverar kundernas uppmärksamhet.

DocumentDbOutputDataSource

Beskriver en DocumentDB-utdatakälla.

Name	Typ	Description
properties.accountId	string	DocumentDB-kontonamnet eller ID:t. Krävs för PUT-begäranden (CreateOrReplace).
properties.accountKey	string	Kontonyckeln för DocumentDB-kontot. Krävs för PUT-begäranden (CreateOrReplace).
properties.collectionNamePattern	string	Mönstret för samlingsnamn för samlingarna som ska användas. Samlingsnamnformatet kan konstrueras med hjälp av den valfria {partition}-token, där partitionerna börjar från 0. Mer information finns i avsnittet https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output DocumentDB. Krävs för PUT-begäranden (CreateOrReplace).
properties.database	string	Namnet på DocumentDB-databasen. Krävs för PUT-begäranden (CreateOrReplace).
properties.documentId	string	Namnet på fältet i utdatahändelser som används för att ange den primära nyckel som infognings- eller uppdateringsåtgärder baseras på.
properties.partitionKey	string	Namnet på fältet i utdatahändelser som används för att ange nyckeln för partitionering av utdata mellan samlingar. Om "collectionNamePattern" innehåller token {partition} måste den här egenskapen anges.
type	string: Microsoft.Storage/DocumentDB	Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

Encoding

Anger kodningen av inkommande data vid indata och kodning av utgående data när det gäller utdata.

Name	Typ	Description
UTF8	string

Error

Vanlig felrepresentation.

Name	Typ	Description
error	Error	Egenskaper för feldefinition.

EventHubOutputDataSource

Beskriver en händelsehubbs utdatakälla.

Name	Typ	Standardvärde	Description
authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.eventHubName	string		Namnet på händelsehubben. Krävs för PUT-begäranden (CreateOrReplace).
properties.partitionKey	string		Den nyckel/kolumn som används för att avgöra till vilken partition som händelsedata ska skickas.
properties.propertyColumns	string[]		De egenskaper som är associerade med händelsehubbens utdata.
serviceBusNamespace	string		Namnområdet som är associerat med önskad händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
sharedAccessPolicyKey	string		Principnyckeln för delad åtkomst för den angivna principen för delad åtkomst. Krävs för PUT-begäranden (CreateOrReplace).
sharedAccessPolicyName	string		Namnet på principen för delad åtkomst för Händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

EventHubStreamInputDataSource

Beskriver en Händelsehubb-indatakälla som innehåller dataström.

Name	Typ	Standardvärde	Description
authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.consumerGroupName	string		Namnet på en händelsehubbkonsumentgrupp som ska användas för att läsa händelser från händelsehubben. Om du anger distinkta konsumentgruppnamn för flera indata kan var och en av dessa indata ta emot samma händelser från händelsehubben. Om inget anges använder indata händelsehubbens standardkonsumentgrupp.
properties.eventHubName	string		Namnet på händelsehubben. Krävs för PUT-begäranden (CreateOrReplace).
serviceBusNamespace	string		Namnområdet som är associerat med önskad händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
sharedAccessPolicyKey	string		Principnyckeln för delad åtkomst för den angivna principen för delad åtkomst. Krävs för PUT-begäranden (CreateOrReplace).
sharedAccessPolicyName	string		Namnet på principen för delad åtkomst för Händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Anger vilken typ av indatakälla som innehåller dataström. Krävs för PUT-begäranden (CreateOrReplace).

EventHubV2OutputDataSource

Beskriver en händelsehubbs utdatakälla.

Name	Typ	Standardvärde	Description
authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.eventHubName	string		Namnet på händelsehubben. Krävs för PUT-begäranden (CreateOrReplace).
properties.partitionKey	string		Den nyckel/kolumn som används för att avgöra till vilken partition som händelsedata ska skickas.
properties.propertyColumns	string[]		De egenskaper som är associerade med händelsehubbens utdata.
serviceBusNamespace	string		Namnområdet som är associerat med önskad händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
sharedAccessPolicyKey	string		Principnyckeln för delad åtkomst för den angivna principen för delad åtkomst. Krävs för PUT-begäranden (CreateOrReplace).
sharedAccessPolicyName	string		Namnet på principen för delad åtkomst för Händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

EventHubV2StreamInputDataSource

Beskriver en Händelsehubb-indatakälla som innehåller dataström.

Name	Typ	Standardvärde	Description
authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.consumerGroupName	string		Namnet på en händelsehubbkonsumentgrupp som ska användas för att läsa händelser från händelsehubben. Om du anger distinkta konsumentgruppnamn för flera indata kan var och en av dessa indata ta emot samma händelser från händelsehubben. Om inget anges använder indata händelsehubbens standardkonsumentgrupp.
properties.eventHubName	string		Namnet på händelsehubben. Krävs för PUT-begäranden (CreateOrReplace).
serviceBusNamespace	string		Namnområdet som är associerat med önskad händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
sharedAccessPolicyKey	string		Principnyckeln för delad åtkomst för den angivna principen för delad åtkomst. Krävs för PUT-begäranden (CreateOrReplace).
sharedAccessPolicyName	string		Namnet på principen för delad åtkomst för Händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Anger vilken typ av indatakälla som innehåller dataström. Krävs för PUT-begäranden (CreateOrReplace).

EventSerializationType

Anger vilken typ av serialisering som indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).

Name	Typ	Description
Avro	string
Csv	string
Json	string
Parquet	string

EventsOutOfOrderPolicy

Anger principen som ska tillämpas på händelser som tas emot i fel ordning i indatahändelseströmmen.

Name	Typ	Description
Adjust	string
Drop	string

FileReferenceInputDataSource

Beskriver en filindatakälla som innehåller referensdata.

Name	Typ	Description
properties.path	string	Sökvägen till filen.
type	string: File	Anger vilken typ av indatakälla som innehåller referensdata. Krävs för PUT-begäranden (CreateOrReplace).

Function

Ett funktionsobjekt som innehåller all information som är associerad med den namngivna funktionen. Alla funktioner finns under ett strömningsjobb.

Name	Typ	Description
id	string	Resurs-ID
name	string	Resursnamn
properties	FunctionProperties: AggregateFunctionProperties ScalarFunctionProperties	De egenskaper som är associerade med en funktion.
type	string	Resurstyp

FunctionInput

Beskriver en indataparameter för en funktion.

Name	Typ	Description
dataType	string	Datatypen (Azure Stream Analytics stöds) för funktionens indataparameter. En lista över giltiga Azure Stream Analytics-datatyper beskrivs på https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	En flagga som anger om parametern är en konfigurationsparameter. Sant om den här indataparametern förväntas vara en konstant. Standardvärdet är false.

FunctionOutput

Beskriver utdata för en funktion.

Name	Typ	Description
dataType	string	Datatypen (Azure Stream Analytics stöds) för funktionens utdata. En lista över giltiga Azure Stream Analytics-datatyper beskrivs på https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

Beskriver en Gateway Message Bus-utdatakälla.

Name	Typ	Description
properties.topic	string	Namnet på Service Bus-ämnet.
type	string: GatewayMessageBus	Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Beskriver en blobindatakälla som innehåller dataströmmar.

Name	Typ	Description
properties.topic	string	Namnet på Service Bus-ämnet.
type	string: GatewayMessageBus	Anger vilken typ av indatakälla som innehåller dataström. Krävs för PUT-begäranden (CreateOrReplace).

Identity

Beskriver hur identitet verifieras

Name	Typ	Description
principalId	string	Identitetens huvudnamns-ID
tenantId	string	Identitetens tenantId
type	string	Identitetstypen

Input

Ett indataobjekt som innehåller all information som är associerad med de namngivna indata. Alla indata finns under ett strömningsjobb.

Name	Typ	Description
id	string	Resurs-ID
name	string	Resursnamn
properties	InputProperties: ReferenceInputProperties StreamInputProperties	De egenskaper som är associerade med indata. Krävs för PUT-begäranden (CreateOrReplace).
type	string	Resurstyp

IoTHubStreamInputDataSource

Beskriver en IoT Hub indatakälla som innehåller dataström.

Name	Typ	Description
properties.consumerGroupName	string	Namnet på en IoT Hub konsumentgrupp som ska användas för att läsa händelser från IoT Hub. Om inte anges använder indata Iot Hubs standardkonsumentgrupp.
properties.endpoint	string	Den IoT Hub slutpunkten som ska anslutas till (t.ex. meddelanden/händelser, meddelanden/åtgärderÖvervakaHändelse osv.).
properties.iotHubNamespace	string	Namnet eller URI:n för IoT Hub. Krävs för PUT-begäranden (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Principnyckeln för delad åtkomst för den angivna principen för delad åtkomst. Krävs för PUT-begäranden (CreateOrReplace).
properties.sharedAccessPolicyName	string	Namnet på principen för delad åtkomst för IoT Hub. Den här principen måste innehålla minst behörigheten Tjänstanslutning. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Anger vilken typ av indatakälla som innehåller dataström. Krävs för PUT-begäranden (CreateOrReplace).

JavaScriptFunctionBinding

Bindningen till en JavaScript-funktion.

Name	Typ	Description
properties.script	string	JavaScript-koden som innehåller en enda funktionsdefinition. Exempel: "function (x, y) { return x + y; }"
type	string: Microsoft.StreamAnalytics/JavascriptUdf	Anger funktionens bindningstyp.

JobStorageAccount

De egenskaper som är associerade med ett Azure Storage-konto med MSI

Name	Typ	Standardvärde	Description
accountKey	string		Kontonyckeln för Azure Storage-kontot. Krävs för PUT-begäranden (CreateOrReplace).
accountName	string		Namnet på Azure Storage-kontot. Krävs för PUT-begäranden (CreateOrReplace).
authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.

JobType

Beskriver typen av jobb. Giltiga lägen är Cloud och "Edge".

Name	Typ	Description
Cloud	string
Edge	string

JsonOutputSerializationFormat

Anger formatet för JSON som utdata ska skrivas i. De värden som stöds för närvarande är "lineSeparated" som anger att utdata kommer att formateras genom att varje JSON-objekt avgränsas med en ny rad och "matris" som anger att utdata kommer att formateras som en matris med JSON-objekt.

Name	Typ	Description
Array	string
LineSeparated	string

JsonSerialization

Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata i JSON-format.

Name	Typ	Description
properties.encoding	Encoding	Anger kodningen av inkommande data vid indata och kodning av utgående data vid utdata. Krävs för PUT-begäranden (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Den här egenskapen gäller endast för JSON-serialisering av utdata. Det är inte tillämpligt på indata. Den här egenskapen anger formatet för den JSON som utdata ska skrivas i. De värden som stöds för närvarande är "lineSeparated" som anger att utdata formateras genom att varje JSON-objekt avgränsas med en ny rad och "matris" som anger att utdata formateras som en matris med JSON-objekt. Standardvärdet är "lineSeparated" om det lämnas null.
type	string: Json	Anger vilken typ av serialisering som används av indata eller utdata. Krävs för PUT-begäranden (CreateOrReplace).

Output

Ett utdataobjekt som innehåller all information som är associerad med de namngivna utdata. Alla utdata finns under ett strömningsjobb.

Name	Typ	Description
id	string	Resurs-ID
name	string	Resursnamn
properties.datasource	OutputDataSource: AzureDataLakeStoreOutputDataSource AzureFunctionOutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource AzureTableOutputDataSource BlobOutputDataSource DocumentDbOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource GatewayMessageBusOutputDataSource PowerBIOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource	Beskriver den datakälla som utdata ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).
properties.diagnostics	Diagnostics	Beskriver de villkor som gäller för indata, utdata eller det övergripande jobbet som berättigar till kund uppmärksamhet.
properties.etag	string	Den aktuella entitetstaggen för utdata. Det här är en täckande sträng. Du kan använda den för att identifiera om resursen har ändrats mellan begäranden. Du kan också använda den i rubrikerna If-Match eller If-None-Match för skrivåtgärder för optimistisk samtidighet.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata. Krävs för PUT-begäranden (CreateOrReplace).
properties.sizeWindow	integer	Storleksfönstret som stream analytics-utdata ska begränsas till.
properties.timeWindow	string	Tidsramen för filtrering av Stream Analytics-jobbutdata.
type	string	Resurstyp

OutputErrorPolicy

Anger principen som ska tillämpas på händelser som kommer till utdata och inte kan skrivas till den externa lagringen på grund av att de är felaktiga (saknade kolumnvärden, kolumnvärden av fel typ eller storlek).

Name	Typ	Description
Drop	string
Stop	string

OutputStartMode

Värdet kan vara JobStartTime, CustomTime eller LastOutputEventTime för att ange om startpunkten för utdatahändelseströmmen ska starta när jobbet startas, starta vid en anpassad användartidsstämpel som anges via egenskapen outputStartTime eller starta från den senaste händelsens utdatatid.

Name	Typ	Description
CustomTime	string
JobStartTime	string
LastOutputEventTime	string

ParquetSerialization

Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata i Parquet-format.

Name	Typ	Description
type	string: Parquet	Anger vilken typ av serialisering som används av indata eller utdata. Krävs för PUT-begäranden (CreateOrReplace).

PowerBIOutputDataSource

Beskriver en Power BI-utdatakälla.

Name	Typ	Standardvärde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.dataset	string		Namnet på Power BI-datauppsättningen. Krävs för PUT-begäranden (CreateOrReplace).
properties.groupId	string		ID för Power BI-gruppen.
properties.groupName	string		Namnet på Power BI-gruppen. Använd den här egenskapen för att komma ihåg vilket specifikt Power BI-grupp-ID som användes.
properties.refreshToken	string		En uppdateringstoken som kan användas för att hämta en giltig åtkomsttoken som sedan kan användas för att autentisera med datakällan. En giltig uppdateringstoken kan för närvarande endast hämtas via Azure-portalen. Vi rekommenderar att du placerar ett dummy-strängvärde här när du skapar datakällan och sedan går till Azure-portalen för att autentisera datakällan som uppdaterar den här egenskapen med en giltig uppdateringstoken. Krävs för PUT-begäranden (CreateOrReplace).
properties.table	string		Namnet på Power BI-tabellen under den angivna datauppsättningen. Krävs för PUT-begäranden (CreateOrReplace).
properties.tokenUserDisplayName	string		Användarens visningsnamn för den användare som användes för att hämta uppdateringstoken. Använd den här egenskapen för att komma ihåg vilken användare som användes för att hämta uppdateringstoken.
properties.tokenUserPrincipalName	string		Användarens huvudnamn (UPN) för den användare som användes för att hämta uppdateringstoken. Använd den här egenskapen för att komma ihåg vilken användare som användes för att hämta uppdateringstoken.
type	string: PowerBI		Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

ReferenceInputProperties

De egenskaper som är associerade med indata som innehåller referensdata.

Name	Typ	Description
compression	Compression	Beskriver hur indata komprimeras
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Beskriver en indatakälla som innehåller referensdata. Krävs för PUT-begäranden (CreateOrReplace).
diagnostics	Diagnostics	Beskriver de villkor som gäller för indata, utdata eller det övergripande jobbet som berättigar till kund uppmärksamhet.
etag	string	Den aktuella entitetstaggen för indata. Det här är en täckande sträng. Du kan använda den för att identifiera om resursen har ändrats mellan begäranden. Du kan också använda den i rubrikerna If-Match eller If-None-Match för skrivåtgärder för optimistisk samtidighet.
partitionKey	string	partitionKey Beskriver en nyckel i indata som används för partitionering av indata
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Reference	Anger om indata är en källa till referensdata eller dataströmmar. Krävs för PUT-begäranden (CreateOrReplace).

RefreshType

Anger typen av datauppdateringsalternativ.

Name	Typ	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

ScalarFunctionProperties

De egenskaper som är associerade med en skalär funktion.

Name	Typ	Description
etag	string	Den aktuella entitetstaggen för funktionen. Det här är en täckande sträng. Du kan använda den för att identifiera om resursen har ändrats mellan begäranden. Du kan också använda den i rubrikerna If-Match eller If-None-Match för skrivåtgärder för optimistisk samtidighet.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Funktionens fysiska bindning. I Azure Machine Learning-webbtjänstens fall beskriver detta till exempel slutpunkten.
properties.inputs	FunctionInput[]	Beskriver en indataparameter för en funktion.
properties.output	FunctionOutput	Beskriver utdata från en funktion.
type	string: Scalar	Anger typen av funktion.

ServiceBusQueueOutputDataSource

Beskriver en utdatakälla för Service Bus-kön.

Name	Typ	Standardvärde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.propertyColumns	string[]		En strängmatris med namnen på de utdatakolumner som ska kopplas till Service Bus-meddelanden som anpassade egenskaper.
properties.queueName	string		Namnet på Service Bus-kön. Krävs för PUT-begäranden (CreateOrReplace).
properties.serviceBusNamespace	string		Namnområdet som är associerat med önskad händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Principnyckeln för delad åtkomst för den angivna principen för delad åtkomst. Krävs för PUT-begäranden (CreateOrReplace).
properties.sharedAccessPolicyName	string		Namnet på principen för delad åtkomst för Händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
properties.systemPropertyColumns	object		Systemegenskaperna som är associerade med Service Bus-kön. Följande systemegenskaper stöds: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
type	string: Microsoft.ServiceBus/Queue		Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

ServiceBusTopicOutputDataSource

Beskriver en utdatakälla för Service Bus-ämnet.

Name	Typ	Standardvärde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.propertyColumns	string[]		En strängmatris med namnen på de utdatakolumner som ska kopplas till Service Bus-meddelanden som anpassade egenskaper.
properties.serviceBusNamespace	string		Namnområdet som är associerat med önskad händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Principnyckeln för delad åtkomst för den angivna principen för delad åtkomst. Krävs för PUT-begäranden (CreateOrReplace).
properties.sharedAccessPolicyName	string		Namnet på principen för delad åtkomst för Händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
properties.systemPropertyColumns	object		Systemegenskaperna som är associerade med Service Bus-ämnesutdata. Följande systemegenskaper stöds: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
properties.topicName	string		Namnet på Service Bus-ämnet. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.ServiceBus/Topic		Anger vilken typ av utdata som datakällan ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

Sku

De egenskaper som är associerade med en SKU.

Name	Typ	Description
name	SkuName	Namnet på SKU:n. Krävs för PUT-begäranden (CreateOrReplace).

SkuName

Namnet på SKU:n. Krävs för PUT-begäranden (CreateOrReplace).

Name	Typ	Description
Standard	string

StorageAccount

De egenskaper som är associerade med ett Azure Storage-konto

Name	Typ	Description
accountKey	string	Kontonyckeln för Azure Storage-kontot. Krävs för PUT-begäranden (CreateOrReplace).
accountName	string	Namnet på Azure Storage-kontot. Krävs för PUT-begäranden (CreateOrReplace).

StreamingJob

Ett direktuppspelningsjobbobjekt som innehåller all information som är associerad med det namngivna strömningsjobbet.

Name	Typ	Description
id	string	Fullständigt kvalificerat resurs-ID för resursen. Exempel – /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Beskriver den systemtilldelade hanterade identitet som tilldelats det här jobbet och som kan användas för att autentisera med indata och utdata.
location	string	Den geo-plats där resursen finns
name	string	Namnet på resursen
properties.cluster	ClusterInfo	Klustret som strömmande jobb ska köras på.
properties.compatibilityLevel	CompatibilityLevel	Styr vissa körningsbeteenden för strömningsjobbet.
properties.contentStoragePolicy	ContentStoragePolicy	Giltiga värden är JobStorageAccount och SystemAccount. Om värdet är JobStorageAccount kräver detta att användaren även anger egenskapen jobStorageAccount. .
properties.createdDate	string	Värdet är en ISO-8601-formaterad UTC-tidsstämpel som anger när strömningsjobbet skapades.
properties.dataLocale	string	Dataspråket för Stream Analytics-jobbet. Värdet ska vara namnet på en .NET-kultur som stöds från uppsättningen https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Standardvärdet är "en-US" om inget anges.
properties.etag	string	Den aktuella entitetstaggen för strömningsjobbet. Det här är en täckande sträng. Du kan använda den för att identifiera om resursen har ändrats mellan begäranden. Du kan också använda den i rubrikerna If-Match eller If-None-Match för skrivåtgärder för optimistisk samtidighet.
properties.eventsLateArrivalMaxDelayInSeconds	integer	Den maximala toleransfördröjningen i sekunder där händelser som kommer sent kan inkluderas. Intervallet som stöds är -1 till 1814399 (20.23:59:59 dagar) och -1 används för att ange väntetid på obestämd tid. Om egenskapen saknas tolkas värdet -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	Den maximala toleransfördröjningen i sekunder där out-of-order-händelser kan justeras för att vara tillbaka i ordning.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Anger principen som ska tillämpas på händelser som tas emot i fel ordning i indatahändelseströmmen.
properties.functions	Function[]	En lista över en eller flera funktioner för strömningsjobbet. Namnegenskapen för varje funktion krävs när du anger den här egenskapen i en PUT-begäran. Det går inte att ändra den här egenskapen via en PATCH-åtgärd. Du måste använda PATCH-API:et som är tillgängligt för den enskilda omvandlingen.
properties.inputs	Input[]	En lista över en eller flera indata till strömningsjobbet. Namnegenskapen för varje indata krävs när du anger den här egenskapen i en PUT-begäran. Det går inte att ändra den här egenskapen via en PATCH-åtgärd. Du måste använda PATCH-API:et som är tillgängligt för enskilda indata.
properties.jobId	string	Ett GUID som unikt identifierar strömningsjobbet. Detta GUID genereras när strömningsjobbet skapas.
properties.jobState	string	Beskriver status för strömningsjobbet.
properties.jobStorageAccount	JobStorageAccount	De egenskaper som är associerade med ett Azure Storage-konto med MSI
properties.jobType	JobType	Beskriver typen av jobb. Giltiga lägen är `Cloud` och "Edge".
properties.lastOutputEventTime	string	Värdet är antingen en ISO-8601-formaterad tidsstämpel som anger den senaste utdatahändelsetiden för strömningsjobbet eller null som anger att utdata ännu inte har producerats. Om det finns flera utdata eller flera strömmar visas det senaste värdet i uppsättningen.
properties.outputErrorPolicy	OutputErrorPolicy	Anger principen som ska tillämpas på händelser som kommer till utdata och inte kan skrivas till den externa lagringen på grund av att de är felaktiga (saknade kolumnvärden, kolumnvärden av fel typ eller storlek).
properties.outputStartMode	OutputStartMode	Den här egenskapen bör endast användas när du vill att jobbet ska startas omedelbart när det skapas. Värdet kan vara JobStartTime, CustomTime eller LastOutputEventTime för att ange om startpunkten för utdatahändelseströmmen ska starta när jobbet startas, starta vid en anpassad användartidsstämpel som anges via egenskapen outputStartTime eller starta från den senaste händelsens utdatatid.
properties.outputStartTime	string	Värdet är antingen en ISO-8601-formaterad tidsstämpel som anger startpunkten för utdatahändelseströmmen eller null för att indikera att utdatahändelseströmmen startar när strömningsjobbet startas. Den här egenskapen måste ha ett värde om outputStartMode är inställt på CustomTime.
properties.outputs	Output[]	En lista över en eller flera utdata för strömningsjobbet. Namnegenskapen för varje utdata krävs när du anger den här egenskapen i en PUT-begäran. Det går inte att ändra den här egenskapen via en PATCH-åtgärd. Du måste använda PATCH-API:et som är tillgängligt för enskilda utdata.
properties.provisioningState	string	Beskriver etableringsstatusen för strömningsjobbet.
properties.sku	Sku	Beskriver SKU:n för strömningsjobbet. Krävs för PUT-begäranden (CreateOrReplace).
properties.transformation	Transformation	Anger frågan och antalet strömningsenheter som ska användas för strömningsjobbet. Namnegenskapen för omvandlingen krävs när du anger den här egenskapen i en PUT-begäran. Det går inte att ändra den här egenskapen via en PATCH-åtgärd. Du måste använda PATCH-API:et som är tillgängligt för den enskilda omvandlingen.
tags	object	Resurstaggar.
type	string	Resurstypen. Exempel: Microsoft.Compute/virtualMachines eller Microsoft.Storage/storageAccounts.

StreamInputProperties

De egenskaper som är associerade med indata som innehåller dataströmmen.

Name	Typ	Description
compression	Compression	Beskriver hur indata komprimeras
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Beskriver en indatakälla som innehåller dataströmmar. Krävs för PUT-begäranden (CreateOrReplace).
diagnostics	Diagnostics	Beskriver de villkor som gäller för indata, utdata eller det övergripande jobbet som berättigar till kund uppmärksamhet.
etag	string	Den aktuella entitetstaggen för indata. Det här är en täckande sträng. Du kan använda den för att identifiera om resursen har ändrats mellan begäranden. Du kan också använda den i rubrikerna If-Match eller If-None-Match för skrivåtgärder för optimistisk samtidighet.
partitionKey	string	partitionKey Beskriver en nyckel i indata som används för partitionering av indata
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Stream	Anger om indata är en källa till referensdata eller dataströmmar. Krävs för PUT-begäranden (CreateOrReplace).

Transformation

Ett transformeringsobjekt som innehåller all information som är associerad med den namngivna omvandlingen. Alla transformeringar finns under ett strömningsjobb.

Name	Typ	Standardvärde	Description
id	string		Resurs-ID
name	string		Resursnamn
properties.etag	string		Den aktuella entitetstaggen för omvandlingen. Det här är en täckande sträng. Du kan använda den för att identifiera om resursen har ändrats mellan begäranden. Du kan också använda den i rubrikerna If-Match eller If-None-Match för skrivåtgärder för optimistisk samtidighet.
properties.query	string		Anger den fråga som ska köras i strömningsjobbet. Du kan läsa mer om Stream Analytics Query Language (SAQL) här: https://msdn.microsoft.com/library/azure/dn834998 . Krävs för PUT-begäranden (CreateOrReplace).
properties.streamingUnits	integer	3	Anger antalet strömningsenheter som strömningsjobbet använder.
properties.validStreamingUnits	integer[]		Anger giltiga strömningsenheter som ett strömningsjobb kan skalas till.
type	string		Resurstyp

Dela via

Streaming Jobs - Create Or Replace

URI-parametrar

Begärandehuvud

Begärandetext

Svar

Säkerhet

azure_auth

Omfattningar

Exempel

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

Exempelbegäran

Exempelsvar

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

Exempelbegäran

Exempelsvar

Definitioner

AggregateFunctionProperties

AuthenticationMode

AvroSerialization

AzureDataLakeStoreOutputDataSource

AzureFunctionOutputDataSource

AzureMachineLearningWebServiceFunctionBinding

AzureMachineLearningWebServiceInputColumn

AzureMachineLearningWebServiceInputs

AzureMachineLearningWebServiceOutputColumn

AzureSqlDatabaseOutputDataSource

AzureSqlReferenceInputDataSource

AzureSynapseOutputDataSource

AzureTableOutputDataSource

BlobOutputDataSource

BlobReferenceInputDataSource

BlobStreamInputDataSource

ClusterInfo

CompatibilityLevel

Compression

CompressionType

ContentStoragePolicy

CsvSerialization

DiagnosticCondition

Diagnostics

DocumentDbOutputDataSource

Encoding

Error

EventHubOutputDataSource

EventHubStreamInputDataSource

EventHubV2OutputDataSource

EventHubV2StreamInputDataSource

EventSerializationType

EventsOutOfOrderPolicy

FileReferenceInputDataSource

Function

FunctionInput

FunctionOutput

GatewayMessageBusOutputDataSource

GatewayMessageBusStreamInputDataSource

Identity

Input

IoTHubStreamInputDataSource

JavaScriptFunctionBinding

JobStorageAccount

JobType

JsonOutputSerializationFormat

JsonSerialization

Output

OutputErrorPolicy

OutputStartMode

ParquetSerialization

PowerBIOutputDataSource

ReferenceInputProperties

RefreshType

ScalarFunctionProperties

ServiceBusQueueOutputDataSource

ServiceBusTopicOutputDataSource

Sku

SkuName

StorageAccount

StreamingJob

StreamInputProperties

Transformation