Streaming Jobs - Create Or Replace

Service:

Stream Analytics

API Version:

2020-03-01

Létrehoz egy streamelési feladatot, vagy lecserél egy már meglévő streamelési feladatot.

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

URI-paraméterek

Name	In	Kötelező	Típus	Description
jobName	path	True	string	A streamelési feladat neve.
resourceGroupName	path	True	string	Az erőforráscsoport neve. A név megkülönbözteti a kis- és nagybetűket. Regex pattern: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	A cél-előfizetés azonosítója.
api-version	query	True	string	A művelethez használandó API-verzió.

Kérelem fejléce

Name	Kötelező	Típus	Description
If-Match		string	A streamelési feladat ETagje. Ezt az értéket kihagyva mindig felülírja az aktuális rekordhalmazt. Adja meg az utolsóként látható ETag értéket, hogy megakadályozza az egyidejű módosítások véletlen felülírását.
If-None-Match		string	Állítsa a "*" értéket egy új streamelési feladat létrehozásához, de a meglévő rekordkészletek frissítésének megakadályozása érdekében. Egyéb értékek esetén a 412 előfeltétel meghiúsult válasz lesz.

Kérelem törzse

Name	Típus	Description
identity	Identity	A feladathoz hozzárendelt rendszer által hozzárendelt felügyelt identitást ismerteti, amely bemenetekkel és kimenetekkel történő hitelesítésre használható.
location	string	Az a földrajzi hely, ahol az erőforrás él
properties.cluster	ClusterInfo	Az a fürt, amelyen a streamelési feladatok futni fognak.
properties.compatibilityLevel	CompatibilityLevel	Szabályozza a streamelési feladat futásidejű viselkedését.
properties.contentStoragePolicy	ContentStoragePolicy	Az érvényes értékek a JobStorageAccount és a SystemAccount. Ha a JobStorageAccount értékre van állítva, a felhasználónak meg kell adnia a jobStorageAccount tulajdonságot is. .
properties.dataLocale	string	A streamelemzési feladat adat területi beállítása. Az értéknek egy támogatott .NET-kultúra neve kell legyen a készletből https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Alapértelmezés szerint "en-US", ha nincs megadva.
properties.eventsLateArrivalMaxDelayInSeconds	integer	A maximális tűrhető késleltetés másodpercben, amikor a késői események is belefoglalhatók. A támogatott tartomány -1 és 1814399 (20.23:59:59 nap), a -1 pedig a határozatlan ideig tartó várakozás megadására szolgál. Ha a tulajdonság hiányzik, a rendszer úgy értelmezi, hogy értéke -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	A maximális elviselhető késleltetés másodpercekben, amikor a rendelésen kívüli eseményeket úgy lehet módosítani, hogy azok ismét sorrendben legyenek.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Azt a szabályzatot jelzi, amely a bemeneti eseménystreamben sorrendből érkező eseményekre alkalmazandó.
properties.functions	Function[]	A streamelési feladat egy vagy több függvényének listája. A tulajdonság PUT-kérelemben való megadásakor az egyes függvények névtulajdonságára van szükség. Ez a tulajdonság patch művelettel nem módosítható. Az egyéni átalakításhoz elérhető PATCH API-t kell használnia.
properties.inputs	Input[]	A streamelési feladat egy vagy több bemenetének listája. A tulajdonság PUT-kérelemben való megadásakor minden bemenethez meg kell adni a name tulajdonságot. Ez a tulajdonság patch művelettel nem módosítható. Az egyes bemenetekhez elérhető PATCH API-t kell használnia.
properties.jobStorageAccount	JobStorageAccount	Az Azure Storage-fiókhoz és az MSI-hez társított tulajdonságok
properties.jobType	JobType	A feladat típusát ismerteti. Az érvényes módok az és az Cloud "Edge".
properties.outputErrorPolicy	OutputErrorPolicy	Azt a szabályzatot jelzi, amely a kimenetbe érkező eseményekre alkalmazandó, és nem írható a külső tárolóba helytelen formázás miatt (hiányzó oszlopértékek, helytelen típusú vagy méretű oszlopértékek).
properties.outputStartMode	OutputStartMode	Ezt a tulajdonságot csak akkor szabad használni, ha azt szeretné, hogy a feladat azonnal elinduljon a létrehozáskor. Az érték lehet JobStartTime, CustomTime vagy LastOutputEventTime, amely jelzi, hogy a kimeneti eseménystream kezdőpontja a feladat indításakor induljon el, a outputStartTime tulajdonságon keresztül megadott egyéni felhasználói időbélyeggel kezdődjön, vagy az utolsó esemény kimeneti időpontjától induljon el.
properties.outputStartTime	string	Az érték egy ISO-8601 formátumú időbélyeg, amely a kimeneti eseményfolyam kezdőpontját jelzi, vagy null érték, amely azt jelzi, hogy a kimeneti eseménystream a streamelési feladat indításakor indul el. Ennek a tulajdonságnak értékkel kell rendelkeznie, ha az outputStartMode customTime értékre van állítva.
properties.outputs	Output[]	A streamelési feladat egy vagy több kimenetének listája. Az egyes kimenetek névtulajdonságára akkor van szükség, ha put kérelemben adhatja meg ezt a tulajdonságot. Ez a tulajdonság patch művelettel nem módosítható. Az egyes kimenetekhez elérhető PATCH API-t kell használnia.
properties.sku	Sku	A streamelési feladat termékváltozatát ismerteti. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.transformation	Transformation	A lekérdezést és a streamelési feladathoz használni kívánt streamelési egységek számát jelzi. A tulajdonság PUT-kérelemben való megadásakor az átalakítás névtulajdonsága szükséges. Ez a tulajdonság patch művelettel nem módosítható. Az egyéni átalakításhoz elérhető PATCH API-t kell használnia.
tags	object	Erőforráscímkék.

Válaszok

Name	Típus	Description
200 OK	StreamingJob	A streamelési feladat létrehozása vagy cseréje sikerült. Headers ETag: string
201 Created	StreamingJob	A streamelési feladat létrehozása vagy cseréje sikerült. Headers ETag: string
Other Status Codes	Error	HIba.

Biztonság

azure_auth

Azure Active Directory OAuth2 Flow

Type: oauth2
Flow: implicit
Authorization URL: https://login.microsoftonline.com/common/oauth2/authorize

Scopes

Name	Description
user_impersonation	felhasználói fiók megszemélyesítése

Példák

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)

Sample Request

HTTP

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

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

Java

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

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

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

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

JavaScript

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

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

createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output().catch(
  console.error
);

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

Sample Response

Status code:

201

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

Response Body

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

Status code:

200

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

Response Body

