Streaming Jobs - Create Or Replace

Tjänst:

Stream Analytics

API-version:

2020-03-01

Skapar ett direktuppspelningsjobb eller ersätter ett redan befintligt direktuppspelningsjobb.

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 minLength: 1 maxLength: 90 pattern: ^[-\w\._\(\)]+$	Namnet på resursgruppen. Namnet är skiftlägesokänsligt.
subscriptionId	path	True	string minLength: 1	ID för målprenumerationen.
api-version	query	True	string minLength: 1	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 synliga 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 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
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 ingen har angetts.
properties.eventsLateArrivalMaxDelayInSeconds	integer (int32)	Den maximala tillåtna 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 med värdet -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer (int32)	Den maximala tillåtna 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 inte kan skrivas till den externa lagringen på grund av att den är felaktigt formaterad (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 med en anpassad användartidsstämpel som anges via egenskapen outputStartTime eller starta från den senaste händelsens utdatatid.
properties.outputStartTime	string (date-time)	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 enheter för direktuppspelning 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.

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

HTTP

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

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

Java

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

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

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

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

JavaScript

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

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

createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output().catch(
  console.error
);

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

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

HTTP

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

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

Java

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

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

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

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

JavaScript

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

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

createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions().catch(
  console.error
);

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

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 aggregeringsfunktion.
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änstens slutpunkt.
AzureMachineLearningWebServiceInputs	Indata för Azure Machine Learning-webbtjänstens slutpunkt.
AzureMachineLearningWebServiceOutputColumn	Beskriver en utdatakolumn för Azure Machine Learning-webbtjänstens slutpunkt.
AzureSqlDatabaseOutputDataSource	Beskriver utdatakällan för en Azure SQL-databas.
AzureSqlReferenceInputDataSource	Beskriver en Azure SQL-databas som refererar till indatakällan.
AzureSynapseOutputDataSource	Beskriver en Azure Synapse-utdatakälla.
AzureTableOutputDataSource	Beskriver en Azure Table-utdatakälla.
BlobOutputDataSource	Beskriver en blobutdatakä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 en 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 det övergripande jobbet, som kräver kundbemärksamhet.
Diagnostics	Beskriver de villkor som gäller för indata, utdata eller det övergripande jobbet som garanterar kundernas uppmärksamhet.
DocumentDbOutputDataSource	Beskriver en DocumentDB-utdatakälla.
Encoding	Anger kodningen av inkommande data vid indata och kodning av utgående data vid utdata.
Error	Vanlig felrepresentation.
EventHubOutputDataSource	Beskriver en Händelsehubb-utdatakälla.
EventHubStreamInputDataSource	Beskriver en Händelsehubb-indatakälla som innehåller dataströmmar.
EventHubV2OutputDataSource	Beskriver en Händelsehubb-utdatakälla.
EventHubV2StreamInputDataSource	Beskriver en Händelsehubb-indatakälla som innehåller dataströmmar.
EventSerializationType	Anger vilken typ av serialisering som indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).
EventsOutOfOrderPolicy	Anger vilken princip 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 från en funktion.
GatewayMessageBusOutputDataSource	Beskriver en Gateway Message Bus-utdatakälla.
GatewayMessageBusStreamInputDataSource	Beskriver en blobindatakälla som innehåller dataströmmar.
Identity	Beskriver hur identiteten verifieras
Input	Ett indataobjekt som innehåller all information som är associerad med den namngivna indatan. Alla indata finns under ett direktuppspelningsjobb.
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 formateras som en matris med JSON-objekt.
JsonSerialization	Beskriver hur data från en 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 direktuppspelningsjobb.
OutputErrorPolicy	Anger vilken princip som ska tillämpas på händelser som anländer till utdata och inte kan skrivas till den externa lagringen på grund av att den är felaktigt formaterad (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 med 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 en indata som innehåller referensdata.
RefreshType	Anger typen av datauppdateringsalternativ.
ScalarFunctionProperties	De egenskaper som är associerade med en skalär funktion.
ServiceBusQueueOutputDataSource	Beskriver en Service Bus Queue-utdatakälla.
ServiceBusTopicOutputDataSource	Beskriver en Service Bus Topic-utdatakälla.
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 en indata som innehåller dataström.
Transformation	Ett transformeringsobjekt som innehåller all information som är associerad med den namngivna omvandlingen. Alla transformeringar finns under ett strömningsjobb.

AggregateFunctionProperties

Objekt

De egenskaper som är associerade med en aggregeringsfunktion.

Name	Typ	Description
etag	string	Den aktuella entitetstaggen för funktionen. Det här är en ogenomskinlig 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 If-Match- eller If-None-Match-huvuden 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 typ av funktion.

AuthenticationMode

Uppräkning

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

Värde	Description
ConnectionString
Msi
UserToken

AvroSerialization

Objekt

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 indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Objekt

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 användaren 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 datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

AzureFunctionOutputDataSource

Objekt

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 låter dig 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 datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

Objekt

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 (int32)	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änstens slutpunkt.
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

Objekt

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

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 (int32)	Det nollbaserade indexet för funktionsparametern som den här indatan mappar till.
name	string	Namnet på indatakolumnen.

AzureMachineLearningWebServiceInputs

Objekt

Indata för Azure Machine Learning-webbtjänstens slutpunkt.

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

AzureMachineLearningWebServiceOutputColumn

Objekt

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

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

Objekt

Beskriver utdatakällan för en Azure SQL-databas.

Name	Typ	Standardvärde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.database	string		Namnet på Azure SQL-databasen. Krävs för PUT-begäranden (CreateOrReplace).
properties.maxBatchCount	number		Maximalt antal batchar för skrivning till Sql Database, 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å SQL-servern 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		Användarnamnet 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 datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

AzureSqlReferenceInputDataSource

Objekt

Beskriver en Azure SQL-databas som refererar till indatakällan.

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

Objekt

Beskriver en Azure Synapse-utdatakälla.

Name	Typ	Description
properties.database	string	Namnet på 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å SQL-servern 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	Användarnamnet 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 datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

AzureTableOutputDataSource

Objekt

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 (int32)	Antalet rader som ska skrivas till Azure-tabellen i taget.
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 Table. 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 Table. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.Storage/Table	Anger vilken typ av datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

BlobOutputDataSource

Objekt

Beskriver en blobutdatakä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 som blobnamnen ska matchas mot för att avgöra om de ska inkluderas som indata eller utdata till jobbet. Mer detaljerad förklaring och exempel finns i 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.
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 datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

BlobReferenceInputDataSource

Objekt

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. Mer detaljerad förklaring och exempel finns i 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.
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

Objekt

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. Mer detaljerad förklaring och exempel finns i 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.
properties.sourcePartitionCount	integer (int32)		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

Objekt

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

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

CompatibilityLevel

Uppräkning

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

Värde	Description
1.0
1.2

Compression

Objekt

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

Uppräkning

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

Värde	Description
Deflate
GZip
None

ContentStoragePolicy

Uppräkning

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

Värde	Description
JobStorageAccount
SystemAccount

CsvSerialization

Objekt

Beskriver hur data från en 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). En lista över värden som stöds finns i 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. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Csv	Anger vilken typ av serialisering som indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).

DiagnosticCondition

Objekt

Villkor som gäller för resursen, eller för det övergripande jobbet, som kräver kundbemärksamhet.

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

Diagnostics

Objekt

Beskriver de villkor som gäller för indata, utdata eller det övergripande jobbet som garanterar kundernas 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 garanterar kundernas uppmärksamhet.

DocumentDbOutputDataSource

Objekt

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	Samlingsnamnmönstret för de samlingar 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 DocumentDB i https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output. 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 infogar eller uppdaterar å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 datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

Encoding

Uppräkning

Anger kodningen av inkommande data vid indata och kodning av utgående data vid utdata.

Värde	Description
UTF8

Error

Objekt

Vanlig felrepresentation.

Name	Typ	Description
error	Error	Egenskaper för feldefinition.

EventHubOutputDataSource

Objekt

Beskriver en Händelsehubb-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 datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

EventHubStreamInputDataSource

Objekt

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

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. Genom att ange distinkta konsumentgruppnamn för flera indata kan var och en av dessa indata ta emot samma händelser från händelsehubben. Om det inte 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

Objekt

Beskriver en Händelsehubb-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 datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

EventHubV2StreamInputDataSource

Objekt

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

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. Genom att ange distinkta konsumentgruppnamn för flera indata kan var och en av dessa indata ta emot samma händelser från händelsehubben. Om det inte 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

Uppräkning

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

Värde	Description
Avro
Csv
Json
Parquet

EventsOutOfOrderPolicy

Uppräkning

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

Värde	Description
Adjust
Drop

FileReferenceInputDataSource

Objekt

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

Objekt

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

Objekt

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 i 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 falskt.

FunctionOutput

Objekt

Beskriver utdata från en funktion.

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

GatewayMessageBusOutputDataSource

Objekt

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 datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Objekt

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

Objekt

Beskriver hur identiteten verifieras

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

Input

Objekt

Ett indataobjekt som innehåller all information som är associerad med den namngivna indatan. Alla indata finns under ett direktuppspelningsjobb.

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