{
  "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)

Sample Request

HTTP

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

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

Java

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

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

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

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

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

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

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

JavaScript

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

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

createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions().catch(
  console.error
);

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

Sample Response

Status code:

201

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

Response Body

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

Status code:

200

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

Response Body

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

Definíciók

Name	Description
AggregateFunctionProperties	Az összesítő függvényhez társított tulajdonságok.
AuthenticationMode	Hitelesítési mód. Az érvényes módok a következők: ConnectionString, Msi és "UserToken".
AvroSerialization	Bemutatja, hogyan szerializálják a bemenetből származó adatokat, vagy hogyan szerializálják az adatokat, amikor Avro formátumú kimenetre írnak.
AzureDataLakeStoreOutputDataSource	Az Azure Data Lake Store kimeneti adatforrását ismerteti.
AzureFunctionOutputDataSource	Meghatározza az AzureFunctionOutputDataSource metaadatait
AzureMachineLearningWebServiceFunctionBinding	Az Azure Machine Learning-webszolgáltatáshoz való kötés.
AzureMachineLearningWebServiceInputColumn	Az Azure Machine Learning webszolgáltatás-végpontjának bemeneti oszlopát ismerteti.
AzureMachineLearningWebServiceInputs	Az Azure Machine Learning webszolgáltatás-végpontjának bemenetei.
AzureMachineLearningWebServiceOutputColumn	Az Azure Machine Learning webszolgáltatás végpontjának kimeneti oszlopát ismerteti.
AzureSqlDatabaseOutputDataSource	Egy Azure SQL adatbázis kimeneti adatforrását ismerteti.
AzureSqlReferenceInputDataSource	Egy Azure SQL adatbázis-referencia bemeneti adatforrását ismerteti.
AzureSynapseOutputDataSource	Egy Azure Synapse kimeneti adatforrást ismertet.
AzureTableOutputDataSource	Az Azure Table kimeneti adatforrását ismerteti.
BlobOutputDataSource	Egy blob kimeneti adatforrását ismerteti.
BlobReferenceInputDataSource	Referenciaadatokat tartalmazó blobbemeneti adatforrást ismertet.
BlobStreamInputDataSource	Egy streamadatokat tartalmazó blobbemeneti adatforrást ismertet.
ClusterInfo	A Stream Analytics-fürthöz társított tulajdonságok.
CompatibilityLevel	Szabályozza a streamelési feladat futásidejű viselkedését.
Compression	A bemeneti adatok tömörítésének módját ismerteti
CompressionType	A bemenet által használt tömörítés típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.
ContentStoragePolicy	Az érvényes értékek a JobStorageAccount és a SystemAccount. Ha a JobStorageAccount értékre van állítva, a felhasználónak meg kell adnia a jobStorageAccount tulajdonságot is. .
CsvSerialization	Bemutatja, hogyan szerializálják a bemenetből származó adatokat, vagy hogyan szerializálják az adatokat, amikor CSV formátumban írnak kimenetbe.
DiagnosticCondition	Az erőforrásra vagy a feladatra vonatkozó olyan feltétel, amely az ügyfelek figyelmét felkelti.
Diagnostics	A bemenetre, kimenetre vagy a feladatra vonatkozó feltételeket ismerteti, amelyek garantálják az ügyfelek figyelmét.
DocumentDbOutputDataSource	Egy DocumentDB kimeneti adatforrást ismertet.
Encoding	Megadja a bejövő adatok kódolását bemenet esetén, valamint a kimenő adatok kódolását kimenet esetén.
Error	Gyakori hibaábrázolás.
EventHubOutputDataSource	Az Event Hub kimeneti adatforrását ismerteti.
EventHubStreamInputDataSource	Egy streamadatokat tartalmazó eseményközpont bemeneti adatforrását ismerteti.
EventHubV2OutputDataSource	Az Event Hub kimeneti adatforrását ismerteti.
EventHubV2StreamInputDataSource	Egy streamadatokat tartalmazó eseményközpont bemeneti adatforrását ismerteti.
EventSerializationType	A bemenet vagy kimenet által használt szerializáció típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.
EventsOutOfOrderPolicy	Azt a szabályzatot jelzi, amely a bemeneti eseménystreamben sorrendből érkező eseményekre alkalmazandó.
FileReferenceInputDataSource	Referenciaadatokat tartalmazó fájlbemeneti adatforrást ismertet.
Function	Egy függvényobjektum, amely az elnevezett függvényhez társított összes információt tartalmazza. Minden függvény egy streamelési feladat alatt található.
FunctionInput	Egy függvény egy bemeneti paraméterét ismerteti.
FunctionOutput	Egy függvény kimenetét ismerteti.
GatewayMessageBusOutputDataSource	Az átjáró Message Bus kimeneti adatforrását ismerteti.
GatewayMessageBusStreamInputDataSource	Egy streamadatokat tartalmazó blobbemeneti adatforrást ismertet.
Identity	Az identitás ellenőrzésének módját ismerteti
Input	Egy bemeneti objektum, amely a nevesített bemenethez társított összes információt tartalmazza. Minden bemenet egy streamelési feladat alatt található.
IoTHubStreamInputDataSource	A streamadatokat tartalmazó IoT Hub bemeneti adatforrást ismerteti.
JavaScriptFunctionBinding	A JavaScript-függvényhez való kötés.
JobStorageAccount	Az MSI-vel rendelkező Azure Storage-fiókhoz társított tulajdonságok
JobType	A feladat típusát ismerteti. Az érvényes módok az és az Cloud "Edge".
JsonOutputSerializationFormat	Megadja annak a JSON-fájlnak a formátumát, amelyben a kimenet meg lesz írva. A jelenleg támogatott értékek "lineSeparated", amely azt jelzi, hogy a kimenet úgy lesz formázva, hogy minden JSON-objektumot egy új sor választ el egymástól, a "tömb" pedig azt jelzi, hogy a kimenet JSON-objektumok tömbjeként lesz formázva.
JsonSerialization	Bemutatja, hogyan szerializálja a bemenetből származó adatokat, vagy hogyan szerializálja az adatokat, amikor JSON formátumú kimenetre írnak.
Output	Egy kimeneti objektum, amely a nevesített kimenethez társított összes információt tartalmazza. Az összes kimenetet egy streamelési feladat tartalmazza.
OutputErrorPolicy	Azt a szabályzatot jelzi, amely a kimenetbe érkező eseményekre alkalmazandó, és nem írható a külső tárolóba helytelen formázás miatt (hiányzó oszlopértékek, helytelen típusú vagy méretű oszlopértékek).
OutputStartMode	Az érték lehet JobStartTime, CustomTime vagy LastOutputEventTime, amely jelzi, hogy a kimeneti eseménystream kezdőpontja a feladat indításakor induljon el, a outputStartTime tulajdonságon keresztül megadott egyéni felhasználói időbélyeggel kezdődjön, vagy az utolsó esemény kimeneti időpontjától induljon el.
ParquetSerialization	Bemutatja, hogyan szerializálják a bemenetből származó adatokat, vagy hogyan szerializálják az adatokat parquet formátumú kimenetbe írva.
PowerBIOutputDataSource	A Power BI kimeneti adatforrását ismerteti.
ReferenceInputProperties	A referenciaadatokat tartalmazó bemenethez társított tulajdonságok.
RefreshType	Az adatfrissítési lehetőség típusát jelzi.
ScalarFunctionProperties	A skaláris függvényhez társított tulajdonságok.
ServiceBusQueueOutputDataSource	Egy Service Bus-üzenetsor kimeneti adatforrását ismerteti.
ServiceBusTopicOutputDataSource	Egy Service Bus-témakör kimeneti adatforrását ismerteti.
Sku	A termékváltozathoz társított tulajdonságok.
SkuName	A termékváltozat neve. PUT (CreateOrReplace) kérelmekhez szükséges.
StorageAccount	Az Azure Storage-fiókhoz társított tulajdonságok
StreamingJob	Egy streamelési feladat objektuma, amely a nevesített streamelési feladathoz társított összes információt tartalmazza.
StreamInputProperties	A streamadatokat tartalmazó bemenethez társított tulajdonságok.
Transformation	Egy átalakítási objektum, amely az elnevezett átalakításhoz társított összes információt tartalmazza. Az összes átalakítást egy streamelési feladat tartalmazza.

AggregateFunctionProperties

Az összesítő függvényhez társított tulajdonságok.

Name	Típus	Description
etag	string	A függvény aktuális entitáscímkéje. Ez egy átlátszatlan sztring. Segítségével észlelheti, hogy az erőforrás megváltozott-e a kérések között. A If-Match vagy az If-None-Match fejlécekben is használhatja az optimista egyidejűség érdekében végzett írási műveletekhez.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	A függvény fizikai kötése. Az Azure Machine Learning webszolgáltatás esetében például ez a végpontot írja le.
properties.inputs	FunctionInput[]	Egy függvény egyik bemeneti paraméterét ismerteti.
properties.output	FunctionOutput	Egy függvény kimenetét ismerteti.
type	string: Aggregate	A függvény típusát jelzi.

AuthenticationMode

Hitelesítési mód. Az érvényes módok a következők: ConnectionString, Msi és "UserToken".

Name	Típus	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Bemutatja, hogyan szerializálják a bemenetből származó adatokat, vagy hogyan szerializálják az adatokat, amikor Avro formátumú kimenetre írnak.

Name	Típus	Description
type	string: Avro	Azt a szerializálási típust jelzi, amelyet a bemenet vagy a kimenet használ. PUT (CreateOrReplace) kérelmekhez szükséges.

AzureDataLakeStoreOutputDataSource

Az Azure Data Lake Store kimeneti adatforrását ismerteti.

Name	Típus	Alapértelmezett érték	Description
properties.accountName	string		Az Azure Data Lake Store-fiók neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.
properties.dateFormat	string		A dátumformátum. Ahol a(z) {date} megjelenik a filePathPrefix fájlban, a tulajdonság értéke lesz a dátumformátum.
properties.filePathPrefix	string		Annak a fájlnak a helye, amelyre a kimenetet meg kell írni. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.refreshToken	string		Egy frissítési jogkivonat, amely egy érvényes hozzáférési jogkivonat beszerzésére használható, amelyet aztán az adatforrással való hitelesítéshez használhat. Egy érvényes frissítési jogkivonat jelenleg csak az Azure Portalon érhető el. Javasoljuk, hogy az adatforrás létrehozásakor helyezzen ide egy üres sztringértéket, majd lépjen az Azure Portalra az adatforrás hitelesítéséhez, amely érvényes frissítési jogkivonattal frissíti ezt a tulajdonságot. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.tenantId	string		A frissítési jogkivonat beszerzéséhez használt felhasználó bérlőazonosítója. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.timeFormat	string		Az időformátum. Ahol a(z) {time} megjelenik a filePathPrefix fájlban, a rendszer ennek a tulajdonságnak az értékét használja időformátumként.
properties.tokenUserDisplayName	string		A frissítési jogkivonat beszerzéséhez használt felhasználó megjelenítendő neve. Ezzel a tulajdonságtal emlékezhet arra, hogy melyik felhasználót használták a frissítési jogkivonat beszerzéséhez.
properties.tokenUserPrincipalName	string		A frissítési jogkivonat beszerzéséhez használt felhasználó egyszerű felhasználóneve (UPN). Ezzel a tulajdonságtal emlékezhet arra, hogy melyik felhasználót használták a frissítési jogkivonat beszerzéséhez.
type	string: Microsoft.DataLake/Accounts		Azt jelzi, hogy milyen típusú adatforrás-kimenet lesz megírva. PUT (CreateOrReplace) kérelmekhez szükséges.

AzureFunctionOutputDataSource

Meghatározza az AzureFunctionOutputDataSource metaadatait

Name	Típus	Description
properties.apiKey	string	Ha egy másik előfizetésből származó Azure-függvényt szeretne használni, ezt a függvény eléréséhez szükséges kulcs megadásával teheti meg.
properties.functionAppName	string	A Azure Functions alkalmazás neve.
properties.functionName	string	A függvény neve az Azure Functions alkalmazásban.
properties.maxBatchCount	number	Egy tulajdonság, amellyel megadhatja az egyes kötegekben a Azure Functions küldött események maximális számát. Az alapértelmezett érték 100.
properties.maxBatchSize	number	Egy tulajdonság, amellyel megadhatja az Azure-függvénynek küldött kimeneti kötegek maximális méretét. A bemeneti egység bájtban van. Ez az érték alapértelmezés szerint 262 144 bájt (256 KB).
type	string: Microsoft.AzureFunction	Azt jelzi, hogy az adatforrás kimenetének típusa milyen típusú lesz. PUT (CreateOrReplace) kérelmekhez szükséges.

AzureMachineLearningWebServiceFunctionBinding

Az Azure Machine Learning-webszolgáltatáshoz való kötés.

Name	Típus	Description
properties.apiKey	string	A Request-Response végponttal történő hitelesítéshez használt API-kulcs.
properties.batchSize	integer	1 és 10000 közötti szám, amely az Azure ML RRS végrehajtási kéréseinek maximális sorszámát írja le. Az alapértelmezett érték 1000.
properties.endpoint	string	A Request-Response az Azure Machine Learning webszolgáltatás végpontjának végrehajtása. További információt itt talál: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
properties.inputs	AzureMachineLearningWebServiceInputs	Az Azure Machine Learning webszolgáltatás-végpontjának bemenetei.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Az Azure Machine Learning webszolgáltatás végpontvégpontjának végrehajtásából származó kimenetek listája.
type	string: Microsoft.MachineLearning/WebService	A függvénykötés típusát jelzi.

AzureMachineLearningWebServiceInputColumn

Az Azure Machine Learning webszolgáltatás-végpontjának bemeneti oszlopát ismerteti.

Name	Típus	Description
dataType	string	A bemeneti oszlop (az Azure Machine Learning által támogatott) adattípusa. Az érvényes Azure Machine Learning-adattípusok listáját itt https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx találja: .
mapTo	integer	A bemeneti függvényparaméter nulla alapú indexe a függvénynek felel meg.
name	string	A bemeneti oszlop neve.

AzureMachineLearningWebServiceInputs

Az Azure Machine Learning webszolgáltatás-végpontjának bemenetei.

Name	Típus	Description
columnNames	AzureMachineLearningWebServiceInputColumn[]	Az Azure Machine Learning webszolgáltatás-végpontjának bemeneti oszlopainak listája.
name	string	A bemenet neve. Ez a végpont készítésekor megadott név.

AzureMachineLearningWebServiceOutputColumn

Az Azure Machine Learning webszolgáltatás végpontjának kimeneti oszlopát ismerteti.

Name	Típus	Description
dataType	string	A kimeneti oszlop (Az Azure Machine Learning által támogatott) adattípusa. Az érvényes Azure Machine Learning-adattípusok listáját itt https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx találja: .
name	string	A kimeneti oszlop neve.

AzureSqlDatabaseOutputDataSource

Egy Azure SQL adatbázis kimeneti adatforrását ismerteti.

Name	Típus	Alapértelmezett érték	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.
properties.database	string		Az Azure SQL adatbázis neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.maxBatchCount	number		Az Sql Database-be való írás maximális Batch-száma, az alapértelmezett érték 10 000. PUT-kérelmek esetén nem kötelező.
properties.maxWriterCount	number		Az írók maximális száma, jelenleg csak 1 (egy író) és 0 (a lekérdezéspartíció alapján) érhető el. PUT-kérelmek esetén nem kötelező.
properties.password	string		A Azure SQL adatbázishoz való csatlakozáshoz használt jelszó. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.server	string		A Azure SQL adatbázist tartalmazó SQL-kiszolgáló neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.table	string		A tábla neve az Azure SQL adatbázisban. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.user	string		A Azure SQL adatbázishoz való csatlakozáshoz használt felhasználónév. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string: Microsoft.Sql/Server/Database		Azt jelzi, hogy az adatforrás kimenetének típusa milyen típusú lesz. PUT (CreateOrReplace) kérelmekhez szükséges.

AzureSqlReferenceInputDataSource

Egy Azure SQL adatbázis-referencia bemeneti adatforrását ismerteti.

Name	Típus	Description
properties.database	string	Ez az elem az adatforrás elemhez van társítva. Ez annak az adatbázisnak a neve, amelybe a kimenet meg lesz írva.
properties.deltaSnapshotQuery	string	Ez az elem az adatforrás elemhez van társítva. Ez a lekérdezés növekményes módosítások beolvasására szolgál az SQL-adatbázisból. A beállítás használatához azt javasoljuk, hogy Azure SQL Database-ben használjon temporális táblákat.
properties.fullSnapshotQuery	string	Ez az elem az adatforrás elemhez van társítva. Ez a lekérdezés az sql-adatbázis adatainak lekérésére szolgál.
properties.password	string	Ez az elem az adatforrás elemhez van társítva. Ez a jelszó lesz használva a SQL Database példányhoz való csatlakozáshoz.
properties.refreshRate	string	Ez az elem az adatforrás elemhez van társítva. Ez azt jelzi, hogy milyen gyakran lesznek lekérve az adatok az adatbázisból. DateTime formátumú.
properties.refreshType	RefreshType	Az adatfrissítési lehetőség típusát jelzi.
properties.server	string	Ez az elem az adatforrás elemhez van társítva. Ez annak a kiszolgálónak a neve, amely a beírt adatbázist tartalmazza.
properties.table	string	Ez az elem az adatforrás elemhez van társítva. A tábla neve a Azure SQL adatbázisban.
properties.user	string	Ez az elem az adatforrás elemhez van társítva. Ez az a felhasználónév, amelyet a SQL Database-példányhoz való csatlakozáshoz használunk.
type	string: Microsoft.Sql/Server/Database	A referenciaadatokat tartalmazó bemeneti adatforrás típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.

AzureSynapseOutputDataSource

Egy Azure Synapse kimeneti adatforrást ismertet.

Name	Típus	Description
properties.database	string	Az Azure SQL adatbázis neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.password	string	A Azure SQL adatbázishoz való csatlakozáshoz használt jelszó. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.server	string	A Azure SQL adatbázist tartalmazó SQL-kiszolgáló neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.table	string	A tábla neve az Azure SQL adatbázisban. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.user	string	A Azure SQL adatbázishoz való csatlakozáshoz használt felhasználónév. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string: Microsoft.Sql/Server/DataWarehouse	Azt jelzi, hogy az adatforrás kimenetének típusa milyen típusú lesz. PUT (CreateOrReplace) kérelmekhez szükséges.

AzureTableOutputDataSource

Az Azure Table kimeneti adatforrását ismerteti.

Name	Típus	Description
properties.accountKey	string	Az Azure Storage-fiók fiókkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.accountName	string	Az Azure Storage-fiók neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.batchSize	integer	Az Azure Tablebe egyszerre írandó sorok száma.
properties.columnsToRemove	string[]	Ha meg van adva, a tömb minden eleme annak az oszlopnak a neve, amely eltávolítja (ha van) a kimeneti eseményentitásokból.
properties.partitionKey	string	Ez az elem egy oszlop nevét jelzi a lekérdezés SELECT utasításából, amely az Azure Table partíciókulcsaként lesz használva. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.rowKey	string	Ez az elem egy oszlop nevét jelzi a lekérdezés SELECT utasításából, amely az Azure Table sorkulcsaként lesz használva. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.table	string	Az Azure Table neve. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string: Microsoft.Storage/Table	Azt jelzi, hogy milyen típusú adatforrás-kimenet lesz megírva. PUT (CreateOrReplace) kérelmekhez szükséges.

BlobOutputDataSource

Egy blob kimeneti adatforrását ismerteti.

Name	Típus	Alapértelmezett érték	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.
properties.blobPathPrefix	string		Blob elérési út előtagja.
properties.container	string		Egy tároló neve a társított Storage-fiókban. Ez a tároló tartalmazza azokat a blob(ok)t, amely(ek)ből olvasni vagy írni szeretne. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.dateFormat	string		A dátumformátum. Ahol a(z) {date} megjelenik a pathPattern fájlban, a tulajdonság értéke lesz a dátumformátum.
properties.pathPattern	string		A blob elérési útjának mintája. Nem reguláris kifejezés. Ez egy mintát jelöl, amely alapján a blobnevek egyeznek annak megállapításához, hogy a blobokat be kell-e vonni a feladat bemeneteként vagy kimeneteként. https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output Részletesebb https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input magyarázatot és példát talál.
properties.storageAccounts	StorageAccount[]		Egy vagy több Azure Storage-fiók listája. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.timeFormat	string		Az időformátum. Ahol a(z) {time} megjelenik a pathPatternben, a tulajdonság értéke időformátumként lesz használva.
type	string: Microsoft.Storage/Blob		Azt jelzi, hogy milyen típusú adatforrás-kimenet lesz megírva. PUT (CreateOrReplace) kérelmekhez szükséges.

BlobReferenceInputDataSource

Referenciaadatokat tartalmazó blobbemeneti adatforrást ismertet.

Name	Típus	Alapértelmezett érték	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.
properties.container	string		Egy tároló neve a társított Storage-fiókon belül. Ez a tároló tartalmazza azokat a blob(ka)t, amely(ek)ből beolvasandó vagy beírandó. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.dateFormat	string		A dátumformátum. Ahol a(z) {date} megjelenik a pathPattern fájlban, a tulajdonság értéke lesz a dátumformátum.
properties.pathPattern	string		A blob elérési útjának mintája. Nem reguláris kifejezés. Ez egy mintát jelöl, amely alapján a rendszer egyezteti a blobneveket annak meghatározásához, hogy azokat bemenetként vagy kimenetként kell-e hozzáadni a feladathoz. Részletesebb https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input magyarázatot és példát találhat a vagy https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output a cikkben.
properties.storageAccounts	StorageAccount[]		Egy vagy több Azure Storage-fiók listája. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.timeFormat	string		Az időformátum. Ahol a(z) {time} megjelenik a pathPatternben, a tulajdonság értéke időformátumként lesz használva.
type	string: Microsoft.Storage/Blob		A referenciaadatokat tartalmazó bemeneti adatforrás típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.

BlobStreamInputDataSource

Egy streamadatokat tartalmazó blobbemeneti adatforrást ismertet.

Name	Típus	Alapértelmezett érték	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.
properties.container	string		Egy tároló neve a társított Storage-fiókon belül. Ez a tároló tartalmazza azokat a blob(ka)t, amely(ek)ből beolvasandó vagy beírandó. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.dateFormat	string		A dátumformátum. Ahol a(z) {date} megjelenik a pathPattern fájlban, a tulajdonság értéke lesz a dátumformátum.
properties.pathPattern	string		A blob elérési útjának mintája. Nem reguláris kifejezés. Ez egy mintát jelöl, amely alapján a rendszer egyezteti a blobneveket annak meghatározásához, hogy azokat bemenetként vagy kimenetként kell-e hozzáadni a feladathoz. Részletesebb https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input magyarázatot és példát találhat a vagy https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output a cikkben.
properties.sourcePartitionCount	integer		A blobbemeneti adatforrás partíciószáma. Tartomány: 1–1024.
properties.storageAccounts	StorageAccount[]		Egy vagy több Azure Storage-fiók listája. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.timeFormat	string		Az időformátum. Ahol a(z) {time} megjelenik a pathPattern fájlban, a tulajdonság értéke időformátumként lesz használva.
type	string: Microsoft.Storage/Blob		A streamadatokat tartalmazó bemeneti adatforrás típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.

ClusterInfo

A Stream Analytics-fürthöz társított tulajdonságok.

Name	Típus	Description
id	string	A fürt erőforrás-azonosítója.

CompatibilityLevel

Szabályozza a streamelési feladat futásidejű viselkedését.

Name	Típus	Description
1.0	string
1.2	string

Compression

A bemeneti adatok tömörítésének módját ismerteti

Name	Típus	Alapértelmezett érték	Description
type	CompressionType	None	A bemenet által használt tömörítés típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.

CompressionType

A bemenet által használt tömörítés típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.

Name	Típus	Description
Deflate	string
GZip	string
None	string

ContentStoragePolicy

Az érvényes értékek a JobStorageAccount és a SystemAccount. Ha a JobStorageAccount értékre van állítva, a felhasználónak meg kell adnia a jobStorageAccount tulajdonságot is. .

Name	Típus	Description
JobStorageAccount	string
SystemAccount	string

CsvSerialization

Bemutatja, hogyan szerializálják a bemenetből származó adatokat, vagy hogyan szerializálják az adatokat, amikor CSV formátumban írnak kimenetbe.

Name	Típus	Description
properties.encoding	Encoding	Meghatározza a bejövő adatok kódolását bemenet esetén, valamint a kimenő adatok kódolását kimenet esetén. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.fieldDelimiter	string	Meghatározza a vesszővel elválasztott értékrekordok (CSV) elválasztására használható elválasztó karaktert. A támogatott értékek listájának megtekintése https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input vagy https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output megtekintése. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string: Csv	Azt a szerializálási típust jelzi, amelyet a bemenet vagy a kimenet használ. PUT (CreateOrReplace) kérelmekhez szükséges.

DiagnosticCondition

Az erőforrásra vagy a feladatra vonatkozó olyan feltétel, amely az ügyfelek figyelmét felkelti.

Name	Típus	Description
code	string	Az átlátszatlan diagnosztikai kód.
message	string	A feltételt részletesen leíró, ember által olvasható üzenet. Az ügyfélkérés Accept-Language honosítva.
since	string	A feltétel kezdetének UTC időbélyege. Az ügyfeleknek ebben az időszakban meg kell tudniuk találni a megfelelő eseményt az operatív naplóban.

Diagnostics

A bemenetre, kimenetre vagy a feladatra vonatkozó feltételeket ismerteti, amelyek garantálják az ügyfelek figyelmét.

Name	Típus	Description
conditions	DiagnosticCondition[]	Az erőforrásra vagy a feladatra vonatkozó nulla vagy több feltétel gyűjteménye, amely garantálja az ügyfelek figyelmét.

DocumentDbOutputDataSource

Egy DocumentDB kimeneti adatforrást ismertet.

Name	Típus	Description
properties.accountId	string	A DocumentDB-fiók neve vagy azonosítója. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.accountKey	string	A DocumentDB-fiók fiókkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.collectionNamePattern	string	A használni kívánt gyűjtemények gyűjteménynév-mintája. A gyűjteménynév formátuma az opcionális {partition} jogkivonattal hozható létre, ahol a partíciók 0-tól kezdődnek. További információt a DocumentDB szakaszában https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output talál. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.database	string	A DocumentDB-adatbázis neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.documentId	string	Az elsődleges kulcs megadásához használt kimeneti események mezőjének neve, amelyen a beszúrási vagy frissítési műveletek alapulnak.
properties.partitionKey	string	A kimeneti események mezőjének neve, amely a kimenet gyűjtemények közötti particionálásának kulcsát adja meg. Ha a "collectionNamePattern" tartalmazza a(z) {partition} tokent, ezt a tulajdonságot meg kell adni.
type	string: Microsoft.Storage/DocumentDB	Azt jelzi, hogy az adatforrás kimenetének típusa milyen típusú lesz. PUT (CreateOrReplace) kérelmekhez szükséges.

Encoding

Megadja a bejövő adatok kódolását bemenet esetén, valamint a kimenő adatok kódolását kimenet esetén.

Name	Típus	Description
UTF8	string

Error

Gyakori hibaábrázolás.

Name	Típus	Description
error	Error	Hibadefiníció tulajdonságai.

EventHubOutputDataSource

Az Event Hub kimeneti adatforrását ismerteti.

Name	Típus	Alapértelmezett érték	Description
authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.
properties.eventHubName	string		Az Eseményközpont neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.partitionKey	string		Az eseményadatok küldéséhez használt partíció meghatározásához használt kulcs/oszlop.
properties.propertyColumns	string[]		Az Event Hub kimenetéhez társított tulajdonságok.
serviceBusNamespace	string		A kívánt eseményközponthoz, Service Bus-üzenetsorhoz, Service Bus-témakörhöz stb. társított névtér. PUT (CreateOrReplace) kérelmekhez szükséges.
sharedAccessPolicyKey	string		A megadott megosztott hozzáférési szabályzat megosztott hozzáférési szabályzatkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
sharedAccessPolicyName	string		Az eseményközpont, a Service Bus-üzenetsor, a Service Bus-témakör stb. közös hozzáférési szabályzatának neve. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string: Microsoft.ServiceBus/EventHub		Azt jelzi, hogy milyen típusú adatforrás-kimenet lesz megírva. PUT (CreateOrReplace) kérelmekhez szükséges.

EventHubStreamInputDataSource

Egy streamadatokat tartalmazó eseményközpont bemeneti adatforrását ismerteti.

Name	Típus	Alapértelmezett érték	Description
authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.
properties.consumerGroupName	string		Egy eseményközpont fogyasztói csoportjának neve, amelyet az eseményközpont eseményeinek olvasásához kell használni. Ha több bemenethez külön fogyasztói csoportneveket ad meg, az egyes bemenetek ugyanazokat az eseményeket fogadják az eseményközpontból. Ha nincs megadva, a bemenet az Eseményközpont alapértelmezett fogyasztói csoportját használja.
properties.eventHubName	string		Az eseményközpont neve. PUT (CreateOrReplace) kérelmekhez szükséges.
serviceBusNamespace	string		A kívánt eseményközponthoz, Service Bus-üzenetsorhoz, Service Bus-témakörhöz stb. társított névtér. PUT (CreateOrReplace) kérelmekhez szükséges.
sharedAccessPolicyKey	string		A megadott megosztott hozzáférési szabályzat megosztott hozzáférési szabályzatkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
sharedAccessPolicyName	string		Az eseményközpont, a Service Bus-üzenetsor, a Service Bus-témakör stb. közös hozzáférési szabályzatának neve. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string: Microsoft.ServiceBus/EventHub		A streamadatokat tartalmazó bemeneti adatforrás típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.

EventHubV2OutputDataSource

Az Event Hub kimeneti adatforrását ismerteti.

Name	Típus	Alapértelmezett érték	Description
authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.
properties.eventHubName	string		Az eseményközpont neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.partitionKey	string		Az eseményadatok küldéséhez használt partíció meghatározásához használt kulcs/oszlop.
properties.propertyColumns	string[]		Az eseményközpont kimenetéhez társított tulajdonságok.
serviceBusNamespace	string		A kívánt eseményközponthoz, Service Bus-üzenetsorhoz, Service Bus-témakörhöz stb. társított névtér. PUT (CreateOrReplace) kérelmekhez szükséges.
sharedAccessPolicyKey	string		A megadott megosztott hozzáférési szabályzat megosztott hozzáférési szabályzatkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
sharedAccessPolicyName	string		Az eseményközpont, a Service Bus-üzenetsor, a Service Bus-témakör stb. közös hozzáférési szabályzatának neve. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string: Microsoft.EventHub/EventHub		Azt jelzi, hogy az adatforrás kimenetének típusa milyen típusú lesz. PUT (CreateOrReplace) kérelmekhez szükséges.

EventHubV2StreamInputDataSource

Egy streamadatokat tartalmazó eseményközpont bemeneti adatforrását ismerteti.

Name	Típus	Alapértelmezett érték	Description
authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.
properties.consumerGroupName	string		Egy eseményközpont fogyasztói csoportjának neve, amelyet az eseményközpont eseményeinek olvasásához kell használni. Ha több bemenethez külön fogyasztói csoportneveket ad meg, az egyes bemenetek ugyanazokat az eseményeket fogadják az eseményközpontból. Ha nincs megadva, a bemenet az Eseményközpont alapértelmezett fogyasztói csoportját használja.
properties.eventHubName	string		Az eseményközpont neve. PUT (CreateOrReplace) kérelmekhez szükséges.
serviceBusNamespace	string		A kívánt eseményközponthoz, Service Bus-üzenetsorhoz, Service Bus-témakörhöz stb. társított névtér. PUT (CreateOrReplace) kérelmekhez szükséges.
sharedAccessPolicyKey	string		A megadott megosztott hozzáférési szabályzat megosztott hozzáférési szabályzatkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
sharedAccessPolicyName	string		Az eseményközpont, a Service Bus-üzenetsor, a Service Bus-témakör stb. közös hozzáférési szabályzatának neve. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string: Microsoft.EventHub/EventHub		A streamadatokat tartalmazó bemeneti adatforrás típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.

EventSerializationType

A bemenet vagy kimenet által használt szerializáció típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.

Name	Típus	Description
Avro	string
Csv	string
Json	string
Parquet	string

EventsOutOfOrderPolicy

Azt a szabályzatot jelzi, amely a bemeneti eseménystreamben sorrendből érkező eseményekre alkalmazandó.

Name	Típus	Description
Adjust	string
Drop	string

FileReferenceInputDataSource

Referenciaadatokat tartalmazó fájlbemeneti adatforrást ismertet.

Name	Típus	Description
properties.path	string	A fájl elérési útja.
type	string: File	A referenciaadatokat tartalmazó bemeneti adatforrás típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.

Function

Egy függvényobjektum, amely az elnevezett függvényhez társított összes információt tartalmazza. Minden függvény egy streamelési feladat alatt található.

Name	Típus	Description
id	string	Erőforrás-azonosító
name	string	Erőforrás neve
properties	FunctionProperties: AggregateFunctionProperties ScalarFunctionProperties	A függvényhez társított tulajdonságok.
type	string	Erőforrás típusa

FunctionInput

Egy függvény egy bemeneti paraméterét ismerteti.

Name	Típus	Description
dataType	string	A függvénybemeneti paraméter (az Azure Stream Analytics által támogatott) adattípusa. Az érvényes Azure Stream Analytics-adattípusok listáját itt találja: https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	Jelölő, amely jelzi, hogy a paraméter konfigurációs paraméter-e. Igaz, ha ez a bemeneti paraméter várhatóan állandó. Az alapértelmezett érték a false (hamis).

FunctionOutput

Egy függvény kimenetét ismerteti.

Name	Típus	Description
dataType	string	A függvény kimenetének (Azure Stream Analytics által támogatott) adattípusa. Az érvényes Azure Stream Analytics-adattípusok listáját itt találja: https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

Az átjáró Message Bus kimeneti adatforrását ismerteti.

Name	Típus	Description
properties.topic	string	A Service Bus-témakör neve.
type	string: GatewayMessageBus	Azt jelzi, hogy milyen típusú adatforrás-kimenet lesz megírva. PUT (CreateOrReplace) kérelmekhez szükséges.

GatewayMessageBusStreamInputDataSource

Egy streamadatokat tartalmazó blobbemeneti adatforrást ismertet.

Name	Típus	Description
properties.topic	string	A Service Bus-témakör neve.
type	string: GatewayMessageBus	A streamadatokat tartalmazó bemeneti adatforrás típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.

Identity

Az identitás ellenőrzésének módját ismerteti

Name	Típus	Description
principalId	string	Az identitásnév azonosítója
tenantId	string	Az identitásbérlő azonosítója
type	string	Az identitás típusa

Input

Egy bemeneti objektum, amely a nevesített bemenethez társított összes információt tartalmazza. Minden bemenet egy streamelési feladat alatt található.

Name	Típus	Description
id	string	Erőforrás-azonosító
name	string	Erőforrás neve
properties	InputProperties: ReferenceInputProperties StreamInputProperties	A bemenethez társított tulajdonságok. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string	Erőforrás típusa

IoTHubStreamInputDataSource

A streamadatokat tartalmazó IoT Hub bemeneti adatforrást ismerteti.

Name	Típus	Description
properties.consumerGroupName	string	Egy IoT Hub fogyasztói csoport neve, amelyet a IoT Hub eseményeinek olvasásához kell használni. Ha nincs megadva, a bemenet az Iot Hub alapértelmezett fogyasztói csoportját használja.
properties.endpoint	string	A IoT Hub végpont, amelyhez csatlakozni szeretne (pl. üzenetek/események, üzenetek/műveletekMonitoringEvents stb.).
properties.iotHubNamespace	string	A IoT Hub neve vagy URI-ja. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.sharedAccessPolicyKey	string	A megadott megosztott hozzáférési szabályzat megosztott hozzáférési szabályzatkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.sharedAccessPolicyName	string	A IoT Hub megosztott hozzáférési szabályzatának neve. Ennek a szabályzatnak tartalmaznia kell legalább a Service Connect engedélyét. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string: Microsoft.Devices/IotHubs	A streamadatokat tartalmazó bemeneti adatforrás típusát jelzi. PUT (CreateOrReplace) kérelmekhez szükséges.

JavaScriptFunctionBinding

A JavaScript-függvényhez való kötés.

Name	Típus	Description
properties.script	string	Egy függvénydefiníciót tartalmazó JavaScript-kód. Például: "függvény (x, y) { x + y; }"
type	string: Microsoft.StreamAnalytics/JavascriptUdf	A függvénykötés típusát jelzi.

JobStorageAccount

Az MSI-vel rendelkező Azure Storage-fiókhoz társított tulajdonságok

Name	Típus	Alapértelmezett érték	Description
accountKey	string		Az Azure Storage-fiók fiókkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
accountName	string		Az Azure Storage-fiók neve. PUT (CreateOrReplace) kérelmekhez szükséges.
authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.

JobType

A feladat típusát ismerteti. Az érvényes módok az és az Cloud "Edge".

Name	Típus	Description
Cloud	string
Edge	string

JsonOutputSerializationFormat

Megadja annak a JSON-fájlnak a formátumát, amelyben a kimenet meg lesz írva. A jelenleg támogatott értékek "lineSeparated", amely azt jelzi, hogy a kimenet úgy lesz formázva, hogy minden JSON-objektumot egy új sor választ el egymástól, a "tömb" pedig azt jelzi, hogy a kimenet JSON-objektumok tömbjeként lesz formázva.

Name	Típus	Description
Array	string
LineSeparated	string

JsonSerialization

Bemutatja, hogyan szerializálja a bemenetből származó adatokat, vagy hogyan szerializálja az adatokat, amikor JSON formátumú kimenetre írnak.

Name	Típus	Description
properties.encoding	Encoding	Meghatározza a bejövő adatok kódolását bemenet esetén, valamint a kimenő adatok kódolását kimenet esetén. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.format	JsonOutputSerializationFormat	Ez a tulajdonság csak a kimenetek JSON-szerializálására vonatkozik. A bemenetekre nem alkalmazható. Ez a tulajdonság határozza meg annak a JSON-nak a formátumát, amelyben a kimenet meg lesz írva. A jelenleg támogatott értékek a "lineSeparated", amely azt jelzi, hogy a kimenet úgy lesz formázva, hogy minden JSON-objektumot egy új sor választ el egymástól, a "tömb" pedig azt jelzi, hogy a kimenet JSON-objektumok tömbjeként lesz formázva. Az alapértelmezett érték a "lineSeparated" (Sorszeparated) érték, ha a bal oldali null érték.
type	string: Json	Azt a szerializálási típust jelzi, amelyet a bemenet vagy a kimenet használ. PUT (CreateOrReplace) kérelmekhez szükséges.

Output

Egy kimeneti objektum, amely a nevesített kimenethez társított összes információt tartalmazza. Az összes kimenetet egy streamelési feladat tartalmazza.

Name	Típus	Description
id	string	Erőforrás-azonosító
name	string	Erőforrás neve
properties.datasource	OutputDataSource: AzureDataLakeStoreOutputDataSource AzureFunctionOutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource AzureTableOutputDataSource BlobOutputDataSource DocumentDbOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource GatewayMessageBusOutputDataSource PowerBIOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource	Ez a cikk azt az adatforrást ismerteti, amelybe a kimenetet írni fogja. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.diagnostics	Diagnostics	A bemenetre, kimenetre vagy teljes feladatra vonatkozó feltételeket ismerteti, amelyek az ügyfelek figyelmét teszik szükségessé.
properties.etag	string	A kimenet aktuális entitáscímkéje. Ez egy átlátszatlan sztring. Segítségével megállapíthatja, hogy az erőforrás megváltozott-e a kérések között. A If-Match vagy az If-None-Match fejlécekben is használhatja az optimista egyidejűség érdekében végzett írási műveletekhez.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	A bemenetből származó adatok szerializálását, illetve az adatok kimenetbe írásakor történő szerializálását ismerteti. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.sizeWindow	integer	A Stream Analytics-kimenetet korlátozó méretablak.
properties.timeWindow	string	A Stream Analytics-feladatok kimeneteinek szűrésére szolgáló időkeret.
type	string	Erőforrás típusa

OutputErrorPolicy

Azt a szabályzatot jelzi, amely a kimenetbe érkező eseményekre alkalmazandó, és nem írható a külső tárolóba helytelen formázás miatt (hiányzó oszlopértékek, helytelen típusú vagy méretű oszlopértékek).

Name	Típus	Description
Drop	string
Stop	string

OutputStartMode

Az érték lehet JobStartTime, CustomTime vagy LastOutputEventTime, amely jelzi, hogy a kimeneti eseménystream kezdőpontja a feladat indításakor induljon el, a outputStartTime tulajdonságon keresztül megadott egyéni felhasználói időbélyeggel kezdődjön, vagy az utolsó esemény kimeneti időpontjától induljon el.

Name	Típus	Description
CustomTime	string
JobStartTime	string
LastOutputEventTime	string

ParquetSerialization

Bemutatja, hogyan szerializálják a bemenetből származó adatokat, vagy hogyan szerializálják az adatokat parquet formátumú kimenetbe írva.

Name	Típus	Description
type	string: Parquet	Azt a szerializálási típust jelzi, amelyet a bemenet vagy a kimenet használ. PUT (CreateOrReplace) kérelmekhez szükséges.

PowerBIOutputDataSource

A Power BI kimeneti adatforrását ismerteti.

Name	Típus	Alapértelmezett érték	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.
properties.dataset	string		A Power BI-adathalmaz neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.groupId	string		A Power BI-csoport azonosítója.
properties.groupName	string		A Power BI-csoport neve. Ezzel a tulajdonságmal emlékezhet arra, hogy melyik Power BI-csoportazonosítót használta.
properties.refreshToken	string		Egy frissítési jogkivonat, amely egy érvényes hozzáférési jogkivonat beszerzésére használható, amelyet aztán az adatforrással való hitelesítéshez használhat. Egy érvényes frissítési jogkivonat jelenleg csak az Azure Portalon érhető el. Javasoljuk, hogy az adatforrás létrehozásakor helyezzen ide egy üres sztringértéket, majd lépjen az Azure Portalra az adatforrás hitelesítéséhez, amely érvényes frissítési jogkivonattal frissíti ezt a tulajdonságot. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.table	string		A Power BI-tábla neve a megadott adathalmaz alatt. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.tokenUserDisplayName	string		A frissítési jogkivonat beszerzéséhez használt felhasználó megjelenítendő neve. Ezzel a tulajdonságtal emlékezhet arra, hogy melyik felhasználót használták a frissítési jogkivonat beszerzéséhez.
properties.tokenUserPrincipalName	string		A frissítési jogkivonat beszerzéséhez használt felhasználó egyszerű felhasználóneve (UPN). Ezzel a tulajdonságtal emlékezhet arra, hogy melyik felhasználót használták a frissítési jogkivonat beszerzéséhez.
type	string: PowerBI		Azt jelzi, hogy milyen típusú adatforrás-kimenet lesz megírva. PUT (CreateOrReplace) kérelmekhez szükséges.

ReferenceInputProperties

A referenciaadatokat tartalmazó bemenethez társított tulajdonságok.

Name	Típus	Description
compression	Compression	A bemeneti adatok tömörítésének módját ismerteti
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Referenciaadatokat tartalmazó bemeneti adatforrást ismertet. PUT (CreateOrReplace) kérelmekhez szükséges.
diagnostics	Diagnostics	A bemenetre, kimenetre vagy a feladatra vonatkozó feltételeket ismerteti, amelyek garantálják az ügyfelek figyelmét.
etag	string	A bemenet aktuális entitáscímkéje. Ez egy átlátszatlan sztring. Segítségével észlelheti, hogy az erőforrás megváltozott-e a kérések között. A If-Match vagy az If-None-Match fejlécekben is használhatja az optimista egyidejűség érdekében végzett írási műveletekhez.
partitionKey	string	partitionKey A bemeneti adatok egyik kulcsát ismerteti, amelyet a bemeneti adatok particionálására használnak
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Bemutatja, hogyan szerializálja a bemenetből származó adatokat, vagy hogyan szerializálja az adatokat a kimenetbe írva. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string: Reference	Azt jelzi, hogy a bemenet referenciaadatok forrása vagy streamadatok forrása. PUT (CreateOrReplace) kérelmekhez szükséges.

RefreshType

Az adatfrissítési lehetőség típusát jelzi.

Name	Típus	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

ScalarFunctionProperties

A skaláris függvényhez társított tulajdonságok.

Name	Típus	Description
etag	string	A függvény aktuális entitáscímkéje. Ez egy átlátszatlan sztring. Segítségével észlelheti, hogy az erőforrás megváltozott-e a kérések között. A If-Match vagy az If-None-Match fejlécekben is használhatja az optimista egyidejűség érdekében végzett írási műveletekhez.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	A függvény fizikai kötése. Az Azure Machine Learning webszolgáltatás esetében például ez a végpontot írja le.
properties.inputs	FunctionInput[]	Egy függvény egyik bemeneti paraméterét ismerteti.
properties.output	FunctionOutput	Egy függvény kimenetét ismerteti.
type	string: Scalar	A függvény típusát jelzi.

ServiceBusQueueOutputDataSource

Egy Service Bus-üzenetsor kimeneti adatforrását ismerteti.

Name	Típus	Alapértelmezett érték	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.
properties.propertyColumns	string[]		A Service Bus-üzenetekhez egyéni tulajdonságként csatolandó kimeneti oszlopok nevének sztringtömbje.
properties.queueName	string		A Service Bus-üzenetsor neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.serviceBusNamespace	string		A kívánt eseményközponthoz, Service Bus-üzenetsorhoz, Service Bus-témakörhöz stb. társított névtér. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.sharedAccessPolicyKey	string		A megadott megosztott hozzáférési szabályzat megosztott hozzáférési szabályzatkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.sharedAccessPolicyName	string		Az eseményközpont, a Service Bus-üzenetsor, a Service Bus-témakör stb. közös hozzáférési szabályzatának neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.systemPropertyColumns	object		A Service Bus-üzenetsorhoz társított rendszertulajdonságok. A következő rendszertulajdonságok támogatottak: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
type	string: Microsoft.ServiceBus/Queue		Azt jelzi, hogy az adatforrás kimenetének típusa milyen típusú lesz. PUT (CreateOrReplace) kérelmekhez szükséges.

ServiceBusTopicOutputDataSource

Egy Service Bus-témakör kimeneti adatforrását ismerteti.

Name	Típus	Alapértelmezett érték	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Hitelesítési mód.
properties.propertyColumns	string[]		A Service Bus-üzenetekhez egyéni tulajdonságként csatolandó kimeneti oszlopok nevének sztringtömbje.
properties.serviceBusNamespace	string		A kívánt eseményközponthoz, Service Bus-üzenetsorhoz, Service Bus-témakörhöz stb. társított névtér. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.sharedAccessPolicyKey	string		A megadott megosztott hozzáférési szabályzat megosztott hozzáférési szabályzatkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.sharedAccessPolicyName	string		Az eseményközpont, a Service Bus-üzenetsor, a Service Bus-témakör stb. közös hozzáférési szabályzatának neve. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.systemPropertyColumns	object		A Service Bus-témakör kimenetéhez társított rendszertulajdonságok. A következő rendszertulajdonságok támogatottak: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
properties.topicName	string		A Service Bus-témakör neve. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string: Microsoft.ServiceBus/Topic		Azt jelzi, hogy az adatforrás kimenetének típusa milyen típusú lesz. PUT (CreateOrReplace) kérelmekhez szükséges.

Sku

A termékváltozathoz társított tulajdonságok.

Name	Típus	Description
name	SkuName	A termékváltozat neve. PUT (CreateOrReplace) kérelmekhez szükséges.

SkuName

A termékváltozat neve. PUT (CreateOrReplace) kérelmekhez szükséges.

Name	Típus	Description
Standard	string

StorageAccount

Az Azure Storage-fiókhoz társított tulajdonságok

Name	Típus	Description
accountKey	string	Az Azure Storage-fiók fiókkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
accountName	string	Az Azure Storage-fiók neve. PUT (CreateOrReplace) kérelmekhez szükséges.

StreamingJob

Egy streamelési feladat objektuma, amely a nevesített streamelési feladathoz társított összes információt tartalmazza.

Name	Típus	Description
id	string	Az erőforrás teljes erőforrás-azonosítója. Ex – /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	A feladathoz hozzárendelt rendszer által hozzárendelt felügyelt identitást ismerteti, amely bemenetekkel és kimenetekkel történő hitelesítésre használható.
location	string	Az a földrajzi hely, ahol az erőforrás él
name	string	Az erőforrás neve
properties.cluster	ClusterInfo	Az a fürt, amelyen a streamelési feladatok futni fognak.
properties.compatibilityLevel	CompatibilityLevel	A streamelési feladat futásidejének bizonyos viselkedését szabályozza.
properties.contentStoragePolicy	ContentStoragePolicy	Az érvényes értékek a JobStorageAccount és a SystemAccount. Ha a JobStorageAccount értékre van állítva, a felhasználónak meg kell adnia a jobStorageAccount tulajdonságot is. .
properties.createdDate	string	Az érték egy ISO-8601 formátumú UTC időbélyeg, amely azt jelzi, hogy mikor jött létre a streamelési feladat.
properties.dataLocale	string	A Stream Analytics-feladat adat területi beállítása. Az értéknek egy támogatott .NET-kulturális környezetnek kell lennie a készletből https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Alapértelmezés szerint "en-US", ha nincs megadva.
properties.etag	string	A streamelési feladat aktuális entitáscímkéje. Ez egy átlátszatlan sztring. Segítségével észlelheti, hogy az erőforrás megváltozott-e a kérések között. A If-Match vagy az If-None-Match fejlécekben is használhatja az optimista egyidejűség érdekében végzett írási műveletekhez.
properties.eventsLateArrivalMaxDelayInSeconds	integer	A maximális elviselhető késleltetés másodpercben, amikor a későn érkező események belefoglalhatók. A támogatott tartomány -1 és 1814399 (20.23:59:59 nap), a -1 pedig a határozatlan ideig tartó várakozás megadására szolgál. Ha a tulajdonság hiányzik, a rendszer úgy értelmezi, hogy értéke -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	A maximális elviselhető késleltetés másodpercben, amikor a sorrenden kívüli események visszaállíthatók a sorrendbe.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	A bemeneti eseménystreamben sorrenden kívül érkező eseményekre alkalmazandó szabályzatot jelzi.
properties.functions	Function[]	A streamelési feladat egy vagy több függvényének listája. Az egyes függvények névtulajdonságára akkor van szükség, ha put kérelemben adja meg ezt a tulajdonságot. Ez a tulajdonság patch művelettel nem módosítható. Az egyéni átalakításhoz elérhető PATCH API-t kell használnia.
properties.inputs	Input[]	A streamelési feladat egy vagy több bemenetének listája. A tulajdonság PUT-kérelemben való megadásakor minden bemenethez meg kell adni a name tulajdonságot. Ez a tulajdonság patch művelettel nem módosítható. Az egyes bemenetekhez elérhető PATCH API-t kell használnia.
properties.jobId	string	A streamelési feladatot egyedileg azonosító GUID. Ez a GUID a streamelési feladat létrehozásakor jön létre.
properties.jobState	string	A streamelési feladat állapotát ismerteti.
properties.jobStorageAccount	JobStorageAccount	Az Azure Storage-fiókhoz és az MSI-hez társított tulajdonságok
properties.jobType	JobType	A feladat típusát ismerteti. Az érvényes módok a és az Cloud "Edge".
properties.lastOutputEventTime	string	Az érték egy ISO-8601 formátumú időbélyeg, amely a streamelési feladat utolsó kimeneti eseményének időpontját jelzi, vagy null érték, amely azt jelzi, hogy a kimenet még nem lett létrehozva. Több kimenet vagy több stream esetén ez a készlet legújabb értékét jeleníti meg.
properties.outputErrorPolicy	OutputErrorPolicy	Azt a házirendet jelzi, amely a kimenetre érkező eseményekre alkalmazandó, és helytelen formátumú (hiányzó oszlopértékek, nem megfelelő típusú vagy méretű oszlopértékek) miatt nem írható a külső tárolóba.
properties.outputStartMode	OutputStartMode	Ezt a tulajdonságot csak akkor szabad használni, ha azt szeretné, hogy a feladat a létrehozás után azonnal elinduljon. Az érték lehet JobStartTime, CustomTime vagy LastOutputEventTime, amely jelzi, hogy a kimeneti eseménystream kezdőpontja a feladat indításakor induljon el, a outputStartTime tulajdonságon keresztül megadott egyéni felhasználói időbélyeggel induljon, vagy az utolsó esemény kimeneti időpontjától induljon.
properties.outputStartTime	string	Az érték egy ISO-8601 formátumú időbélyeg, amely a kimeneti eseménystream kiindulási pontját jelzi, vagy null érték, amely azt jelzi, hogy a kimeneti eseménystream a streamelési feladat indításakor indul el. Ennek a tulajdonságnak értékkel kell rendelkeznie, ha az outputStartMode customTime értékre van állítva.
properties.outputs	Output[]	A streamelési feladat egy vagy több kimenetének listája. A tulajdonság PUT-kérelemben való megadásakor minden kimenethez meg kell adni a name tulajdonságot. Ez a tulajdonság patch művelettel nem módosítható. Az egyes kimenetekhez elérhető PATCH API-t kell használnia.
properties.provisioningState	string	A streamelési feladat kiépítési állapotát ismerteti.
properties.sku	Sku	A streamelési feladat termékváltozatát ismerteti. PUT (CreateOrReplace) kérelmekhez szükséges.
properties.transformation	Transformation	A lekérdezést és a streamelési feladathoz használandó streamelési egységek számát jelzi. Az átalakítás névtulajdonságára akkor van szükség, ha put kérelemben adja meg ezt a tulajdonságot. Ez a tulajdonság patch művelettel nem módosítható. Az egyes átalakításokhoz elérhető PATCH API-t kell használnia.
tags	object	Erőforráscímkék.
type	string	Az erőforrás típusa. Például: Microsoft.Compute/virtualMachines vagy Microsoft.Storage/storageAccounts.

StreamInputProperties

A streamadatokat tartalmazó bemenethez társított tulajdonságok.

Name	Típus	Description
compression	Compression	A bemeneti adatok tömörítésének módját ismerteti
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	A streamadatokat tartalmazó bemeneti adatforrást ismerteti. PUT (CreateOrReplace) kérelmekhez szükséges.
diagnostics	Diagnostics	A bemenetre, kimenetre vagy a feladatra vonatkozó feltételeket ismerteti, amelyek garantálják az ügyfelek figyelmét.
etag	string	A bemenet aktuális entitáscímkéje. Ez egy átlátszatlan sztring. Segítségével észlelheti, hogy az erőforrás megváltozott-e a kérések között. A If-Match vagy az If-None-Match fejlécekben is használhatja az optimista egyidejűség érdekében végzett írási műveletekhez.
partitionKey	string	partitionKey A bemeneti adatok egyik kulcsát ismerteti, amelyet a bemeneti adatok particionálására használnak
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Bemutatja, hogyan szerializálja a bemenetből származó adatokat, vagy hogyan szerializálja az adatokat a kimenetbe írva. PUT (CreateOrReplace) kérelmekhez szükséges.
type	string: Stream	Azt jelzi, hogy a bemenet referenciaadatok forrása vagy streamadatok forrása. PUT (CreateOrReplace) kérelmekhez szükséges.

Transformation

Egy átalakítási objektum, amely az elnevezett átalakításhoz társított összes információt tartalmazza. Az összes átalakítást egy streamelési feladat tartalmazza.

Name	Típus	Alapértelmezett érték	Description
id	string		Erőforrás-azonosító
name	string		Erőforrás neve
properties.etag	string		Az átalakítás aktuális entitáscímkéje. Ez egy átlátszatlan sztring. Segítségével megállapíthatja, hogy az erőforrás megváltozott-e a kérések között. A If-Match vagy az If-None-Match fejlécekben is használhatja az optimista egyidejűség érdekében végzett írási műveletekhez.
properties.query	string		Megadja a streamelési feladatban futtatandó lekérdezést. A Stream Analytics lekérdezési nyelvéről (SAQL) itt tudhat meg többet: https://msdn.microsoft.com/library/azure/dn834998 . PUT (CreateOrReplace) kérelmekhez szükséges.
properties.streamingUnits	integer	3	A streamelési feladat által használt streamelési egységek számát adja meg.
properties.validStreamingUnits	integer[]		Megadja, hogy a streamelési feladat mely érvényes streamelési egységekre méretezhető.
type	string		Erőforrás típusa