Objekt

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 det inte anges använder indata Iot Hubs standardkonsumentgrupp.
properties.endpoint	string	IoT Hub-slutpunkten som ska anslutas till (dvs. 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

Objekt

Bindningen till en JavaScript-funktion.

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

JobStorageAccount

Objekt

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

Uppräkning

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

Värde	Description
Cloud
Edge

JsonOutputSerializationFormat

Uppräkning

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 formateras som en matris med JSON-objekt.

Värde	Description
Array
LineSeparated

JsonSerialization

Objekt

Beskriver hur data från en 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 JSON-serialisering av utdata. Det är inte tillämpligt för indata. Den här egenskapen 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 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 indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).

Output

Objekt

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

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 skrivs 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 garanterar kundernas uppmärksamhet.
properties.etag	string	Den aktuella entitetstaggen för utdata. Det här är en ogenomskinlig 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 If-Match- eller If-None-Match-huvuden 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 (int32)	Storleksfönstret för att begränsa ett Stream Analytics-utdata till.
properties.timeWindow	string	Tidsramen för att filtrera Stream Analytics-jobbutdata.
type	string	Resurstyp

OutputErrorPolicy

Uppräkning

Anger vilken princip som ska tillämpas på händelser som anländer till utdata och inte kan skrivas till den externa lagringen på grund av att den är felaktigt formaterad (saknade kolumnvärden, kolumnvärden av fel typ eller storlek).

Värde	Description
Drop
Stop

OutputStartMode

Uppräkning

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 med en anpassad användartidsstämpel som anges via egenskapen outputStartTime eller starta från den senaste händelsens utdatatid.

Värde	Description
CustomTime
JobStartTime
LastOutputEventTime

ParquetSerialization

Objekt

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 indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).

PowerBIOutputDataSource

Objekt

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:t 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 datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

ReferenceInputProperties

Objekt

De egenskaper som är associerade med en 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 garanterar kundernas uppmärksamhet.
etag	string	Den aktuella entitetstaggen för indata. Det här är en ogenomskinlig 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 If-Match- eller If-None-Match-huvuden 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öm. Krävs för PUT-begäranden (CreateOrReplace).

RefreshType

Uppräkning

Anger typen av datauppdateringsalternativ.

Värde	Description
RefreshPeriodicallyWithDelta
RefreshPeriodicallyWithFull
Static

ScalarFunctionProperties

Objekt

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 ogenomskinlig 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 If-Match- eller If-None-Match-huvuden 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 typ av funktion.

ServiceBusQueueOutputDataSource

Objekt

Beskriver en Service Bus Queue-utdatakälla.

Name	Typ	Standardvärde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.propertyColumns	string[]		En strängmatris med namnen på 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 datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

ServiceBusTopicOutputDataSource

Objekt

Beskriver en Service Bus Topic-utdatakälla.

Name	Typ	Standardvärde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.propertyColumns	string[]		En strängmatris med namnen på 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 datakällutdata som ska skrivas till. Krävs för PUT-begäranden (CreateOrReplace).

Sku

Objekt

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

Uppräkning

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

Värde	Description
Standard

StorageAccount

Objekt

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

Objekt

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. Ex – /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 (date-time)	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 ingen har angetts.
properties.etag	string	Den aktuella entitetstaggen för strömningsjobbet. Det här är en ogenomskinlig 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 If-Match- eller If-None-Match-huvuden för skrivåtgärder för optimistisk samtidighet.
properties.eventsLateArrivalMaxDelayInSeconds	integer (int32)	Den maximala tillåtna 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 med värdet -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer (int32)	Den maximala tillåtna 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.jobId	string	Ett GUID som unikt identifierar strömningsjobbet. Detta GUID genereras när strömningsjobbet skapas.
properties.jobState	string	Beskriver tillståndet 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 (date-time)	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 vilken princip som ska tillämpas på händelser som anländer till utdata och inte kan skrivas till den externa lagringen på grund av att den är felaktigt formaterad (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 med en anpassad användartidsstämpel som anges via egenskapen outputStartTime eller starta från den senaste händelsens utdatatid.
properties.outputStartTime	string (date-time)	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.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 enheter för direktuppspelning 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. Ex- Microsoft.Compute/virtualMachines eller Microsoft.Storage/storageAccounts.

StreamInputProperties

Objekt

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

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 garanterar kundernas uppmärksamhet.
etag	string	Den aktuella entitetstaggen för indata. Det här är en ogenomskinlig 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 If-Match- eller If-None-Match-huvuden 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öm. Krävs för PUT-begäranden (CreateOrReplace).

Transformation

Objekt

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 ogenomskinlig 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 If-Match- eller If-None-Match-huvuden 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 (int32)	3	Anger antalet strömningsenheter som strömningsjobbet använder.
properties.validStreamingUnits	integer[] (int32)		Anger giltiga strömningsenheter som ett direktuppspelningsjobb kan skalas till.
type	string		Resurstyp